packet
0.1.0
通过 TCP 或 UDP 连接发送网络数据包。
数据包是代表单个网络消息的主类。它有一个指示消息类型的字节代码和一个[]byte
类型的有效负载。
流具有发送和接收通道,以及用于重新连接的热插拔连接。用户有责任注册回调以通过OnError
消耗错误。
// Connect to a server
conn , _ := net . Dial ( "tcp" , "localhost:7000" )
// Create a stream
stream := packet . NewStream ( 1024 )
stream . SetConnection ( conn )
// Send a message
stream . Outgoing <- packet . New ( 0 , [] byte ( "ping" ))
// Receive message
msg := <- stream . Incoming
// Check message contents
if string ( msg . Data ) != "pong"
// Close server connection to simulate server death
server . Close ()
// Send packet while server is down (will be buffered until it reconnects)
client . Outgoing <- packet . New ( 0 , [] byte ( "ping" ))
// Reconnect
newServer , _ := net . Dial ( "tcp" , "localhost:7000" )
// Hot-swap connection
client . SetConnection ( newServer )
// The previously buffered messages in the Outgoing channel will be sent now.
如果您想提出拉取请求,请查看样式指南。
冯志强 | 斯科特·拉亚普勒 | 爱德华·乌尔巴赫 |
想在这里看到你自己的名字吗?