软件环境:goland
之前用纯逻辑垒完了一个可登入登出的在线多人聊天室(代码仓库地址),这次学习了protobuf协议,于是想试着更新下聊天室的版本。
主要目的是为了掌握protobuf的使用。
通过protobuf中内置好的编码函数,将要发送的数据进行编码,之后在“编码后的”数据前加入协议号和报头,再转码通过write与read函数进行数据的发送和接收。
//客户端,对接收到的数据进行解码
newtest := &protocol.conn_tos{}
err = proto.unmarshal(msgdata[0:msgdata_read],newtest)
if err != nil{
log.fatal("unmarshaling error:",err)
}
fmt.println(newtest.getnickname(),newtest.getmsg())
//服务端,接收到信息并遍历map发送消息
datamsg := make([]byte,255)
datamsg_read ,err := conn.read(datamsg)
if datamsg_read == 0 || err != nil{
continue
}
fmt.println(datamsg[0:datamsg_read])
for _,v := range connmap{
v.write(datamsg[0:datamsg_read])
}
1,注意字节处的拼接,建议使用append函数;
2,处理连接处注意对数据编码解码的处理;
3,设置map存所有连服务端的客户端连接,并到需要时遍历输出和转发消息至map中所有的连接;
server端
client1端
client2端
client3端
如对本文有疑问, 点击进行留言回复!!
网友评论