Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-28 01:44:47 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

新增端口配置

Browse Source
This commit is contained in:
boyce
2020-02-07 15:25:39 +08:00
parent 7fd97033ec
commit 6b142b1fde
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Test/config/nodeconfig.json
View File

@@ -2,8 +2,8 @@
"Public":{ "Public":{
"LogLevel":1, "LogLevel":1,
"HttpPort":9400, "HttpPort":9400,
"WSPort":9500, "WSPort":9401,
"ListenPort":9402,
"CAFile":[ "CAFile":[
{ {
"CertFile":"", "CertFile":"",

6
network/tcpsocketserver.go
View File

@@ -42,6 +42,7 @@ type TcpSocketServer struct {
MaxRecvPackSize uint16 MaxRecvPackSize uint16
MaxSendPackSize uint16 MaxSendPackSize uint16
iReciver ITcpSocketServerReciver iReciver ITcpSocketServerReciver
nodelay bool
} }
type MsgBasePack struct { type MsgBasePack struct {
@@ -74,6 +75,8 @@ func (slf *TcpSocketServer) Start(){
} }
func (slf *TcpSocketServer) listenServer(){ func (slf *TcpSocketServer) listenServer(){
slf.nodelay = true
listener, err := net.Listen("tcp", slf.listenAddr) listener, err := net.Listen("tcp", slf.listenAddr)
if err != nil { if err != nil {
service.GetLogger().Printf(service.LEVER_FATAL, "TcpSocketServer Listen error %+v",err) service.GetLogger().Printf(service.LEVER_FATAL, "TcpSocketServer Listen error %+v",err)
@@ -88,6 +91,9 @@ func (slf *TcpSocketServer) listenServer(){
continue continue
} }
if slf.nodelay {
//conn.(ifaceSetNoDelay)
}
for { for {
clientId += 1 clientId += 1
if slf.mapClient.Get(clientId)!= nil { if slf.mapClient.Get(clientId)!= nil {