go語言實現tcp訊息傳送,乙個伺服器端乙個客戶端,客戶端向伺服器端傳送訊息顯示到伺服器端,當客戶端傳送exit則退出客戶端。
1.伺服器端
package main
import (
"fmt"
"net"
)func process(con net.conn)else }}
func main()
defer lister.close()//延時關閉listen
//迴圈等待客戶端連線
forelse
go process(conn)
} "lister=%v\n",lister)
}
2.客戶端
package main
import (
"bufio"
"fmt"
"net"
"os"
"strings"
)func main()
//功能一:客戶端可以傳送單行資料,然後退出
reader := bufio.newreader(os.stdin) 代表標準輸入【終端】
forline = strings.trim(line," \r\n")
if line == "exit"
//再將讀取的傳送給伺服器
_, err = conn.write(byte(line + "\n"))
if err != nil
}}
go 實現 kafka 訊息傳送 接收
kafka是訊息中介軟體的一種,是一種分布式流平台,是用於構建實時資料管道和流應用程式。具有橫向擴充套件,容錯,wicked fast 快 等優點。生產者 producer 將訊息記錄 record 傳送到kafka中的主題中 topic 乙個主題可以有多個分割槽 partition 訊息最終儲存在...
Go語言實現Valid Parentheses
write a function called that takes a string of parentheses,and determines if the order of the parentheses is valid.the function should return true if ...
java socke傳送tcp訊息
前言 因實際需求,第三方提供了乙個ip乙個埠,加一段報文和報文引數的說明就需要開發,呼叫介面。最開始也是懵,後來才醒悟是socket tcp請求不需要太難 string info try info buffer.tostring 4.關閉連線 br.close sck.close is.close ...