Go语言的TCP网络通信框架，具备编码器和解码器接口，自己实现对应的编码器接口就行
服务的整体编写思路，实际上都是Go的常规路子，然后做了一个编码解码的封装。先构建服务对象，然后指定编码解码结构对象，启动服务器，然后开启一个接收客户理解的协程acceptClients，在这个go routine中执行等待客户连接，客户连接上来之后，会开启用户的读取数据Go routine,读取在数据的过程中将数据根据编码器进行解码成对应的结构对象，然后投递到解析处理队列，另外一个专门解析的go routine专门负责从队列中获得客户发送的数据对象进行操作然后触发OnRecvData事件，我们编写服务端代码的时候，主要就是实现这个接收事件进行处理。这里有一个专门的go routine来负责检查心跳，从客户队列中获取解码对象执行OnRecvData操作，以及从发送队列中获取发送对象进行编码，然后发送到客户并触发OnSendData事件。服务器内部会不断的检查心跳，心跳机制是设定了TimeOutSeconds不为0的时候，会使用Go内部的ReadDeadLine等方法自动处理，如果达到了这个时间执行失败的，就关闭连接，表示失败了，如果设定了TimeOutSeconds=0，则会比对最后一次读取或者发送数据成功的时间和当前的时间差，超过2分钟的，视为心跳失败，则关闭连接。
发送对象编码后的长度+发送的对象编码
dxserver.DxTcpServer的LimitSendPkgCout表示限制的包的发送队列，如果指定的长度大于0，则会构建一个发送通道，所有的发送对象会先到通道，然后从通道进行数据发送，如果指定为0，则发送对象的时候，就直接立即发送数据了。
RequestCount表示请求数量
SendRequestCount表示发送的请求数量
SendDataSize表示发送的数据量大小
RecvDataSize表示接受的数据量大小
OnRecvData客户端发送数据包过来之后执行，其中包含有编码器自动解码的出来对象
OnClientConnect客户端连接事件
OnClientDisConnected客户断开事件
OnSendData数据发送触发事件
TimeOutSeconds超时设定，默认为0，采用自带的go routine判定心跳
SetCoder(encoder IConCoder)设定编码器
Open(addr string)打开一个服务，addr是服务地址比如":8340"
RemoteAddr()对象的远程地址
Close()关闭连接
WriteObject(obj interface{})将对象编码之后发送回客户端
type EchoCoder struct {
}
//ECHO编码器编码，直接将内容写入到buf中
func (coder *EchoCoder)Encode(obj interface{},buf *bytes.Buffer) error {
buf.Write(obj.([]byte))
return nil
}
func (coder *EchoCoder)Decode(bytes []byte)(result interface{},ok bool) {
return bytes,true
}
func (coder *EchoCoder)HeadBufferLen()uint16 {
return 2
}
func (coder *EchoCoder)MaxBufferLen()uint16 {
return 1024
}
func NewEchoServer()*dxserver.DxTcpServer{
srv := new(dxserver.DxTcpServer)
srv.LimitSendPkgCount = 20
coder := new(EchoCoder)
srv.SetCoder(coder)
srv.OnRecvData = func(con *dxserver.DxNetConnection,recvData interface{}) {
//直接发送回去
con.WriteObject(recvData)
}
/*srv.OnClientConnect = func(con *dxserver.DxNetConnection){
//客户端登录了
fmt.Println("登录客户",srv.ClientCount())
}*/
return srv
}
//然后
func main(){
srv = EchoDemo.NewEchoServer()
srv.Open("127.0.0.1:8340")
}以上的编码器是直接将发送的内容返回写入到了Buf中了，如果是其他的格式，比如，如果是Json，那么编码器的编码函数可以写为
func (coder *JsonCoder)Decode(pkgbytes []byte)(result interface{},ok bool) {
buf := bytes.NewReader(pkgbytes[:])
decoder := json.NewDecoder(buf)
jsonpkg := new(JSONPKG)
ok = decoder.Decode(jsonpkg)==nil
if ok{
result = jsonpkg
}else{
result = nil
}
return
}
func (coder *JsonCoder)Encode(obj interface{},buf *bytes.Buffer) error {
encoder := json.NewEncoder(buf)
return encoder.Encode(obj)
}//服务器端
srv = Filesrv.NewFileServer(curExecDir)
srv.Open("127.0.0.1:8340")
//客户端
func main() {
app := controls.NewApplication()
app.ShowMainForm = false
mainForm := app.CreateForm()
PopMenu := NVisbleControls.NewPopupMenu(mainForm)
fclient = FileClient.NewFileClient()
fclient.OnDownLoad = func(client *FileClient.FileClient,FileName string,TotalSize,Position int64){
fmt.Println(FileName,"正在文件下载",Position*100/TotalSize,"%")
}
mItem := PopMenu.Items().AddItem("下载文件")
mItem.OnClick = func(sender interface{}) {
fclient.DownLoadFile("第2版394860.pdf","d:\\2.pdf")
fclient.DownLoadFile("游戏编程大师技巧(第二版.pdf","d:\\3.pdf")
}
mItem = PopMenu.Items().AddItem("-")
mItem = PopMenu.Items().AddItem("退出")
mItem.OnClick = func(sender interface{}) {
fclient.Close()
mainForm.Close()
}
trayicon := NVisbleControls.NewTrayIcon(mainForm)
trayicon.PopupMenu = PopMenu
trayicon.SetVisible(true)
fclient.Connect("127.0.0.1:8340")
app.Run()
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent