{"id":16852,"date":"2025-04-18T23:17:06","date_gmt":"2025-04-18T15:17:06","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/16852.html"},"modified":"2025-04-18T23:17:06","modified_gmt":"2025-04-18T15:17:06","slug":"%e5%b9%b6%e5%8f%91%e6%9c%8d%e5%8a%a1%e5%99%a8%e6%a1%86%e6%9e%b6-zinx","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/16852.html","title":{"rendered":"\u5e76\u53d1\u670d\u52a1\u5668\u6846\u67b6\u2014\u2014zinx"},"content":{"rendered":"

zinx\u6846\u67b6<\/h3>\n

Zinx \u662f\u4e00\u4e2a\u7528 Go \u8bed\u8a00\u7f16\u5199\u7684\u9ad8\u6027\u80fd\u3001\u8f7b\u91cf\u7ea7\u7684 TCP \u670d\u52a1\u5668\u6846\u67b6，\u5b83\u88ab\u8bbe\u8ba1\u4e3a\u7b80\u5355\u3001\u5feb\u901f\u4e14\u6613\u4e8e\u4f7f\u7528\u3002Zinx \u63d0\u4f9b\u4e86\u4e00\u7cfb\u5217\u7684\u529f\u80fd，\u5305\u62ec\u4f46\u4e0d\u9650\u4e8e\u8fde\u63a5\u7ba1\u7406\u3001\u6570\u636e\u7f16\u89e3\u7801\u3001\u4e1a\u52a1\u5904\u7406\u3001\u8d1f\u8f7d\u5747\u8861\u7b49，\u9002\u7528\u4e8e\u6784\u5efa\u5404\u79cd TCP \u7f51\u7edc\u670d\u52a1，\u5982\u6e38\u620f\u670d\u52a1\u5668\u3001\u5373\u65f6\u901a\u8baf\u670d\u52a1\u5668\u7b49\u3002<\/p>\n

\u4e0b\u9762\u5b9e\u73b0zinx\u7684\u591a\u4e2a\u529f\u80fd\u5305\u62ec：\u8def\u7531\u3001\u5168\u5c40\u914d\u7f6e\u3001\u6d88\u606f\u5c01\u88c5\u3001\u8bfb\u5199\u5206\u79bb\u3001\u6d88\u606f\u961f\u5217\u3001\u94fe\u63a5\u7ba1\u7406\u7b49\u3002<\/p>\n

\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\" utils\u5305\u4e0bGlobalObj.go<\/p>\n

package<\/span> utils<\/p>\n

import<\/span> (<\/span>
\n"datarace\/zinx\/ziface"<\/span>
\n"encoding\/json"<\/span>
\n"io\/ioutil"<\/span>
\n)<\/span><\/p>\n

\/*
\n\u5b58\u50a8\u4e00\u5207\u6709\u5173Zinx\u6846\u67b6\u7684\u5168\u5c40\u53c2\u6570，\u4f9b\u5176\u4ed6\u6a21\u5757\u4f7f\u7528
\n\u4e00\u4e9b\u53c2\u6570\u4e5f\u53ef\u4ee5\u901a\u8fc7 \u7528\u6237\u6839\u636e zinx.json\u6765\u914d\u7f6e
\n*\/<\/span>
\ntype<\/span> GlobalObj struct<\/span> {<\/span>
\nTcpServer ziface.<\/span>IServer \/\/\u5f53\u524dZinx\u7684\u5168\u5c40Server\u5bf9\u8c61<\/span>
\nHost string<\/span> \/\/\u5f53\u524d\u670d\u52a1\u5668\u4e3b\u673aIP<\/span>
\nTcpPort int<\/span> \/\/\u5f53\u524d\u670d\u52a1\u5668\u4e3b\u673a\u76d1\u542c\u7aef\u53e3\u53f7<\/span>
\nName string<\/span> \/\/\u5f53\u524d\u670d\u52a1\u5668\u540d\u79f0<\/span>
\nVersion string<\/span> \/\/\u5f53\u524dZinx\u7248\u672c\u53f7<\/span>
\nMaxPacketSize uint32<\/span> \/\/\u90fd\u9700\u6570\u636e\u5305\u7684\u6700\u5927\u503c<\/span>
\nMaxConn int<\/span> \/\/\u5f53\u524d\u670d\u52a1\u5668\u4e3b\u673a\u5141\u8bb8\u7684\u6700\u5927\u94fe\u63a5\u4e2a\u6570<\/span>
\nWorkerPoolSize uint32<\/span> \/\/\u4e1a\u52a1\u5de5\u4f5cWorker\u6c60\u7684\u6570\u91cf<\/span>
\nMaxWorkerTaskLen uint32<\/span> \/\/\u4e1a\u52a1\u5de5\u4f5cWorker\u5bf9\u5e94\u8d1f\u8d23\u7684\u4efb\u52a1\u961f\u5217\u6700\u5927\u4efb\u52a1\u5b58\u50a8\u6570\u91cf<\/span>
\nConfFilePath string<\/span>
\nMaxMsgChanLen int<\/span>
\n}<\/span><\/p>\n

\/*
\n\u5b9a\u4e49\u4e00\u4e2a\u5168\u5c40\u7684\u5bf9\u8c61
\n*\/<\/span>
\nvar<\/span> GlobalObject *<\/span>GlobalObj<\/p>\n

\/\/ \u8bfb\u53d6\u7528\u6237\u7684\u914d\u7f6e\u6587\u4ef6<\/span>
\nfunc<\/span> (<\/span>g *<\/span>GlobalObj)<\/span> Reload<\/span>(<\/span>)<\/span> {<\/span>
\ndata,<\/span> err :=<\/span> ioutil.<\/span>ReadFile<\/span>(<\/span>"zinx.json"<\/span>)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\npanic<\/span>(<\/span>err)<\/span>
\n}<\/span>
\n\/\/\u5c06json\u6570\u636e\u89e3\u6790\u5230struct\u4e2d<\/span>
\n\/\/fmt.Printf("json :%s\\\\n", data)<\/span>
\nerr =<\/span> json.<\/span>Unmarshal<\/span>(<\/span>data,<\/span> &<\/span>GlobalObject)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\npanic<\/span>(<\/span>err)<\/span>
\n}<\/span>
\n}<\/span>
\nfunc<\/span> init<\/span>(<\/span>)<\/span> {<\/span>
\n\/\/\u521d\u59cb\u5316GlobalObject\u53d8\u91cf，\u8bbe\u7f6e\u4e00\u4e9b\u9ed8\u8ba4\u503c<\/span>
\nGlobalObject =<\/span> &<\/span>GlobalObj{<\/span>
\nName:<\/span> "ZinxServerApp"<\/span>,<\/span>
\nVersion:<\/span> "V0.4"<\/span>,<\/span>
\nTcpPort:<\/span> 7777<\/span>,<\/span>
\nHost:<\/span> "0.0.0.0"<\/span>,<\/span>
\nMaxConn:<\/span> 12000<\/span>,<\/span>
\nMaxPacketSize:<\/span> 4096<\/span>,<\/span>
\nConfFilePath:<\/span> "conf\/zinx.json"<\/span>,<\/span>
\nWorkerPoolSize:<\/span> 10<\/span>,<\/span>
\nMaxWorkerTaskLen:<\/span> 1024<\/span>,<\/span>
\n}<\/span>
\n\/\/\u4ece\u914d\u7f6e\u6587\u4ef6\u4e2d\u52a0\u8f7d\u4e00\u4e9b\u7528\u6237\u914d\u7f6e\u7684\u53c2\u6570<\/span>
\nGlobalObject.<\/span>Reload<\/span>(<\/span>)<\/span>
\n}<\/span><\/p>\n

ziface\u5305<\/p>\n

package<\/span> ziface<\/p>\n

type<\/span> IConnManager interface<\/span> {<\/span>
\nAdd<\/span>(<\/span>conn IConnection)<\/span> \/\/\u6dfb\u52a0\u94fe\u63a5<\/span>
\nRemove<\/span>(<\/span>conn IConnection)<\/span> \/\/\u5220\u9664\u8fde\u63a5<\/span>
\nGet<\/span>(<\/span>connID uint32<\/span>)<\/span> (<\/span>IConnection,<\/span> error<\/span>)<\/span> \/\/\u5229\u7528ConnID\u83b7\u53d6\u94fe\u63a5<\/span>
\nLen<\/span>(<\/span>)<\/span> int<\/span> \/\/\u83b7\u53d6\u5f53\u524d\u8fde\u63a5<\/span>
\nClearConn<\/span>(<\/span>)<\/span> \/\/\u5220\u9664\u5e76\u505c\u6b62\u6240\u6709\u94fe\u63a5<\/span>
\n}<\/span><\/p>\n

package<\/span> ziface<\/p>\n

import<\/span> "net"<\/span><\/p>\n

type<\/span> IConnection interface<\/span> {<\/span>
\nStart<\/span>(<\/span>)<\/span>
\nStop<\/span>(<\/span>)<\/span>
\nGetConnID<\/span>(<\/span>)<\/span> uint32<\/span>
\nGetTCPConnection<\/span>(<\/span>)<\/span> *<\/span>net.<\/span>TCPConn
\nRemoteAddr<\/span>(<\/span>)<\/span> net.<\/span>Addr
\nSendMsg<\/span>(<\/span>msgId uint32<\/span>,<\/span> data [<\/span>]<\/span>byte<\/span>)<\/span> error<\/span>
\n\/\/\u76f4\u63a5\u5c06Message\u6570\u636e\u53d1\u9001\u7ed9\u8fdc\u7a0b\u7684TCP\u5ba2\u6237\u7aef(\u6709\u7f13\u51b2)<\/span>
\nSendBuffMsg<\/span>(<\/span>msgId uint32<\/span>,<\/span> data [<\/span>]<\/span>byte<\/span>)<\/span> error<\/span> \/\/\u6dfb\u52a0\u5e26\u7f13\u51b2\u53d1\u9001\u6d88\u606f\u63a5\u53e3<\/span>
\n\/\/\u8bbe\u7f6e\u94fe\u63a5\u5c5e\u6027<\/span>
\nSetProperty<\/span>(<\/span>key string<\/span>,<\/span> value interface<\/span>{<\/span>}<\/span>)<\/span>
\n\/\/\u83b7\u53d6\u94fe\u63a5\u5c5e\u6027<\/span>
\nGetProperty<\/span>(<\/span>key string<\/span>)<\/span> (<\/span>interface<\/span>{<\/span>}<\/span>,<\/span> error<\/span>)<\/span>
\n\/\/\u79fb\u9664\u94fe\u63a5\u5c5e\u6027<\/span>
\nRemoveProperty<\/span>(<\/span>key string<\/span>)<\/span>
\n}<\/span>
\ntype<\/span> HandFunc func<\/span>(<\/span>*<\/span>net.<\/span>TCPConn,<\/span> [<\/span>]<\/span>byte<\/span>,<\/span> int<\/span>)<\/span> error<\/span><\/p>\n

package<\/span> ziface<\/p>\n

type<\/span> IDataPack interface<\/span> {<\/span>
\nGetHeadLen<\/span>(<\/span>)<\/span> int32<\/span>
\nPack<\/span>(<\/span>msg IMessage)<\/span> (<\/span>[<\/span>]<\/span>byte<\/span>,<\/span> error<\/span>)<\/span>
\nUnpack<\/span>(<\/span>[<\/span>]<\/span>byte<\/span>)<\/span> (<\/span>IMessage,<\/span> error<\/span>)<\/span>
\n}<\/span><\/p>\n

package<\/span> ziface<\/p>\n

type<\/span> IMessage interface<\/span> {<\/span>
\nGetDataLen<\/span>(<\/span>)<\/span> uint32<\/span>
\nGetMsgId<\/span>(<\/span>)<\/span> uint32<\/span>
\nGetData<\/span>(<\/span>)<\/span> [<\/span>]<\/span>byte<\/span>
\nSetMsgId<\/span>(<\/span>uint32<\/span>)<\/span>
\nSetData<\/span>(<\/span>[<\/span>]<\/span>byte<\/span>)<\/span>
\nSetDataLen<\/span>(<\/span>uint32<\/span>)<\/span>
\n}<\/span><\/p>\n

package<\/span> ziface<\/p>\n

type<\/span> IMsgHandle interface<\/span> {<\/span>
\nDoMsgHandler<\/span>(<\/span>request IRequest)<\/span> \/\/\u9a6c\u4e0a\u4ee5\u975e\u963b\u585e\u65b9\u5f0f\u5904\u7406\u6d88\u606f<\/span>
\nAddRouter<\/span>(<\/span>msgId uint32<\/span>,<\/span> router IRouter)<\/span> \/\/\u4e3a\u6d88\u606f\u6dfb\u52a0\u5177\u4f53\u7684\u5904\u7406\u903b\u8f91<\/span>
\nStartWorkerPool<\/span>(<\/span>)<\/span> \/\/\u542f\u52a8worker\u5de5\u4f5c\u6c60<\/span>
\nSendMsgToTaskQueue<\/span>(<\/span>request IRequest)<\/span> \/\/\u5c06\u6d88\u606f\u4ea4\u7ed9TaskQueue,\u7531worker\u8fdb\u884c\u5904\u7406<\/span>
\n}<\/span><\/p>\n

package<\/span> ziface<\/p>\n

type<\/span> IRequest interface<\/span> {<\/span>
\nGetConnection<\/span>(<\/span>)<\/span> IConnection
\nGetData<\/span>(<\/span>)<\/span> [<\/span>]<\/span>byte<\/span>
\nGetMsgID<\/span>(<\/span>)<\/span> uint32<\/span>
\n}<\/span><\/p>\n

package<\/span> ziface<\/p>\n

type<\/span> IRouter interface<\/span> {<\/span>
\nPreHandle<\/span>(<\/span>req IRequest)<\/span>
\nHandle<\/span>(<\/span>req IRequest)<\/span>
\nPostHandle<\/span>(<\/span>req IRequest)<\/span>
\n}<\/span><\/p>\n

package<\/span> ziface<\/p>\n

type<\/span> IServer interface<\/span> {<\/span>
\nStart<\/span>(<\/span>)<\/span>
\nStop<\/span>(<\/span>)<\/span>
\nServe<\/span>(<\/span>)<\/span>
\nAddRouter<\/span>(<\/span>msgId uint32<\/span>,<\/span> router IRouter)<\/span>
\n\/\/\u5f97\u5230\u94fe\u63a5\u7ba1\u7406<\/span>
\nGetConnMgr<\/span>(<\/span>)<\/span> IConnManager
\n\/\/\u8bbe\u7f6e\u8be5Server\u7684\u8fde\u63a5\u521b\u5efa\u65f6Hook\u51fd\u6570<\/span>
\nSetOnConnStart<\/span>(<\/span>func<\/span>(<\/span>IConnection)<\/span>)<\/span>
\n\/\/\u8bbe\u7f6e\u8be5Server\u7684\u8fde\u63a5\u65ad\u5f00\u65f6\u7684Hook\u51fd\u6570<\/span>
\nSetOnConnStop<\/span>(<\/span>func<\/span>(<\/span>IConnection)<\/span>)<\/span>
\n\/\/\u8c03\u7528\u8fde\u63a5OnConnStart Hook\u51fd\u6570<\/span>
\nCallOnConnStart<\/span>(<\/span>conn IConnection)<\/span>
\n\/\/\u8c03\u7528\u8fde\u63a5OnConnStop Hook\u51fd\u6570<\/span>
\nCallOnConnStop<\/span>(<\/span>conn IConnection)<\/span>
\n}<\/span><\/p>\n

znet\u5305 connection<\/p>\n

package<\/span> znet<\/p>\n

import<\/span> (<\/span>
\n"datarace\/zinx\/utils"<\/span>
\n"datarace\/zinx\/ziface"<\/span>
\n"errors"<\/span>
\n"fmt"<\/span>
\n"io"<\/span>
\n"net"<\/span>
\n"sync"<\/span>
\n)<\/span><\/p>\n

type<\/span> Connection struct<\/span> {<\/span>
\n\/\/\u5f53\u524dConn\u5c5e\u4e8e\u54ea\u4e2aServer<\/span>
\nTcpServer ziface.<\/span>IServer \/\/\u5f53\u524dconn\u5c5e\u4e8e\u54ea\u4e2aserver，\u5728conn\u521d\u59cb\u5316\u7684\u65f6\u5019\u6dfb\u52a0\u5373\u53ef<\/span>
\n\/\/\u5f53\u524d\u8fde\u63a5\u7684socket TCP\u5957\u63a5\u5b57<\/span>
\nConn *<\/span>net.<\/span>TCPConn
\n\/\/\u5f53\u524d\u8fde\u63a5\u7684ID \u4e5f\u53ef\u4ee5\u79f0\u4f5c\u4e3aSessionID，ID\u5168\u5c40\u552f\u4e00<\/span>
\nConnID uint32<\/span>
\n\/\/\u5f53\u524d\u8fde\u63a5\u7684\u5173\u95ed\u72b6\u6001<\/span>
\nisClosed bool<\/span>
\n\/\/\u6d88\u606f\u7ba1\u7406MsgId\u548c\u5bf9\u5e94\u5904\u7406\u65b9\u6cd5\u7684\u6d88\u606f\u7ba1\u7406\u6a21\u5757<\/span>
\nMsgHandler ziface.<\/span>IMsgHandle
\n\/\/\u544a\u77e5\u8be5\u94fe\u63a5\u5df2\u7ecf\u9000\u51fa\/\u505c\u6b62\u7684channel<\/span>
\nExitBuffChan chan<\/span> bool<\/span>
\n\/\/\u65e0\u7f13\u51b2\u7ba1\u9053，\u7528\u4e8e\u8bfb\u3001\u5199\u4e24\u4e2agoroutine\u4e4b\u95f4\u7684\u6d88\u606f\u901a\u4fe1<\/span>
\nmsgChan chan<\/span> [<\/span>]<\/span>byte<\/span>
\n\/\/\u6709\u5173\u51b2\u7ba1\u9053，\u7528\u4e8e\u8bfb\u3001\u5199\u4e24\u4e2agoroutine\u4e4b\u95f4\u7684\u6d88\u606f\u901a\u4fe1<\/span>
\nmsgBuffChan chan<\/span> [<\/span>]<\/span>byte<\/span>
\n\/\/\u94fe\u63a5\u5c5e\u6027<\/span>
\nproperty map<\/span>[<\/span>string<\/span>]<\/span>interface<\/span>{<\/span>}<\/span>
\n\/\/\u4fdd\u62a4\u94fe\u63a5\u5c5e\u6027\u4fee\u6539\u7684\u9501<\/span>
\npropertyLock sync.<\/span>RWMutex
\n}<\/span><\/p>\n

\/\/ \u521b\u5efa\u8fde\u63a5\u7684\u65b9\u6cd5<\/span>
\nfunc<\/span> NewConntion<\/span>(<\/span>server ziface.<\/span>IServer,<\/span> conn *<\/span>net.<\/span>TCPConn,<\/span> connID uint32<\/span>,<\/span> msgHandler ziface.<\/span>IMsgHandle)<\/span> *<\/span>Connection {<\/span>
\n\/\/\u521d\u59cb\u5316Conn\u5c5e\u6027<\/span>
\nc :=<\/span> &<\/span>Connection{<\/span>
\nTcpServer:<\/span> server,<\/span> \/\/\u5c06\u96b6\u5c5e\u7684server\u4f20\u9012\u8fdb\u6765<\/span>
\nConn:<\/span> conn,<\/span>
\nConnID:<\/span> connID,<\/span>
\nisClosed:<\/span> false<\/span>,<\/span>
\nMsgHandler:<\/span> msgHandler,<\/span>
\nExitBuffChan:<\/span> make<\/span>(<\/span>chan<\/span> bool<\/span>,<\/span> 1<\/span>)<\/span>,<\/span>
\nmsgChan:<\/span> make<\/span>(<\/span>chan<\/span> [<\/span>]<\/span>byte<\/span>)<\/span>,<\/span>
\nmsgBuffChan:<\/span> make<\/span>(<\/span>chan<\/span> [<\/span>]<\/span>byte<\/span>,<\/span> utils.<\/span>GlobalObject.<\/span>MaxMsgChanLen)<\/span>,<\/span> \/\/\u4e0d\u8981\u5fd8\u8bb0\u521d\u59cb\u5316<\/span>
\nproperty:<\/span> make<\/span>(<\/span>map<\/span>[<\/span>string<\/span>]<\/span>interface<\/span>{<\/span>}<\/span>)<\/span>,<\/span> \/\/\u5bf9\u94fe\u63a5\u5c5e\u6027map\u521d\u59cb\u5316<\/span>
\n}<\/span>
\n\/\/\u5c06\u65b0\u521b\u5efa\u7684Conn\u6dfb\u52a0\u5230\u94fe\u63a5\u7ba1\u7406\u4e2d<\/span>
\nc.<\/span>TcpServer.<\/span>GetConnMgr<\/span>(<\/span>)<\/span>.<\/span>Add<\/span>(<\/span>c)<\/span> \/\/\u5c06\u5f53\u524d\u65b0\u521b\u5efa\u7684\u8fde\u63a5\u6dfb\u52a0\u5230ConnManager\u4e2d<\/span>
\nreturn<\/span> c
\n}<\/span><\/p>\n

\/\/ \u8bbe\u7f6e\u94fe\u63a5\u5c5e\u6027<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> SetProperty<\/span>(<\/span>key string<\/span>,<\/span> value interface<\/span>{<\/span>}<\/span>)<\/span> {<\/span>
\nc.<\/span>propertyLock.<\/span>Lock<\/span>(<\/span>)<\/span>
\ndefer<\/span> c.<\/span>propertyLock.<\/span>Unlock<\/span>(<\/span>)<\/span>
\nc.<\/span>property[<\/span>key]<\/span> =<\/span> value
\n}<\/span><\/p>\n

\/\/ \u83b7\u53d6\u94fe\u63a5\u5c5e\u6027<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> GetProperty<\/span>(<\/span>key string<\/span>)<\/span> (<\/span>interface<\/span>{<\/span>}<\/span>,<\/span> error<\/span>)<\/span> {<\/span>
\nc.<\/span>propertyLock.<\/span>RLock<\/span>(<\/span>)<\/span>
\ndefer<\/span> c.<\/span>propertyLock.<\/span>RUnlock<\/span>(<\/span>)<\/span>
\nif<\/span> value,<\/span> ok :=<\/span> c.<\/span>property[<\/span>key]<\/span>;<\/span> ok {<\/span>
\nreturn<\/span> value,<\/span> nil<\/span>
\n}<\/span> else<\/span> {<\/span>
\nreturn<\/span> nil<\/span>,<\/span> errors.<\/span>New<\/span>(<\/span>"no property found"<\/span>)<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u79fb\u9664\u94fe\u63a5\u5c5e\u6027<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> RemoveProperty<\/span>(<\/span>key string<\/span>)<\/span> {<\/span>
\nc.<\/span>propertyLock.<\/span>Lock<\/span>(<\/span>)<\/span>
\ndefer<\/span> c.<\/span>propertyLock.<\/span>Unlock<\/span>(<\/span>)<\/span>
\ndelete<\/span>(<\/span>c.<\/span>property,<\/span> key)<\/span>
\n}<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> startReader<\/span>(<\/span>)<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"[Reader Goroutine is running]"<\/span>)<\/span>
\ndefer<\/span> fmt.<\/span>Println<\/span>(<\/span>c.<\/span>RemoteAddr<\/span>(<\/span>)<\/span>.<\/span>String<\/span>(<\/span>)<\/span>,<\/span> "[conn Reader exit!]"<\/span>)<\/span>
\ndefer<\/span> c.<\/span>Stop<\/span>(<\/span>)<\/span>
\nfor<\/span> {<\/span>
\n\/\/ \u521b\u5efa\u62c6\u5305\u89e3\u5305\u7684\u5bf9\u8c61<\/span>
\ndp :=<\/span> NewDataPack<\/span>(<\/span>)<\/span>
\n\/\/\u8bfb\u53d6\u5ba2\u6237\u7aef\u7684Msg head<\/span>
\nheadData :=<\/span> make<\/span>(<\/span>[<\/span>]<\/span>byte<\/span>,<\/span> dp.<\/span>GetHeadLen<\/span>(<\/span>)<\/span>)<\/span>
\nif<\/span> _<\/span>,<\/span> err :=<\/span> io.<\/span>ReadFull<\/span>(<\/span>c.<\/span>GetTCPConnection<\/span>(<\/span>)<\/span>,<\/span> headData)<\/span>;<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"read msg head error "<\/span>,<\/span> err)<\/span>
\nbreak<\/span>
\n}<\/span>
\n\/\/\u62c6\u5305，\u5f97\u5230msgid \u548c datalen \u653e\u5728msg\u4e2d<\/span>
\nmsg,<\/span> err :=<\/span> dp.<\/span>Unpack<\/span>(<\/span>headData)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"unpack error "<\/span>,<\/span> err)<\/span>
\nbreak<\/span>
\n}<\/span>
\n\/\/\u6839\u636e dataLen \u8bfb\u53d6 data，\u653e\u5728msg.Data\u4e2d<\/span>
\nvar<\/span> data [<\/span>]<\/span>byte<\/span>
\nif<\/span> msg.<\/span>GetDataLen<\/span>(<\/span>)<\/span> ><\/span> 0<\/span> {<\/span>
\ndata =<\/span> make<\/span>(<\/span>[<\/span>]<\/span>byte<\/span>,<\/span> msg.<\/span>GetDataLen<\/span>(<\/span>)<\/span>)<\/span>
\nif<\/span> _<\/span>,<\/span> err :=<\/span> io.<\/span>ReadFull<\/span>(<\/span>c.<\/span>GetTCPConnection<\/span>(<\/span>)<\/span>,<\/span> data)<\/span>;<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"read msg data error "<\/span>,<\/span> err)<\/span>
\ncontinue<\/span>
\n}<\/span>
\n}<\/span>
\nmsg.<\/span>SetData<\/span>(<\/span>data)<\/span>
\n\/\/\u5f97\u5230\u5f53\u524d\u5ba2\u6237\u7aef\u8bf7\u6c42\u7684Request\u6570\u636e<\/span>
\nreq :=<\/span> Request{<\/span>
\nconn:<\/span> c,<\/span>
\nmsg:<\/span> msg,<\/span>
\n}<\/span>
\n\/\/\u4ece\u7ed1\u5b9a\u597d\u7684\u6d88\u606f\u548c\u5bf9\u5e94\u7684\u5904\u7406\u65b9\u6cd5\u4e2d\u6267\u884c\u5bf9\u5e94\u7684Handle\u65b9\u6cd5<\/span>
\nif<\/span> utils.<\/span>GlobalObject.<\/span>WorkerPoolSize ><\/span> 0<\/span> {<\/span>
\n\/\/\u5df2\u7ecf\u542f\u52a8\u5de5\u4f5c\u6c60\u673a\u5236，\u5c06\u6d88\u606f\u4ea4\u7ed9Worker\u5904\u7406<\/span>
\nc.<\/span>MsgHandler.<\/span>SendMsgToTaskQueue<\/span>(<\/span>&<\/span>req)<\/span>
\n}<\/span> else<\/span> {<\/span>
\n\/\/\u4ece\u7ed1\u5b9a\u597d\u7684\u6d88\u606f\u548c\u5bf9\u5e94\u7684\u5904\u7406\u65b9\u6cd5\u4e2d\u6267\u884c\u5bf9\u5e94\u7684Handle\u65b9\u6cd5<\/span>
\ngo<\/span> c.<\/span>MsgHandler.<\/span>DoMsgHandler<\/span>(<\/span>&<\/span>req)<\/span>
\n}<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u542f\u52a8\u8fde\u63a5，\u8ba9\u5f53\u524d\u8fde\u63a5\u5f00\u59cb\u5de5\u4f5c<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> Start<\/span>(<\/span>)<\/span> {<\/span>
\n\/\/1 \u5f00\u542f\u7528\u6237\u4ece\u5ba2\u6237\u7aef\u8bfb\u53d6\u6570\u636e\u6d41\u7a0b\u7684Goroutine<\/span>
\ngo<\/span> c.<\/span>startReader<\/span>(<\/span>)<\/span>
\n\/\/2 \u5f00\u542f\u7528\u4e8e\u5199\u56de\u5ba2\u6237\u7aef\u6570\u636e\u6d41\u7a0b\u7684Goroutine<\/span>
\ngo<\/span> c.<\/span>StartWriter<\/span>(<\/span>)<\/span>
\n\/\/\u6309\u7167\u7528\u6237\u4f20\u9012\u8fdb\u6765\u7684\u521b\u5efa\u8fde\u63a5\u65f6\u9700\u8981\u5904\u7406\u7684\u4e1a\u52a1，\u6267\u884c\u94a9\u5b50\u65b9\u6cd5<\/span>
\nc.<\/span>TcpServer.<\/span>CallOnConnStart<\/span>(<\/span>c)<\/span>
\n}<\/span><\/p>\n

\/\/func (c *Connection) Start() {<\/span>
\n\/\/go c.startReader()<\/span>
\n\/\/for {<\/span>
\n\/\/select {<\/span>
\n\/\/case <-c.ExitBuffChan:<\/span>
\n\/\/return<\/span>
\n\/\/}<\/span>
\n\/\/}<\/span>
\n\/\/}<\/span><\/p>\n

\/\/ \u505c\u6b62\u8fde\u63a5，\u7ed3\u675f\u5f53\u524d\u8fde\u63a5\u72b6\u6001M<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> Stop<\/span>(<\/span>)<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Conn Stop()…ConnID = "<\/span>,<\/span> c.<\/span>ConnID)<\/span>
\n\/\/\u5982\u679c\u5f53\u524d\u94fe\u63a5\u5df2\u7ecf\u5173\u95ed<\/span>
\nif<\/span> c.<\/span>isClosed ==<\/span> true<\/span> {<\/span>
\nreturn<\/span>
\n}<\/span>
\nc.<\/span>isClosed =<\/span> true<\/span>
\n\/\/==================<\/span>
\n\/\/\u5982\u679c\u7528\u6237\u6ce8\u518c\u4e86\u8be5\u94fe\u63a5\u7684\u5173\u95ed\u56de\u8c03\u4e1a\u52a1，\u90a3\u4e48\u5728\u6b64\u523b\u5e94\u8be5\u663e\u793a\u8c03\u7528<\/span>
\nc.<\/span>TcpServer.<\/span>CallOnConnStop<\/span>(<\/span>c)<\/span>
\n\/\/==================<\/span>
\n\/\/ \u5173\u95edsocket\u94fe\u63a5<\/span>
\nc.<\/span>Conn.<\/span>Close<\/span>(<\/span>)<\/span>
\n\/\/\u5173\u95edWriter<\/span>
\nc.<\/span>ExitBuffChan <-<\/span> true<\/span>
\n\/\/\u5c06\u94fe\u63a5\u4ece\u8fde\u63a5\u7ba1\u7406\u5668\u4e2d\u5220\u9664<\/span>
\nc.<\/span>TcpServer.<\/span>GetConnMgr<\/span>(<\/span>)<\/span>.<\/span>Remove<\/span>(<\/span>c)<\/span>
\n\/\/\u5173\u95ed\u8be5\u94fe\u63a5\u5168\u90e8\u7ba1\u9053<\/span>
\nclose<\/span>(<\/span>c.<\/span>ExitBuffChan)<\/span>
\nclose<\/span>(<\/span>c.<\/span>msgBuffChan)<\/span>
\n}<\/span><\/p>\n

\/*
\n\u5199\u6d88\u606fGoroutine， \u7528\u6237\u5c06\u6570\u636e\u53d1\u9001\u7ed9\u5ba2\u6237\u7aef
\n*\/<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> StartWriter<\/span>(<\/span>)<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"[Writer Goroutine is running]"<\/span>)<\/span>
\ndefer<\/span> fmt.<\/span>Println<\/span>(<\/span>c.<\/span>RemoteAddr<\/span>(<\/span>)<\/span>.<\/span>String<\/span>(<\/span>)<\/span>,<\/span> "[conn Writer exit!]"<\/span>)<\/span>
\nfor<\/span> {<\/span>
\nselect<\/span> {<\/span>
\ncase<\/span> data :=<\/span> <-<\/span>c.<\/span>msgChan:<\/span>
\n\/\/\u6709\u6570\u636e\u8981\u5199\u7ed9\u5ba2\u6237\u7aef<\/span>
\nif<\/span> _<\/span>,<\/span> err :=<\/span> c.<\/span>Conn.<\/span>Write<\/span>(<\/span>data)<\/span>;<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Send Data error:, "<\/span>,<\/span> err,<\/span> " Conn Writer exit"<\/span>)<\/span>
\nreturn<\/span>
\n}<\/span>
\n\/\/\u9488\u5bf9\u6709\u7f13\u51b2channel\u9700\u8981\u4e9b\u7684\u6570\u636e\u5904\u7406<\/span>
\ncase<\/span> data,<\/span> ok :=<\/span> <-<\/span>c.<\/span>msgBuffChan:<\/span>
\nif<\/span> ok {<\/span>
\n\/\/\u6709\u6570\u636e\u8981\u5199\u7ed9\u5ba2\u6237\u7aef<\/span>
\nif<\/span> _<\/span>,<\/span> err :=<\/span> c.<\/span>Conn.<\/span>Write<\/span>(<\/span>data)<\/span>;<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Send Buff Data error:, "<\/span>,<\/span> err,<\/span> " Conn Writer exit"<\/span>)<\/span>
\nreturn<\/span>
\n}<\/span>
\n}<\/span> else<\/span> {<\/span>
\nbreak<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"msgBuffChan is Closed"<\/span>)<\/span>
\n}<\/span>
\ncase<\/span> <-<\/span>c.<\/span>ExitBuffChan:<\/span>
\nreturn<\/span>
\n}<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u76f4\u63a5\u5c06Message\u6570\u636e\u53d1\u9001\u6570\u636e\u7ed9\u8fdc\u7a0b\u7684TCP\u5ba2\u6237\u7aef<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> SendMsg<\/span>(<\/span>msgId uint32<\/span>,<\/span> data [<\/span>]<\/span>byte<\/span>)<\/span> error<\/span> {<\/span>
\nif<\/span> c.<\/span>isClosed ==<\/span> true<\/span> {<\/span>
\nreturn<\/span> errors.<\/span>New<\/span>(<\/span>"Connection closed when send msg"<\/span>)<\/span>
\n}<\/span>
\n\/\/\u5c06data\u5c01\u5305，\u5e76\u4e14\u53d1\u9001<\/span>
\ndp :=<\/span> NewDataPack<\/span>(<\/span>)<\/span>
\nmsg,<\/span> err :=<\/span> dp.<\/span>Pack<\/span>(<\/span>NewMsgPackage<\/span>(<\/span>msgId,<\/span> data)<\/span>)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Pack error msg id = "<\/span>,<\/span> msgId)<\/span>
\nreturn<\/span> errors.<\/span>New<\/span>(<\/span>"Pack error msg "<\/span>)<\/span>
\n}<\/span>
\n\/\/\u5199\u56de\u5ba2\u6237\u7aef<\/span>
\nc.<\/span>msgChan <-<\/span> msg \/\/\u5c06\u4e4b\u524d\u76f4\u63a5\u56de\u5199\u7ed9conn.Write\u7684\u65b9\u6cd5 \u6539\u4e3a \u53d1\u9001\u7ed9Channel \u4f9bWriter\u8bfb\u53d6<\/span>
\nreturn<\/span> nil<\/span>
\n}<\/span><\/p>\n

\/\/ \u4ece\u5f53\u524d\u8fde\u63a5\u83b7\u53d6\u539f\u59cb\u7684socket TCPConn<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> GetTCPConnection<\/span>(<\/span>)<\/span> *<\/span>net.<\/span>TCPConn {<\/span>
\nreturn<\/span> c.<\/span>Conn
\n}<\/span><\/p>\n

\/\/ \u83b7\u53d6\u5f53\u524d\u8fde\u63a5ID<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> GetConnID<\/span>(<\/span>)<\/span> uint32<\/span> {<\/span>
\nreturn<\/span> c.<\/span>ConnID
\n}<\/span><\/p>\n

\/\/ \u83b7\u53d6\u8fdc\u7a0b\u5ba2\u6237\u7aef\u5730\u5740\u4fe1\u606f<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> RemoteAddr<\/span>(<\/span>)<\/span> net.<\/span>Addr {<\/span>
\nreturn<\/span> c.<\/span>Conn.<\/span>RemoteAddr<\/span>(<\/span>)<\/span>
\n}<\/span><\/p>\n

\/\/ \/\/ \u76f4\u63a5\u5c06Message\u6570\u636e\u53d1\u9001\u6570\u636e\u7ed9\u8fdc\u7a0b\u7684TCP\u5ba2\u6237\u7aef<\/span>
\n\/\/<\/span>
\n\/\/func (c *Connection) SendMsg(msgId uint32, data []byte) error {<\/span>
\n\/\/if c.isClosed == true {<\/span>
\n\/\/return errors.New("Connection closed when send msg")<\/span>
\n\/\/}<\/span>
\n\/\/\/\/\u5c06data\u5c01\u5305，\u5e76\u4e14\u53d1\u9001<\/span>
\n\/\/dp := NewDataPack()<\/span>
\n\/\/msg, err := dp.Pack(NewMsgPackage(msgId, data))<\/span>
\n\/\/if err != nil {<\/span>
\n\/\/fmt.Println("Pack error msg id = ", msgId)<\/span>
\n\/\/return errors.New("Pack error msg ")<\/span>
\n\/\/}<\/span>
\n\/\/\/\/\u5199\u56de\u5ba2\u6237\u7aef<\/span>
\n\/\/if _, err := c.Conn.Write(msg); err != nil {<\/span>
\n\/\/fmt.Println("Write msg id ", msgId, " error ")<\/span>
\n\/\/c.ExitBuffChan <- true<\/span>
\n\/\/return errors.New("conn Write error")<\/span>
\n\/\/}<\/span>
\n\/\/return nil<\/span>
\n\/\/}<\/span>
\nfunc<\/span> (<\/span>c *<\/span>Connection)<\/span> SendBuffMsg<\/span>(<\/span>msgId uint32<\/span>,<\/span> data [<\/span>]<\/span>byte<\/span>)<\/span> error<\/span> {<\/span>
\nif<\/span> c.<\/span>isClosed ==<\/span> true<\/span> {<\/span>
\nreturn<\/span> errors.<\/span>New<\/span>(<\/span>"Connection closed when send buff msg"<\/span>)<\/span>
\n}<\/span>
\n\/\/\u5c06data\u5c01\u5305，\u5e76\u4e14\u53d1\u9001<\/span>
\ndp :=<\/span> NewDataPack<\/span>(<\/span>)<\/span>
\nmsg,<\/span> err :=<\/span> dp.<\/span>Pack<\/span>(<\/span>NewMsgPackage<\/span>(<\/span>msgId,<\/span> data)<\/span>)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Pack error msg id = "<\/span>,<\/span> msgId)<\/span>
\nreturn<\/span> errors.<\/span>New<\/span>(<\/span>"Pack error msg "<\/span>)<\/span>
\n}<\/span>
\n\/\/\u5199\u56de\u5ba2\u6237\u7aef<\/span>
\nc.<\/span>msgBuffChan <-<\/span> msg
\nreturn<\/span> nil<\/span>
\n}<\/span><\/p>\n

ConnManager<\/p>\n

package<\/span> znet<\/p>\n

import<\/span> (<\/span>
\n"datarace\/zinx\/ziface"<\/span>
\n"errors"<\/span>
\n"fmt"<\/span>
\n"sync"<\/span>
\n)<\/span><\/p>\n

type<\/span> ConnManager struct<\/span> {<\/span>
\nconnections map<\/span>[<\/span>uint32<\/span>]<\/span>ziface.<\/span>IConnection
\nconnLock sync.<\/span>RWMutex
\n}<\/span><\/p>\n

\/*
\n\u521b\u5efa\u4e00\u4e2a\u94fe\u63a5\u7ba1\u7406
\n*\/<\/span>
\nfunc<\/span> NewConnManager<\/span>(<\/span>)<\/span> *<\/span>ConnManager {<\/span>
\nreturn<\/span> &<\/span>ConnManager{<\/span>
\nconnections:<\/span> make<\/span>(<\/span>map<\/span>[<\/span>uint32<\/span>]<\/span>ziface.<\/span>IConnection)<\/span>,<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u6dfb\u52a0\u94fe\u63a5<\/span>
\nfunc<\/span> (<\/span>connMgr *<\/span>ConnManager)<\/span> Add<\/span>(<\/span>conn ziface.<\/span>IConnection)<\/span> {<\/span>
\n\/\/\u4fdd\u62a4\u5171\u4eab\u8d44\u6e90Map \u52a0\u5199\u9501<\/span>
\nconnMgr.<\/span>connLock.<\/span>Lock<\/span>(<\/span>)<\/span>
\ndefer<\/span> connMgr.<\/span>connLock.<\/span>Unlock<\/span>(<\/span>)<\/span>
\n\/\/\u5c06conn\u8fde\u63a5\u6dfb\u52a0\u5230ConnMananger\u4e2d<\/span>
\nconnMgr.<\/span>connections[<\/span>conn.<\/span>GetConnID<\/span>(<\/span>)<\/span>]<\/span> =<\/span> conn
\nfmt.<\/span>Println<\/span>(<\/span>"connection add to ConnManager successfully: conn num = "<\/span>,<\/span> connMgr.<\/span>Len<\/span>(<\/span>)<\/span>)<\/span>
\n}<\/span><\/p>\n

\/\/ \u5220\u9664\u8fde\u63a5<\/span>
\nfunc<\/span> (<\/span>connMgr *<\/span>ConnManager)<\/span> Remove<\/span>(<\/span>conn ziface.<\/span>IConnection)<\/span> {<\/span>
\n\/\/\u4fdd\u62a4\u5171\u4eab\u8d44\u6e90Map \u52a0\u5199\u9501<\/span>
\nconnMgr.<\/span>connLock.<\/span>Lock<\/span>(<\/span>)<\/span>
\ndefer<\/span> connMgr.<\/span>connLock.<\/span>Unlock<\/span>(<\/span>)<\/span>
\n\/\/\u5220\u9664\u8fde\u63a5\u4fe1\u606f<\/span>
\ndelete<\/span>(<\/span>connMgr.<\/span>connections,<\/span> conn.<\/span>GetConnID<\/span>(<\/span>)<\/span>)<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"connection Remove ConnID="<\/span>,<\/span> conn.<\/span>GetConnID<\/span>(<\/span>)<\/span>,<\/span> " successfully: conn num = "<\/span>,<\/span> connMgr.<\/span>Len<\/span>(<\/span>)<\/span>)<\/span>
\n}<\/span><\/p>\n

\/\/ \u5229\u7528ConnID\u83b7\u53d6\u94fe\u63a5<\/span>
\nfunc<\/span> (<\/span>connMgr *<\/span>ConnManager)<\/span> Get<\/span>(<\/span>connID uint32<\/span>)<\/span> (<\/span>ziface.<\/span>IConnection,<\/span> error<\/span>)<\/span> {<\/span>
\n\/\/\u4fdd\u62a4\u5171\u4eab\u8d44\u6e90Map \u52a0\u8bfb\u9501<\/span>
\nconnMgr.<\/span>connLock.<\/span>RLock<\/span>(<\/span>)<\/span>
\ndefer<\/span> connMgr.<\/span>connLock.<\/span>RUnlock<\/span>(<\/span>)<\/span>
\nif<\/span> conn,<\/span> ok :=<\/span> connMgr.<\/span>connections[<\/span>connID]<\/span>;<\/span> ok {<\/span>
\nreturn<\/span> conn,<\/span> nil<\/span>
\n}<\/span> else<\/span> {<\/span>
\nreturn<\/span> nil<\/span>,<\/span> errors.<\/span>New<\/span>(<\/span>"connection not found"<\/span>)<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u83b7\u53d6\u5f53\u524d\u8fde\u63a5<\/span>
\nfunc<\/span> (<\/span>connMgr *<\/span>ConnManager)<\/span> Len<\/span>(<\/span>)<\/span> int<\/span> {<\/span>
\nreturn<\/span> len<\/span>(<\/span>connMgr.<\/span>connections)<\/span>
\n}<\/span><\/p>\n

\/\/ \u6e05\u9664\u5e76\u505c\u6b62\u6240\u6709\u8fde\u63a5<\/span>
\nfunc<\/span> (<\/span>connMgr *<\/span>ConnManager)<\/span> ClearConn<\/span>(<\/span>)<\/span> {<\/span>
\n\/\/\u4fdd\u62a4\u5171\u4eab\u8d44\u6e90Map \u52a0\u5199\u9501<\/span>
\nconnMgr.<\/span>connLock.<\/span>Lock<\/span>(<\/span>)<\/span>
\ndefer<\/span> connMgr.<\/span>connLock.<\/span>Unlock<\/span>(<\/span>)<\/span>
\n\/\/\u505c\u6b62\u5e76\u5220\u9664\u5168\u90e8\u7684\u8fde\u63a5\u4fe1\u606f<\/span>
\nfor<\/span> connID,<\/span> conn :=<\/span> range<\/span> connMgr.<\/span>connections {<\/span>
\n\/\/\u505c\u6b62<\/span>
\nconn.<\/span>Stop<\/span>(<\/span>)<\/span>
\n\/\/\u5220\u9664<\/span>
\ndelete<\/span>(<\/span>connMgr.<\/span>connections,<\/span> connID)<\/span>
\n}<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Clear All Connections successfully: conn num = "<\/span>,<\/span> connMgr.<\/span>Len<\/span>(<\/span>)<\/span>)<\/span>
\n}<\/span><\/p>\n

datapack<\/p>\n

package<\/span> znet<\/p>\n

import<\/span> (<\/span>
\n"bytes"<\/span>
\n"datarace\/zinx\/utils"<\/span>
\n"datarace\/zinx\/ziface"<\/span>
\n"encoding\/binary"<\/span>
\n"errors"<\/span>
\n)<\/span><\/p>\n

type<\/span> DataPack struct<\/span>{<\/span>}<\/span><\/p>\n

func<\/span> NewDataPack<\/span>(<\/span>)<\/span> *<\/span>DataPack {<\/span>
\nreturn<\/span> &<\/span>DataPack{<\/span>}<\/span>
\n}<\/span>
\nfunc<\/span> (<\/span>dp *<\/span>DataPack)<\/span> GetHeadLen<\/span>(<\/span>)<\/span> uint32<\/span> {<\/span>
\n\/\/Id uint32(4\u5b57\u8282) + DataLen uint32(4\u5b57\u8282)<\/span>
\nreturn<\/span> 8<\/span>
\n}<\/span><\/p>\n

\/\/ \u5c01\u5305\u65b9\u6cd5(\u538b\u7f29\u6570\u636e)<\/span>
\nfunc<\/span> (<\/span>dp *<\/span>DataPack)<\/span> Pack<\/span>(<\/span>msg ziface.<\/span>IMessage)<\/span> (<\/span>[<\/span>]<\/span>byte<\/span>,<\/span> error<\/span>)<\/span> {<\/span>
\n\/\/\u521b\u5efa\u4e00\u4e2a\u5b58\u653ebytes\u5b57\u8282\u7684\u7f13\u51b2<\/span>
\ndataBuff :=<\/span> bytes.<\/span>NewBuffer<\/span>(<\/span>[<\/span>]<\/span>byte<\/span>{<\/span>}<\/span>)<\/span>
\n\/\/\u5199dataLen<\/span>
\nif<\/span> err :=<\/span> binary.<\/span>Write<\/span>(<\/span>dataBuff,<\/span> binary.<\/span>LittleEndian,<\/span> msg.<\/span>GetDataLen<\/span>(<\/span>)<\/span>)<\/span>;<\/span> err !=<\/span> nil<\/span> {<\/span>
\nreturn<\/span> nil<\/span>,<\/span> err
\n}<\/span>
\n\/\/\u5199msgID<\/span>
\nif<\/span> err :=<\/span> binary.<\/span>Write<\/span>(<\/span>dataBuff,<\/span> binary.<\/span>LittleEndian,<\/span> msg.<\/span>GetMsgId<\/span>(<\/span>)<\/span>)<\/span>;<\/span> err !=<\/span> nil<\/span> {<\/span>
\nreturn<\/span> nil<\/span>,<\/span> err
\n}<\/span>
\n\/\/\u5199data\u6570\u636e<\/span>
\nif<\/span> err :=<\/span> binary.<\/span>Write<\/span>(<\/span>dataBuff,<\/span> binary.<\/span>LittleEndian,<\/span> msg.<\/span>GetData<\/span>(<\/span>)<\/span>)<\/span>;<\/span> err !=<\/span> nil<\/span> {<\/span>
\nreturn<\/span> nil<\/span>,<\/span> err
\n}<\/span>
\nreturn<\/span> dataBuff.<\/span>Bytes<\/span>(<\/span>)<\/span>,<\/span> nil<\/span>
\n}<\/span>
\nfunc<\/span> (<\/span>dp *<\/span>DataPack)<\/span> Unpack<\/span>(<\/span>binaryData [<\/span>]<\/span>byte<\/span>)<\/span> (<\/span>ziface.<\/span>IMessage,<\/span> error<\/span>)<\/span> {<\/span>
\n\/\/\u521b\u5efa\u4e00\u4e2a\u4ece\u8f93\u5165\u4e8c\u8fdb\u5236\u6570\u636e\u7684ioReader<\/span>
\ndataBuff :=<\/span> bytes.<\/span>NewReader<\/span>(<\/span>binaryData)<\/span>
\n\/\/\u53ea\u89e3\u538bhead\u7684\u4fe1\u606f，\u5f97\u5230dataLen\u548cmsgID<\/span>
\nmsg :=<\/span> &<\/span>Message{<\/span>}<\/span>
\n\/\/\u8bfbdataLen<\/span>
\nif<\/span> err :=<\/span> binary.<\/span>Read<\/span>(<\/span>dataBuff,<\/span> binary.<\/span>LittleEndian,<\/span> &<\/span>msg.<\/span>DataLen)<\/span>;<\/span> err !=<\/span> nil<\/span> {<\/span>
\nreturn<\/span> nil<\/span>,<\/span> err
\n}<\/span>
\n\/\/\u8bfbmsgID<\/span>
\nif<\/span> err :=<\/span> binary.<\/span>Read<\/span>(<\/span>dataBuff,<\/span> binary.<\/span>LittleEndian,<\/span> &<\/span>msg.<\/span>Id)<\/span>;<\/span> err !=<\/span> nil<\/span> {<\/span>
\nreturn<\/span> nil<\/span>,<\/span> err
\n}<\/span>
\n\/\/\u5224\u65addataLen\u7684\u957f\u5ea6\u662f\u5426\u8d85\u51fa\u6211\u4eec\u5141\u8bb8\u7684\u6700\u5927\u5305\u957f\u5ea6<\/span>
\nif<\/span> utils.<\/span>GlobalObject.<\/span>MaxPacketSize ><\/span> 0<\/span> &&<\/span> msg.<\/span>DataLen ><\/span> utils.<\/span>GlobalObject.<\/span>MaxPacketSize {<\/span>
\nreturn<\/span> nil<\/span>,<\/span> errors.<\/span>New<\/span>(<\/span>"Too large msg data recieved"<\/span>)<\/span>
\n}<\/span>
\n\/\/\u8fd9\u91cc\u53ea\u9700\u8981\u628ahead\u7684\u6570\u636e\u62c6\u5305\u51fa\u6765\u5c31\u53ef\u4ee5\u4e86，\u7136\u540e\u518d\u901a\u8fc7head\u7684\u957f\u5ea6，\u518d\u4ececonn\u8bfb\u53d6\u4e00\u6b21\u6570\u636e<\/span>
\nreturn<\/span> msg,<\/span> nil<\/span>
\n}<\/span><\/p>\n

message<\/p>\n

package<\/span> znet<\/p>\n

type<\/span> Message struct<\/span> {<\/span>
\nId uint32<\/span>
\nDataLen uint32<\/span>
\nData [<\/span>]<\/span>byte<\/span>
\n}<\/span><\/p>\n

func<\/span> NewMsgPackage<\/span>(<\/span>id uint32<\/span>,<\/span> data [<\/span>]<\/span>byte<\/span>)<\/span> *<\/span>Message {<\/span>
\nreturn<\/span> &<\/span>Message{<\/span>
\nId:<\/span> id,<\/span>
\nDataLen:<\/span> uint32<\/span>(<\/span>len<\/span>(<\/span>data)<\/span>)<\/span>,<\/span>
\nData:<\/span> data,<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u83b7\u53d6\u6d88\u606f\u6570\u636e\u6bb5\u957f\u5ea6<\/span>
\nfunc<\/span> (<\/span>msg *<\/span>Message)<\/span> GetDataLen<\/span>(<\/span>)<\/span> uint32<\/span> {<\/span>
\nreturn<\/span> msg.<\/span>DataLen
\n}<\/span><\/p>\n

\/\/ \u83b7\u53d6\u6d88\u606fID<\/span>
\nfunc<\/span> (<\/span>msg *<\/span>Message)<\/span> GetMsgId<\/span>(<\/span>)<\/span> uint32<\/span> {<\/span>
\nreturn<\/span> msg.<\/span>Id
\n}<\/span><\/p>\n

\/\/ \u83b7\u53d6\u6d88\u606f\u5185\u5bb9<\/span>
\nfunc<\/span> (<\/span>msg *<\/span>Message)<\/span> GetData<\/span>(<\/span>)<\/span> [<\/span>]<\/span>byte<\/span> {<\/span>
\nreturn<\/span> msg.<\/span>Data
\n}<\/span><\/p>\n

\/\/ \u8bbe\u7f6e\u6d88\u606f\u6570\u636e\u6bb5\u957f\u5ea6<\/span>
\nfunc<\/span> (<\/span>msg *<\/span>Message)<\/span> SetDataLen<\/span>(<\/span>len<\/span> uint32<\/span>)<\/span> {<\/span>
\nmsg.<\/span>DataLen =<\/span> len<\/span>
\n}<\/span><\/p>\n

\/\/ \u8bbe\u8ba1\u6d88\u606fID<\/span>
\nfunc<\/span> (<\/span>msg *<\/span>Message)<\/span> SetMsgId<\/span>(<\/span>msgId uint32<\/span>)<\/span> {<\/span>
\nmsg.<\/span>Id =<\/span> msgId
\n}<\/span><\/p>\n

\/\/ \u8bbe\u8ba1\u6d88\u606f\u5185\u5bb9<\/span>
\nfunc<\/span> (<\/span>msg *<\/span>Message)<\/span> SetData<\/span>(<\/span>data [<\/span>]<\/span>byte<\/span>)<\/span> {<\/span>
\nmsg.<\/span>Data =<\/span> data
\n}<\/span><\/p>\n

msgHandler<\/p>\n

package<\/span> znet<\/p>\n

import<\/span> (<\/span>
\n"datarace\/zinx\/utils"<\/span>
\n"datarace\/zinx\/ziface"<\/span>
\n"fmt"<\/span>
\n"strconv"<\/span>
\n)<\/span><\/p>\n

type<\/span> MsgHandle struct<\/span> {<\/span>
\nApis map<\/span>[<\/span>uint32<\/span>]<\/span>ziface.<\/span>IRouter
\nWorkerPoolSize uint32<\/span>
\nTaskQueue [<\/span>]<\/span>chan<\/span> ziface.<\/span>IRequest
\n}<\/span><\/p>\n

func<\/span> NewMsgHandle<\/span>(<\/span>)<\/span> *<\/span>MsgHandle {<\/span>
\nreturn<\/span> &<\/span>MsgHandle{<\/span>
\nApis:<\/span> make<\/span>(<\/span>map<\/span>[<\/span>uint32<\/span>]<\/span>ziface.<\/span>IRouter)<\/span>,<\/span>
\nWorkerPoolSize:<\/span> utils.<\/span>GlobalObject.<\/span>WorkerPoolSize,<\/span>
\nTaskQueue:<\/span> make<\/span>(<\/span>[<\/span>]<\/span>chan<\/span> ziface.<\/span>IRequest,<\/span> utils.<\/span>GlobalObject.<\/span>WorkerPoolSize)<\/span>,<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u9a6c\u4e0a\u4ee5\u975e\u963b\u585e\u65b9\u5f0f\u5904\u7406\u6d88\u606f<\/span>
\nfunc<\/span> (<\/span>mh *<\/span>MsgHandle)<\/span> DoMsgHandler<\/span>(<\/span>request ziface.<\/span>IRequest)<\/span> {<\/span>
\nhandler,<\/span> ok :=<\/span> mh.<\/span>Apis[<\/span>request.<\/span>GetMsgID<\/span>(<\/span>)<\/span>]<\/span>
\nif<\/span> !<\/span>ok {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"api msgId = "<\/span>,<\/span> request.<\/span>GetMsgID<\/span>(<\/span>)<\/span>,<\/span> " is not FOUND!"<\/span>)<\/span>
\nreturn<\/span>
\n}<\/span>
\n\/\/\u6267\u884c\u5bf9\u5e94\u5904\u7406\u65b9\u6cd5<\/span>
\nhandler.<\/span>PreHandle<\/span>(<\/span>request)<\/span>
\nhandler.<\/span>Handle<\/span>(<\/span>request)<\/span>
\nhandler.<\/span>PostHandle<\/span>(<\/span>request)<\/span>
\n}<\/span><\/p>\n

\/\/ \u4e3a\u6d88\u606f\u6dfb\u52a0\u5177\u4f53\u7684\u5904\u7406\u903b\u8f91<\/span>
\nfunc<\/span> (<\/span>mh *<\/span>MsgHandle)<\/span> AddRouter<\/span>(<\/span>msgId uint32<\/span>,<\/span> router ziface.<\/span>IRouter)<\/span> {<\/span>
\n\/\/1 \u5224\u65ad\u5f53\u524dmsg\u7ed1\u5b9a\u7684API\u5904\u7406\u65b9\u6cd5\u662f\u5426\u5df2\u7ecf\u5b58\u5728<\/span>
\nif<\/span> _<\/span>,<\/span> ok :=<\/span> mh.<\/span>Apis[<\/span>msgId]<\/span>;<\/span> ok {<\/span>
\npanic<\/span>(<\/span>"repeated api , msgId = "<\/span> +<\/span> strconv.<\/span>Itoa<\/span>(<\/span>int<\/span>(<\/span>msgId)<\/span>)<\/span>)<\/span>
\n}<\/span>
\n\/\/2 \u6dfb\u52a0msg\u4e0eapi\u7684\u7ed1\u5b9a\u5173\u7cfb<\/span>
\nmh.<\/span>Apis[<\/span>msgId]<\/span> =<\/span> router
\nfmt.<\/span>Println<\/span>(<\/span>"Add api msgId = "<\/span>,<\/span> msgId)<\/span>
\n}<\/span><\/p>\n

\/\/ \u542f\u52a8\u4e00\u4e2aWorker\u5de5\u4f5c\u6d41\u7a0b<\/span>
\nfunc<\/span> (<\/span>mh *<\/span>MsgHandle)<\/span> StartOneWorker<\/span>(<\/span>workerID int<\/span>,<\/span> taskQueue chan<\/span> ziface.<\/span>IRequest)<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Worker ID = "<\/span>,<\/span> workerID,<\/span> " is started."<\/span>)<\/span>
\n\/\/\u4e0d\u65ad\u7684\u7b49\u5f85\u961f\u5217\u4e2d\u7684\u6d88\u606f<\/span>
\nfor<\/span> {<\/span>
\nselect<\/span> {<\/span>
\n\/\/\u6709\u6d88\u606f\u5219\u53d6\u51fa\u961f\u5217\u7684Request，\u5e76\u6267\u884c\u7ed1\u5b9a\u7684\u4e1a\u52a1\u65b9\u6cd5<\/span>
\ncase<\/span> request :=<\/span> <-<\/span>taskQueue:<\/span>
\nmh.<\/span>DoMsgHandler<\/span>(<\/span>request)<\/span>
\n}<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u542f\u52a8worker\u5de5\u4f5c\u6c60<\/span>
\nfunc<\/span> (<\/span>mh *<\/span>MsgHandle)<\/span> StartWorkerPool<\/span>(<\/span>)<\/span> {<\/span>
\n\/\/\u904d\u5386\u9700\u8981\u542f\u52a8worker\u7684\u6570\u91cf，\u4f9d\u6b64\u542f\u52a8<\/span>
\nfor<\/span> i :=<\/span> 0<\/span>;<\/span> i <<\/span> int<\/span>(<\/span>mh.<\/span>WorkerPoolSize)<\/span>;<\/span> i++<\/span> {<\/span>
\n\/\/\u4e00\u4e2aworker\u88ab\u542f\u52a8<\/span>
\n\/\/\u7ed9\u5f53\u524dworker\u5bf9\u5e94\u7684\u4efb\u52a1\u961f\u5217\u5f00\u8f9f\u7a7a\u95f4<\/span>
\nmh.<\/span>TaskQueue[<\/span>i]<\/span> =<\/span> make<\/span>(<\/span>chan<\/span> ziface.<\/span>IRequest,<\/span> utils.<\/span>GlobalObject.<\/span>MaxWorkerTaskLen)<\/span>
\n\/\/\u542f\u52a8\u5f53\u524dWorker，\u963b\u585e\u7684\u7b49\u5f85\u5bf9\u5e94\u7684\u4efb\u52a1\u961f\u5217\u662f\u5426\u6709\u6d88\u606f\u4f20\u9012\u8fdb\u6765<\/span>
\ngo<\/span> mh.<\/span>StartOneWorker<\/span>(<\/span>i,<\/span> mh.<\/span>TaskQueue[<\/span>i]<\/span>)<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u5c06\u6d88\u606f\u4ea4\u7ed9TaskQueue,\u7531worker\u8fdb\u884c\u5904\u7406<\/span>
\nfunc<\/span> (<\/span>mh *<\/span>MsgHandle)<\/span> SendMsgToTaskQueue<\/span>(<\/span>request ziface.<\/span>IRequest)<\/span> {<\/span>
\n\/\/\u6839\u636eConnID\u6765\u5206\u914d\u5f53\u524d\u7684\u8fde\u63a5\u5e94\u8be5\u7531\u54ea\u4e2aworker\u8d1f\u8d23\u5904\u7406<\/span>
\n\/\/\u8f6e\u8be2\u7684\u5e73\u5747\u5206\u914d\u6cd5\u5219<\/span>
\n\/\/\u5f97\u5230\u9700\u8981\u5904\u7406\u6b64\u6761\u8fde\u63a5\u7684workerID<\/span>
\nworkerID :=<\/span> request.<\/span>GetConnection<\/span>(<\/span>)<\/span>.<\/span>GetConnID<\/span>(<\/span>)<\/span> %<\/span> mh.<\/span>WorkerPoolSize
\nfmt.<\/span>Println<\/span>(<\/span>"Add ConnID="<\/span>,<\/span> request.<\/span>GetConnection<\/span>(<\/span>)<\/span>.<\/span>GetConnID<\/span>(<\/span>)<\/span>,<\/span> " request msgID="<\/span>,<\/span> request.<\/span>GetMsgID<\/span>(<\/span>)<\/span>,<\/span> "to workerID="<\/span>,<\/span> workerID)<\/span>
\n\/\/\u5c06\u8bf7\u6c42\u6d88\u606f\u53d1\u9001\u7ed9\u4efb\u52a1\u961f\u5217<\/span>
\nmh.<\/span>TaskQueue[<\/span>workerID]<\/span> <-<\/span> request
\n}<\/span><\/p>\n

request<\/p>\n

package<\/span> znet<\/p>\n

import<\/span> (<\/span>
\n"datarace\/zinx\/ziface"<\/span>
\n)<\/span><\/p>\n

type<\/span> Request struct<\/span> {<\/span>
\nconn ziface.<\/span>IConnection
\nmsg ziface.<\/span>IMessage
\n}<\/span><\/p>\n

func<\/span> (<\/span>r *<\/span>Request)<\/span> GetConnection<\/span>(<\/span>)<\/span> ziface.<\/span>IConnection {<\/span>
\nreturn<\/span> r.<\/span>conn
\n}<\/span><\/p>\n

\/\/ \u83b7\u53d6\u8bf7\u6c42\u6d88\u606f\u7684\u6570\u636e<\/span>
\nfunc<\/span> (<\/span>r *<\/span>Request)<\/span> GetData<\/span>(<\/span>)<\/span> [<\/span>]<\/span>byte<\/span> {<\/span>
\nreturn<\/span> r.<\/span>msg.<\/span>GetData<\/span>(<\/span>)<\/span>
\n}<\/span><\/p>\n

\/\/ \u83b7\u53d6\u8bf7\u6c42\u7684\u6d88\u606f\u7684ID<\/span>
\nfunc<\/span> (<\/span>r *<\/span>Request)<\/span> GetMsgID<\/span>(<\/span>)<\/span> uint32<\/span> {<\/span>
\nreturn<\/span> r.<\/span>msg.<\/span>GetMsgId<\/span>(<\/span>)<\/span>
\n}<\/span><\/p>\n

router<\/p>\n

package<\/span> znet<\/p>\n

import<\/span> "datarace\/zinx\/ziface"<\/span><\/p>\n

type<\/span> BaseRouter struct<\/span>{<\/span>}<\/span><\/p>\n

func<\/span> (<\/span>br *<\/span>BaseRouter)<\/span> PreHandle<\/span>(<\/span>request ziface.<\/span>IRequest)<\/span> {<\/span>}<\/span>
\nfunc<\/span> (<\/span>br *<\/span>BaseRouter)<\/span> Handle<\/span>(<\/span>request ziface.<\/span>IRequest)<\/span> {<\/span>}<\/span>
\nfunc<\/span> (<\/span>br *<\/span>BaseRouter)<\/span> PostHandle<\/span>(<\/span>request ziface.<\/span>IRequest)<\/span> {<\/span>}<\/span><\/p>\n

server<\/p>\n

package<\/span> znet<\/p>\n

import<\/span> (<\/span>
\n"datarace\/zinx\/utils"<\/span>
\n"datarace\/zinx\/ziface"<\/span>
\n"fmt"<\/span>
\n"net"<\/span>
\n"time"<\/span>
\n)<\/span><\/p>\n

\/\/ iServer \u63a5\u53e3\u5b9e\u73b0，\u5b9a\u4e49\u4e00\u4e2aServer\u670d\u52a1\u7c7b<\/span>
\ntype<\/span> Server struct<\/span> {<\/span>
\n\/\/\u670d\u52a1\u5668\u7684\u540d\u79f0<\/span>
\nName string<\/span>
\n\/\/tcp4 or other<\/span>
\nIPVersion string<\/span>
\n\/\/\u670d\u52a1\u7ed1\u5b9a\u7684IP\u5730\u5740<\/span>
\nIP string<\/span>
\n\/\/\u670d\u52a1\u7ed1\u5b9a\u7684\u7aef\u53e3<\/span>
\nPort int<\/span>
\n\/\/\u5f53\u524dServer\u7684\u6d88\u606f\u7ba1\u7406\u6a21\u5757，\u7528\u6765\u7ed1\u5b9aMsgId\u548c\u5bf9\u5e94\u7684\u5904\u7406\u65b9\u6cd5<\/span>
\nmsgHandler ziface.<\/span>IMsgHandle
\n\/\/\u5f53\u524dServer\u7684\u94fe\u63a5\u7ba1\u7406\u5668<\/span>
\nConnMgr ziface.<\/span>IConnManager
\n\/\/\u65b0\u589e\u4e24\u4e2ahook\u51fd\u6570\u539f\u578b<\/span>
\n\/\/\u8be5Server\u7684\u8fde\u63a5\u521b\u5efa\u65f6Hook\u51fd\u6570<\/span>
\nOnConnStart func<\/span>(<\/span>conn ziface.<\/span>IConnection)<\/span>
\n\/\/\u8be5Server\u7684\u8fde\u63a5\u65ad\u5f00\u65f6\u7684Hook\u51fd\u6570<\/span>
\nOnConnStop func<\/span>(<\/span>conn ziface.<\/span>IConnection)<\/span>
\n}<\/span><\/p>\n

\/\/ \u5f97\u5230\u94fe\u63a5\u7ba1\u7406<\/span>
\nfunc<\/span> (<\/span>s *<\/span>Server)<\/span> GetConnMgr<\/span>(<\/span>)<\/span> ziface.<\/span>IConnManager {<\/span>
\nreturn<\/span> s.<\/span>ConnMgr
\n}<\/span><\/p>\n

\/\/ ============== \u5b9e\u73b0 ziface.IServer \u91cc\u7684\u5168\u90e8\u63a5\u53e3\u65b9\u6cd5 ========<\/span>
\n\/\/ \u5f00\u542f\u7f51\u7edc\u670d\u52a1<\/span>
\nfunc<\/span> (<\/span>s *<\/span>Server)<\/span> Start<\/span>(<\/span>)<\/span> {<\/span>
\nfmt.<\/span>Printf<\/span>(<\/span>"[START] Server listenner at IP: %s, Port %d, is starting\\\\n"<\/span>,<\/span> s.<\/span>IP,<\/span> s.<\/span>Port)<\/span>
\nfmt.<\/span>Printf<\/span>(<\/span>"[START] Server name: %s,listenner at IP: %s, Port %d is starting\\\\n"<\/span>,<\/span> s.<\/span>Name,<\/span> s.<\/span>IP,<\/span> s.<\/span>Port)<\/span>
\nfmt.<\/span>Printf<\/span>(<\/span>"[Zinx] Version: %s, MaxConn: %d, MaxPacketSize: %d\\\\n"<\/span>,<\/span>
\nutils.<\/span>GlobalObject.<\/span>Version,<\/span>
\nutils.<\/span>GlobalObject.<\/span>MaxConn,<\/span>
\nutils.<\/span>GlobalObject.<\/span>MaxPacketSize)<\/span>
\n\/\/\u5f00\u542f\u4e00\u4e2ago\u53bb\u505a\u670d\u52a1\u7aefLinster\u4e1a\u52a1<\/span>
\ngo<\/span> func<\/span>(<\/span>)<\/span> {<\/span>
\n\/\/1 \u83b7\u53d6\u4e00\u4e2aTCP\u7684Addr<\/span>
\ns.<\/span>msgHandler.<\/span>StartWorkerPool<\/span>(<\/span>)<\/span>
\naddr,<\/span> err :=<\/span> net.<\/span>ResolveTCPAddr<\/span>(<\/span>s.<\/span>IPVersion,<\/span> fmt.<\/span>Sprintf<\/span>(<\/span>"%s:%d"<\/span>,<\/span> s.<\/span>IP,<\/span> s.<\/span>Port)<\/span>)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"resolve tcp addr err: "<\/span>,<\/span> err)<\/span>
\nreturn<\/span>
\n}<\/span>
\n\/\/2 \u76d1\u542c\u670d\u52a1\u5668\u5730\u5740<\/span>
\nlistenner,<\/span> err :=<\/span> net.<\/span>ListenTCP<\/span>(<\/span>s.<\/span>IPVersion,<\/span> addr)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"listen"<\/span>,<\/span> s.<\/span>IPVersion,<\/span> "err"<\/span>,<\/span> err)<\/span>
\nreturn<\/span>
\n}<\/span>
\n\/\/\u5df2\u7ecf\u76d1\u542c\u6210\u529f<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"start Zinx server "<\/span>,<\/span> s.<\/span>Name,<\/span> " succ, now listenning…"<\/span>)<\/span>
\nvar<\/span> cid uint32<\/span>
\ncid =<\/span> 0<\/span>
\n\/\/3 \u542f\u52a8server\u7f51\u7edc\u8fde\u63a5\u4e1a\u52a1<\/span>
\nfor<\/span> {<\/span>
\n\/\/3.1 \u963b\u585e\u7b49\u5f85\u5ba2\u6237\u7aef\u5efa\u7acb\u8fde\u63a5\u8bf7\u6c42<\/span>
\nconn,<\/span> err :=<\/span> listenner.<\/span>AcceptTCP<\/span>(<\/span>)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Accept err "<\/span>,<\/span> err)<\/span>
\ncontinue<\/span>
\n}<\/span>
\n\/\/=============<\/span>
\n\/\/3.2 \u8bbe\u7f6e\u670d\u52a1\u5668\u6700\u5927\u8fde\u63a5\u63a7\u5236,\u5982\u679c\u8d85\u8fc7\u6700\u5927\u8fde\u63a5，\u90a3\u4e48\u5219\u5173\u95ed\u6b64\u65b0\u7684\u8fde\u63a5<\/span>
\nif<\/span> s.<\/span>ConnMgr.<\/span>Len<\/span>(<\/span>)<\/span> >=<\/span> utils.<\/span>GlobalObject.<\/span>MaxConn {<\/span>
\nconn.<\/span>Close<\/span>(<\/span>)<\/span>
\ncontinue<\/span>
\n}<\/span>
\n\/\/=============<\/span>
\n\/\/3.3 \u5904\u7406\u8be5\u65b0\u8fde\u63a5\u8bf7\u6c42\u7684 \u4e1a\u52a1 \u65b9\u6cd5， \u6b64\u65f6\u5e94\u8be5\u6709 handler \u548c conn\u662f\u7ed1\u5b9a\u7684<\/span>
\ndealConn :=<\/span> NewConntion<\/span>(<\/span>s,<\/span> conn,<\/span> cid,<\/span> s.<\/span>msgHandler)<\/span>
\ncid++<\/span>
\n\/\/3.4 \u542f\u52a8\u5f53\u524d\u94fe\u63a5\u7684\u5904\u7406\u4e1a\u52a1<\/span>
\ngo<\/span> dealConn.<\/span>Start<\/span>(<\/span>)<\/span>
\n\/\/go func() {<\/span>
\n\/\/\/\/\u4e0d\u65ad\u7684\u5faa\u73af\u4ece\u5ba2\u6237\u7aef\u83b7\u53d6\u6570\u636e<\/span>
\n\/\/for {<\/span>
\n\/\/buf := make([]byte, 512)<\/span>
\n\/\/cnt, err := conn.Read(buf)<\/span>
\n\/\/if err != nil {<\/span>
\n\/\/fmt.Println("recv buf err ", err)<\/span>
\n\/\/continue<\/span>
\n\/\/}<\/span>
\n\/\/\/\/\u56de\u663e<\/span>
\n\/\/if _, err := conn.Write(buf[:cnt]); err != nil {<\/span>
\n\/\/fmt.Println("write back buf err ", err)<\/span>
\n\/\/continue<\/span>
\n\/\/}<\/span>
\n\/\/}<\/span>
\n\/\/}()<\/span>
\n}<\/span>
\n}<\/span>(<\/span>)<\/span>
\n}<\/span>
\nfunc<\/span> (<\/span>s *<\/span>Server)<\/span> Stop<\/span>(<\/span>)<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"[STOP] Zinx server , name "<\/span>,<\/span> s.<\/span>Name)<\/span>
\n\/\/\u5c06\u5176\u4ed6\u9700\u8981\u6e05\u7406\u7684\u8fde\u63a5\u4fe1\u606f\u6216\u8005\u5176\u4ed6\u4fe1\u606f \u4e5f\u8981\u4e00\u5e76\u505c\u6b62\u6216\u8005\u6e05\u7406<\/span>
\ns.<\/span>ConnMgr.<\/span>ClearConn<\/span>(<\/span>)<\/span>
\n}<\/span>
\nfunc<\/span> (<\/span>s *<\/span>Server)<\/span> Serve<\/span>(<\/span>)<\/span> {<\/span>
\ns.<\/span>Start<\/span>(<\/span>)<\/span>
\n\/\/TODO Server.Serve() \u662f\u5426\u5728\u542f\u52a8\u670d\u52a1\u7684\u65f6\u5019 \u8fd8\u8981\u5904\u7406\u5176\u4ed6\u7684\u4e8b\u60c5\u5462 \u53ef\u4ee5\u5728\u8fd9\u91cc\u6dfb\u52a0<\/span>
\n\/\/\u963b\u585e,\u5426\u5219\u4e3bGo\u9000\u51fa， listenner\u7684go\u5c06\u4f1a\u9000\u51fa<\/span>
\nfor<\/span> {<\/span>
\ntime.<\/span>Sleep<\/span>(<\/span>10<\/span> *<\/span> time.<\/span>Second)<\/span>
\n}<\/span>
\n}<\/span>
\nfunc<\/span> (<\/span>s *<\/span>Server)<\/span> AddRouter<\/span>(<\/span>msgId uint32<\/span>,<\/span> router ziface.<\/span>IRouter)<\/span> {<\/span>
\ns.<\/span>msgHandler.<\/span>AddRouter<\/span>(<\/span>msgId,<\/span> router)<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Add Router SUCC!! msgID = "<\/span>,<\/span> msgId)<\/span>
\n}<\/span><\/p>\n

\/*
\n\u521b\u5efa\u4e00\u4e2a\u670d\u52a1\u5668\u53e5\u67c4
\n*\/<\/span>
\nfunc<\/span> NewServer<\/span>(<\/span>)<\/span> *<\/span>Server {<\/span>
\nutils.<\/span>GlobalObject.<\/span>Reload<\/span>(<\/span>)<\/span>
\ns :=<\/span> &<\/span>Server{<\/span>
\nName:<\/span> utils.<\/span>GlobalObject.<\/span>Name,<\/span>
\nIPVersion:<\/span> "tcp4"<\/span>,<\/span>
\nIP:<\/span> utils.<\/span>GlobalObject.<\/span>Host,<\/span>
\nPort:<\/span> utils.<\/span>GlobalObject.<\/span>TcpPort,<\/span>
\nmsgHandler:<\/span> NewMsgHandle<\/span>(<\/span>)<\/span>,<\/span> \/\/msgHandler \u521d\u59cb\u5316<\/span>
\nConnMgr:<\/span> NewConnManager<\/span>(<\/span>)<\/span>,<\/span> \/\/\u521b\u5efaConnManage<\/span>
\n}<\/span>
\nreturn<\/span> s
\n}<\/span><\/p>\n

\/\/ \u8bbe\u7f6e\u8be5Server\u7684\u8fde\u63a5\u521b\u5efa\u65f6Hook\u51fd\u6570<\/span>
\nfunc<\/span> (<\/span>s *<\/span>Server)<\/span> SetOnConnStart<\/span>(<\/span>hookFunc func<\/span>(<\/span>ziface.<\/span>IConnection)<\/span>)<\/span> {<\/span>
\ns.<\/span>OnConnStart =<\/span> hookFunc
\n}<\/span><\/p>\n

\/\/ \u8bbe\u7f6e\u8be5Server\u7684\u8fde\u63a5\u65ad\u5f00\u65f6\u7684Hook\u51fd\u6570<\/span>
\nfunc<\/span> (<\/span>s *<\/span>Server)<\/span> SetOnConnStop<\/span>(<\/span>hookFunc func<\/span>(<\/span>ziface.<\/span>IConnection)<\/span>)<\/span> {<\/span>
\ns.<\/span>OnConnStop =<\/span> hookFunc
\n}<\/span><\/p>\n

\/\/ \u8c03\u7528\u8fde\u63a5OnConnStart Hook\u51fd\u6570<\/span>
\nfunc<\/span> (<\/span>s *<\/span>Server)<\/span> CallOnConnStart<\/span>(<\/span>conn ziface.<\/span>IConnection)<\/span> {<\/span>
\nif<\/span> s.<\/span>OnConnStart !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"—> CallOnConnStart…."<\/span>)<\/span>
\ns.<\/span>OnConnStart<\/span>(<\/span>conn)<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u8c03\u7528\u8fde\u63a5OnConnStop Hook\u51fd\u6570<\/span>
\nfunc<\/span> (<\/span>s *<\/span>Server)<\/span> CallOnConnStop<\/span>(<\/span>conn ziface.<\/span>IConnection)<\/span> {<\/span>
\nif<\/span> s.<\/span>OnConnStop !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"—> CallOnConnStop…."<\/span>)<\/span>
\ns.<\/span>OnConnStop<\/span>(<\/span>conn)<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\u5ba2\u6237\u7aef<\/p>\n

package<\/span> main<\/p>\n

import<\/span> (<\/span>
\n"datarace\/zinx\/znet"<\/span>
\n"fmt"<\/span>
\n"io"<\/span>
\n"net"<\/span>
\n"time"<\/span>
\n)<\/span><\/p>\n

\/*
\n\u6a21\u62df\u5ba2\u6237\u7aef
\n*\/<\/span>
\nfunc<\/span> main<\/span>(<\/span>)<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Client Test … start"<\/span>)<\/span>
\n\/\/3\u79d2\u4e4b\u540e\u53d1\u8d77\u6d4b\u8bd5\u8bf7\u6c42，\u7ed9\u670d\u52a1\u7aef\u5f00\u542f\u670d\u52a1\u7684\u673a\u4f1a<\/span>
\ntime.<\/span>Sleep<\/span>(<\/span>3<\/span> *<\/span> time.<\/span>Second)<\/span>
\nconn,<\/span> err :=<\/span> net.<\/span>Dial<\/span>(<\/span>"tcp"<\/span>,<\/span> "127.0.0.1:7777"<\/span>)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"client start err, exit!"<\/span>)<\/span>
\nreturn<\/span>
\n}<\/span>
\nfor<\/span> {<\/span>
\n\/\/\u53d1\u5c01\u5305message\u6d88\u606f<\/span>
\ndp :=<\/span> znet.<\/span>NewDataPack<\/span>(<\/span>)<\/span>
\nmsg,<\/span> _<\/span> :=<\/span> dp.<\/span>Pack<\/span>(<\/span>znet.<\/span>NewMsgPackage<\/span>(<\/span>0<\/span>,<\/span> [<\/span>]<\/span>byte<\/span>(<\/span>"Zinx V0.8 Client0 Test Message"<\/span>)<\/span>)<\/span>)<\/span>
\n_<\/span>,<\/span> err :=<\/span> conn.<\/span>Write<\/span>(<\/span>msg)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"write error err "<\/span>,<\/span> err)<\/span>
\nreturn<\/span>
\n}<\/span>
\n\/\/\u5148\u8bfb\u51fa\u6d41\u4e2d\u7684head\u90e8\u5206<\/span>
\nheadData :=<\/span> make<\/span>(<\/span>[<\/span>]<\/span>byte<\/span>,<\/span> dp.<\/span>GetHeadLen<\/span>(<\/span>)<\/span>)<\/span>
\n_<\/span>,<\/span> err =<\/span> io.<\/span>ReadFull<\/span>(<\/span>conn,<\/span> headData)<\/span> \/\/ReadFull \u4f1a\u628amsg\u586b\u5145\u6ee1\u4e3a\u6b62<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"read head error"<\/span>)<\/span>
\nbreak<\/span>
\n}<\/span>
\n\/\/\u5c06headData\u5b57\u8282\u6d41 \u62c6\u5305\u5230msg\u4e2d<\/span>
\nmsgHead,<\/span> err :=<\/span> dp.<\/span>Unpack<\/span>(<\/span>headData)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"server unpack err:"<\/span>,<\/span> err)<\/span>
\nreturn<\/span>
\n}<\/span>
\nif<\/span> msgHead.<\/span>GetDataLen<\/span>(<\/span>)<\/span> ><\/span> 0<\/span> {<\/span>
\n\/\/msg \u662f\u6709data\u6570\u636e\u7684，\u9700\u8981\u518d\u6b21\u8bfb\u53d6data\u6570\u636e<\/span>
\nmsg :=<\/span> msgHead.<\/span>(<\/span>*<\/span>znet.<\/span>Message)<\/span>
\nmsg.<\/span>Data =<\/span> make<\/span>(<\/span>[<\/span>]<\/span>byte<\/span>,<\/span> msg.<\/span>GetDataLen<\/span>(<\/span>)<\/span>)<\/span>
\n\/\/\u6839\u636edataLen\u4eceio\u4e2d\u8bfb\u53d6\u5b57\u8282\u6d41<\/span>
\n_<\/span>,<\/span> err :=<\/span> io.<\/span>ReadFull<\/span>(<\/span>conn,<\/span> msg.<\/span>Data)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"server unpack data err:"<\/span>,<\/span> err)<\/span>
\nreturn<\/span>
\n}<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"==> Recv Msg: ID="<\/span>,<\/span> msg.<\/span>Id,<\/span> ", len="<\/span>,<\/span> msg.<\/span>DataLen,<\/span> ", data="<\/span>,<\/span> string<\/span>(<\/span>msg.<\/span>Data)<\/span>)<\/span>
\n}<\/span>
\ntime.<\/span>Sleep<\/span>(<\/span>1<\/span> *<\/span> time.<\/span>Second)<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\u670d\u52a1\u7aef<\/p>\n

package<\/span> main<\/p>\n

import<\/span> (<\/span>
\n"datarace\/zinx\/ziface"<\/span>
\n"datarace\/zinx\/znet"<\/span>
\n"fmt"<\/span>
\n)<\/span><\/p>\n

\/\/ ping test \u81ea\u5b9a\u4e49\u8def\u7531<\/span>
\ntype<\/span> PingRouter struct<\/span> {<\/span>
\nznet.<\/span>BaseRouter
\n}<\/span><\/p>\n

\/\/ Ping Handle<\/span>
\nfunc<\/span> (<\/span>this *<\/span>PingRouter)<\/span> Handle<\/span>(<\/span>request ziface.<\/span>IRequest)<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Call PingRouter Handle"<\/span>)<\/span>
\n\/\/\u5148\u8bfb\u53d6\u5ba2\u6237\u7aef\u7684\u6570\u636e，\u518d\u56de\u5199ping…ping…ping<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"recv from client : msgId="<\/span>,<\/span> request.<\/span>GetMsgID<\/span>(<\/span>)<\/span>,<\/span> ", data="<\/span>,<\/span> string<\/span>(<\/span>request.<\/span>GetData<\/span>(<\/span>)<\/span>)<\/span>)<\/span>
\nerr :=<\/span> request.<\/span>GetConnection<\/span>(<\/span>)<\/span>.<\/span>SendBuffMsg<\/span>(<\/span>0<\/span>,<\/span> [<\/span>]<\/span>byte<\/span>(<\/span>"ping…ping…ping"<\/span>)<\/span>)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>err)<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

type<\/span> HelloZinxRouter struct<\/span> {<\/span>
\nznet.<\/span>BaseRouter
\n}<\/span><\/p>\n

\/\/ HelloZinxRouter Handle<\/span>
\nfunc<\/span> (<\/span>this *<\/span>HelloZinxRouter)<\/span> Handle<\/span>(<\/span>request ziface.<\/span>IRequest)<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Call HelloZinxRouter Handle"<\/span>)<\/span>
\n\/\/\u5148\u8bfb\u53d6\u5ba2\u6237\u7aef\u7684\u6570\u636e，\u518d\u56de\u5199ping…ping…ping<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"recv from client : msgId="<\/span>,<\/span> request.<\/span>GetMsgID<\/span>(<\/span>)<\/span>,<\/span> ", data="<\/span>,<\/span> string<\/span>(<\/span>request.<\/span>GetData<\/span>(<\/span>)<\/span>)<\/span>)<\/span>
\nerr :=<\/span> request.<\/span>GetConnection<\/span>(<\/span>)<\/span>.<\/span>SendBuffMsg<\/span>(<\/span>1<\/span>,<\/span> [<\/span>]<\/span>byte<\/span>(<\/span>"Hello Zinx Router V0.10"<\/span>)<\/span>)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>err)<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u521b\u5efa\u8fde\u63a5\u7684\u65f6\u5019\u6267\u884c<\/span>
\nfunc<\/span> DoConnectionBegin<\/span>(<\/span>conn ziface.<\/span>IConnection)<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"DoConnecionBegin is Called … "<\/span>)<\/span>
\n\/\/=============\u8bbe\u7f6e\u4e24\u4e2a\u94fe\u63a5\u5c5e\u6027，\u5728\u8fde\u63a5\u521b\u5efa\u4e4b\u540e===========<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Set conn Name, Home done!"<\/span>)<\/span>
\nconn.<\/span>SetProperty<\/span>(<\/span>"Name"<\/span>,<\/span> "Aceld"<\/span>)<\/span>
\nconn.<\/span>SetProperty<\/span>(<\/span>"Home"<\/span>,<\/span> "https:\/\/www.jianshu.com\/u\/35261429b7f1"<\/span>)<\/span>
\n\/\/===================================================<\/span>
\nerr :=<\/span> conn.<\/span>SendMsg<\/span>(<\/span>2<\/span>,<\/span> [<\/span>]<\/span>byte<\/span>(<\/span>"DoConnection BEGIN…"<\/span>)<\/span>)<\/span>
\nif<\/span> err !=<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>err)<\/span>
\n}<\/span>
\n}<\/span><\/p>\n

\/\/ \u8fde\u63a5\u65ad\u5f00\u7684\u65f6\u5019\u6267\u884c<\/span>
\nfunc<\/span> DoConnectionLost<\/span>(<\/span>conn ziface.<\/span>IConnection)<\/span> {<\/span>
\n\/\/============\u5728\u8fde\u63a5\u9500\u6bc1\u4e4b\u524d，\u67e5\u8be2conn\u7684Name，Home\u5c5e\u6027=====<\/span>
\nif<\/span> name,<\/span> err :=<\/span> conn.<\/span>GetProperty<\/span>(<\/span>"Name"<\/span>)<\/span>;<\/span> err ==<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Conn Property Name = "<\/span>,<\/span> name)<\/span>
\n}<\/span>
\nif<\/span> home,<\/span> err :=<\/span> conn.<\/span>GetProperty<\/span>(<\/span>"Home"<\/span>)<\/span>;<\/span> err ==<\/span> nil<\/span> {<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"Conn Property Home = "<\/span>,<\/span> home)<\/span>
\n}<\/span>
\n\/\/===================================================<\/span>
\nfmt.<\/span>Println<\/span>(<\/span>"DoConneciotnLost is Called … "<\/span>)<\/span>
\n}<\/span>
\nfunc<\/span> main<\/span>(<\/span>)<\/span> {<\/span>
\n\/\/\u521b\u5efa\u4e00\u4e2aserver\u53e5\u67c4<\/span>
\ns :=<\/span> znet.<\/span>NewServer<\/span>(<\/span>)<\/span>
\n\/\/\u6ce8\u518c\u94fe\u63a5hook\u56de\u8c03\u51fd\u6570<\/span>
\ns.<\/span>SetOnConnStart<\/span>(<\/span>DoConnectionBegin)<\/span>
\ns.<\/span>SetOnConnStop<\/span>(<\/span>DoConnectionLost)<\/span>
\n\/\/\u914d\u7f6e\u8def\u7531<\/span>
\ns.<\/span>AddRouter<\/span>(<\/span>0<\/span>,<\/span> &<\/span>PingRouter{<\/span>}<\/span>)<\/span>
\ns.<\/span>AddRouter<\/span>(<\/span>1<\/span>,<\/span> &<\/span>HelloZinxRouter{<\/span>}<\/span>)<\/span>
\n\/\/\u5f00\u542f\u670d\u52a1<\/span>
\ns.<\/span>Serve<\/span>(<\/span>)<\/span>
\n}<\/span><\/p>\n

\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\" \"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"<\/p>\n","protected":false},"excerpt":{"rendered":"

\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb908\u6b21\u3002Zinx \u662f\u4e00\u4e2a\u7528 Go \u8bed\u8a00\u7f16\u5199\u7684\u9ad8\u6027\u80fd\u3001\u8f7b\u91cf\u7ea7\u7684 TCP \u670d\u52a1\u5668\u6846\u67b6\uff0c\u5b83\u88ab\u8bbe\u8ba1\u4e3a\u7b80\u5355\u3001\u5feb\u901f\u4e14\u6613\u4e8e\u4f7f\u7528\u3002Zinx \u63d0\u4f9b\u4e86\u4e00\u7cfb\u5217\u7684\u529f\u80fd\uff0c\u5305\u62ec\u4f46\u4e0d\u9650\u4e8e\u8fde\u63a5\u7ba1\u7406\u3001\u6570\u636e\u7f16\u89e3\u7801\u3001\u4e1a\u52a1\u5904\u7406\u3001\u8d1f\u8f7d\u5747\u8861\u7b49\uff0c\u9002\u7528\u4e8e\u6784\u5efa\u5404\u79cd TCP \u7f51\u7edc\u670d\u52a1\uff0c\u5982\u6e38\u620f\u670d\u52a1\u5668\u3001\u5373\u65f6\u901a\u8baf\u670d\u52a1\u5668\u7b49\u3002\u4e0b\u9762\u5b9e\u73b0zinx\u7684\u591a\u4e2a\u529f\u80fd\u5305\u62ec\uff1a\u8def\u7531\u3001\u5168\u5c40\u914d\u7f6e\u3001\u6d88\u606f\u5c01\u88c5\u3001\u8bfb\u5199\u5206\u79bb\u3001\u6d88\u606f\u961f\u5217\u3001\u94fe\u63a5\u7ba1\u7406\u7b49\u3002utils\u5305\u4e0bGlobalObj.go\u3002_zinx<\/p>\n","protected":false},"author":2,"featured_media":16849,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[92,745,423,43,44],"topic":[],"class_list":["post-16852","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-github","tag-go","tag-423","tag-43","tag-44"],"yoast_head":"\n\u5e76\u53d1\u670d\u52a1\u5668\u6846\u67b6\u2014\u2014zinx - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/16852.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u5e76\u53d1\u670d\u52a1\u5668\u6846\u67b6\u2014\u2014zinx - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb908\u6b21\u3002Zinx \u662f\u4e00\u4e2a\u7528 Go \u8bed\u8a00\u7f16\u5199\u7684\u9ad8\u6027\u80fd\u3001\u8f7b\u91cf\u7ea7\u7684 TCP \u670d\u52a1\u5668\u6846\u67b6\uff0c\u5b83\u88ab\u8bbe\u8ba1\u4e3a\u7b80\u5355\u3001\u5feb\u901f\u4e14\u6613\u4e8e\u4f7f\u7528\u3002Zinx \u63d0\u4f9b\u4e86\u4e00\u7cfb\u5217\u7684\u529f\u80fd\uff0c\u5305\u62ec\u4f46\u4e0d\u9650\u4e8e\u8fde\u63a5\u7ba1\u7406\u3001\u6570\u636e\u7f16\u89e3\u7801\u3001\u4e1a\u52a1\u5904\u7406\u3001\u8d1f\u8f7d\u5747\u8861\u7b49\uff0c\u9002\u7528\u4e8e\u6784\u5efa\u5404\u79cd TCP \u7f51\u7edc\u670d\u52a1\uff0c\u5982\u6e38\u620f\u670d\u52a1\u5668\u3001\u5373\u65f6\u901a\u8baf\u670d\u52a1\u5668\u7b49\u3002\u4e0b\u9762\u5b9e\u73b0zinx\u7684\u591a\u4e2a\u529f\u80fd\u5305\u62ec\uff1a\u8def\u7531\u3001\u5168\u5c40\u914d\u7f6e\u3001\u6d88\u606f\u5c01\u88c5\u3001\u8bfb\u5199\u5206\u79bb\u3001\u6d88\u606f\u961f\u5217\u3001\u94fe\u63a5\u7ba1\u7406\u7b49\u3002utils\u5305\u4e0bGlobalObj.go\u3002_zinx\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/16852.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2025-04-18T15:17:06+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418151705-68026cf119ec6.png\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"13 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/16852.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/16852.html\",\"name\":\"\u5e76\u53d1\u670d\u52a1\u5668\u6846\u67b6\u2014\u2014zinx - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2025-04-18T15:17:06+00:00\",\"dateModified\":\"2025-04-18T15:17:06+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/16852.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/16852.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/16852.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u5e76\u53d1\u670d\u52a1\u5668\u6846\u67b6\u2014\u2014zinx\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"\u5e76\u53d1\u670d\u52a1\u5668\u6846\u67b6\u2014\u2014zinx - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/16852.html","og_locale":"zh_CN","og_type":"article","og_title":"\u5e76\u53d1\u670d\u52a1\u5668\u6846\u67b6\u2014\u2014zinx - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb908\u6b21\u3002Zinx \u662f\u4e00\u4e2a\u7528 Go \u8bed\u8a00\u7f16\u5199\u7684\u9ad8\u6027\u80fd\u3001\u8f7b\u91cf\u7ea7\u7684 TCP \u670d\u52a1\u5668\u6846\u67b6\uff0c\u5b83\u88ab\u8bbe\u8ba1\u4e3a\u7b80\u5355\u3001\u5feb\u901f\u4e14\u6613\u4e8e\u4f7f\u7528\u3002Zinx \u63d0\u4f9b\u4e86\u4e00\u7cfb\u5217\u7684\u529f\u80fd\uff0c\u5305\u62ec\u4f46\u4e0d\u9650\u4e8e\u8fde\u63a5\u7ba1\u7406\u3001\u6570\u636e\u7f16\u89e3\u7801\u3001\u4e1a\u52a1\u5904\u7406\u3001\u8d1f\u8f7d\u5747\u8861\u7b49\uff0c\u9002\u7528\u4e8e\u6784\u5efa\u5404\u79cd TCP \u7f51\u7edc\u670d\u52a1\uff0c\u5982\u6e38\u620f\u670d\u52a1\u5668\u3001\u5373\u65f6\u901a\u8baf\u670d\u52a1\u5668\u7b49\u3002\u4e0b\u9762\u5b9e\u73b0zinx\u7684\u591a\u4e2a\u529f\u80fd\u5305\u62ec\uff1a\u8def\u7531\u3001\u5168\u5c40\u914d\u7f6e\u3001\u6d88\u606f\u5c01\u88c5\u3001\u8bfb\u5199\u5206\u79bb\u3001\u6d88\u606f\u961f\u5217\u3001\u94fe\u63a5\u7ba1\u7406\u7b49\u3002utils\u5305\u4e0bGlobalObj.go\u3002_zinx","og_url":"https:\/\/www.wsisp.com\/helps\/16852.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2025-04-18T15:17:06+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418151705-68026cf119ec6.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"13 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/16852.html","url":"https:\/\/www.wsisp.com\/helps\/16852.html","name":"\u5e76\u53d1\u670d\u52a1\u5668\u6846\u67b6\u2014\u2014zinx - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2025-04-18T15:17:06+00:00","dateModified":"2025-04-18T15:17:06+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/16852.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/16852.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/16852.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u5e76\u53d1\u670d\u52a1\u5668\u6846\u67b6\u2014\u2014zinx"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/16852","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=16852"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/16852\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/16849"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=16852"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=16852"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=16852"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=16852"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}