Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-05-22 01:27:32 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化websocket服务

Browse Source
This commit is contained in:
boyce
2019-01-26 16:47:15 +08:00
parent e71c339f0d
commit 423da02940
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
network/websocketserver.go
View File

@@ -83,7 +83,7 @@ func (slf *WebsocketServer) Init(pattern string, port uint16, messageReciver IMe
slf.mapClient = make(map[uint64]*WSClient) slf.mapClient = make(map[uint64]*WSClient)
slf.messageReciver = messageReciver slf.messageReciver = messageReciver
http.HandleFunc("/ws", slf.wsHandler) http.HandleFunc(slf.pattern, slf.wsHandler)
} }
func (slf *WebsocketServer) startListen() { func (slf *WebsocketServer) startListen() {

6
service/Service.go
View File

@@ -35,6 +35,7 @@ type IService interface {
OnFetchService(iservice IService) error OnFetchService(iservice IService) error
GetServiceType() int GetServiceType() int
GetServiceName() string GetServiceName() string
SetServiceName(serviceName string) bool
GetServiceId() int GetServiceId() int
IsTimeOutTick(microSecond int64) bool IsTimeOutTick(microSecond int64) bool
@@ -94,6 +95,11 @@ func (slf *BaseService) GetServiceName() string {
return slf.servicename return slf.servicename
} }
func (slf *BaseService) SetServiceName(serviceName string) bool {
slf.servicename = serviceName
return true
}
func (slf *BaseService) GetStatus() int { func (slf *BaseService) GetStatus() int {
return slf.Status return slf.Status
} }