Go語(yǔ)言實(shí)現(xiàn)服務(wù)端消息接收和發(fā)送

第Go語(yǔ)言實(shí)現(xiàn)服務(wù)端消息接收和發(fā)送本文實(shí)例為大家分享了Go實(shí)現(xiàn)服務(wù)端消息接收和發(fā)送的具體代碼，供大家參考，具體內(nèi)容如下

一.服務(wù)端接收數(shù)據(jù)并返回?cái)?shù)據(jù)

服務(wù)端代碼

packagemain

import(

"net"

"fmt"

funcmain(){

//創(chuàng)建TCPAddress變量,指定協(xié)議tcp4,監(jiān)聽(tīng)本機(jī)8899端口

addr,_:=net.ResolveTCPAddr("tcp4","localhost:8899")

//監(jiān)聽(tīng)TCPAddress設(shè)定的地址

lis,_:=net.ListenTCP("tcp4",addr)

fmt.Println("服務(wù)器已啟動(dòng)")

//阻塞式等待客戶(hù)端消息,返回連接對(duì)象,用于接收客戶(hù)端消息或向客戶(hù)端發(fā)送消息

conn,_:=lis.Accept()

//把數(shù)據(jù)讀取到切片中

b:=make([]byte,256)

fmt.Println("read之前")

//客戶(hù)端沒(méi)有發(fā)送數(shù)據(jù)且客戶(hù)端對(duì)象沒(méi)有關(guān)閉,Read()將會(huì)阻塞,一旦接收到數(shù)據(jù)就不阻塞

count,_:=conn.Read(b)

fmt.Println("接收到的數(shù)據(jù):",string(b[:count]))

/*

向客戶(hù)端發(fā)送數(shù)據(jù)

*/

conn.Write([]byte("這是服務(wù)器傳遞的數(shù)據(jù)"))

//關(guān)閉連接

conn.Close()

fmt.Println("服務(wù)器結(jié)束")

}

客戶(hù)端代碼

packagemain

import(

"net"

"fmt"

funcmain(){

//服務(wù)器端ip和端口

addr,_:=net.ResolveTCPAddr("tcp4","localhost:8899")

//申請(qǐng)連接客戶(hù)端

conn,_:=net.DialTCP("tcp4",nil,addr)

//向服務(wù)端發(fā)送數(shù)據(jù)

count,_:=conn.Write([]byte("客戶(hù)端傳遞的數(shù)據(jù)"))

fmt.Println("客戶(hù)端向服務(wù)端發(fā)送的數(shù)據(jù)量為:",count)

/*

接收服務(wù)器傳遞回來(lái)的數(shù)據(jù)

*/

b:=make([]byte,256)

c,_:=conn.Read(b)

fmt.Println(string(b[:c]))

關(guān)閉連接

conn.Close()

fmt.Println("客戶(hù)端結(jié)束")

}

可以在服務(wù)端添加循環(huán),不停接收客戶(hù)端發(fā)送來(lái)的數(shù)據(jù),服務(wù)端代碼修改如下

packagemain

import(

"net"

"fmt"

funcmain(){

addr,_:=net.ResolveTCPAddr("tcp4","localhost:8899")

lis,_:=net.ListenTCP("tcp4",addr)

fmt.Println("服務(wù)器已啟動(dòng)")

/*

服務(wù)器端添加死循環(huán),不停的接收客戶(hù)端對(duì)象

*/

for{

conn,_:=lis.Accept()

b:=make([]byte,256)

count,_:=conn.Read(b)

nc:=string(b[:count])

fmt.Println("接收到的數(shù)據(jù):",nc)

conn.Write([]byte("服務(wù)器:"+nc))

conn.Close()

fmt.Println("服務(wù)器結(jié)束")

}

客戶(hù)端代碼修改如下

packagemain

import(

"net"

"fmt"

"strconv"

funcmain(){

//服務(wù)器端ip和端口

addr,_:=net.ResolveTCPAddr("tcp4","localhost:8899")

//通過(guò)循環(huán),模擬發(fā)送五次客戶(hù)端請(qǐng)求

fori:=1;ii++{

conn,_:=net.DialTCP("tcp4",nil,addr)

conn.Write([]byte("客戶(hù)端數(shù)據(jù)"+strconv.Itoa(i)))

b:=make([]byte,256)

c,_:=conn.Read(b)

fmt.Println("第",i,"次服務(wù)器返回的數(shù)據(jù):",string(b[:c]))

conn.Close()

fmt.Println("客戶(hù)端結(jié)束")

}

三.并發(fā)訪問(wèn)

上面代碼的問(wèn)題是服務(wù)器獲取到客戶(hù)端對(duì)象后,如果客戶(hù)端什么也沒(méi)有輸入,其他客戶(hù)端無(wú)法連接.可以通過(guò)結(jié)合goroutine完成并發(fā)訪問(wèn)

只需要修改server.go,在里面添加goroutine

packagemain

import(

"net"

"fmt"

funcmain(){

addr,_:=net.ResolveTCPAddr("tcp4","localhost:8899")

lis,_:=net.ListenTCP("tcp4",addr)

fmt.Println("服務(wù)器已啟動(dòng)")

/*

服務(wù)器端添加死循環(huán),不停的接收客戶(hù)端對(duì)象

*/

for{

conn,_:=lis.Accept()

gofunc(){//在此處添加創(chuàng)建gofunc()即可

b:=make([]byte,256)

count,_:=conn.Read(b)

nc:=string(b[:count])

fmt.Println("接收到的數(shù)據(jù):",n