Go語言實現TCP訊息傳送

2021-09-10 07:52:09 字數 779 閱讀 4953

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 ...