mirror of
https://github.com/duanhf2012/origin.git
synced 2026-02-13 23:24:45 +08:00
Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
97c55ada71 | ||
|
|
776b234022 | ||
|
|
a4f425bd69 | ||
|
|
ee54862be2 | ||
|
|
13642d7402 | ||
|
|
18d620118e | ||
|
|
f02592d126 | ||
|
|
0f890887f7 | ||
|
|
c5c05b6ae9 | ||
|
|
68b891df51 |
@@ -87,6 +87,9 @@ service.json如下:
|
|||||||
---------------
|
---------------
|
||||||
```
|
```
|
||||||
{
|
{
|
||||||
|
"Global": {
|
||||||
|
"AreaId": 1
|
||||||
|
},
|
||||||
"Service":{
|
"Service":{
|
||||||
"HttpService":{
|
"HttpService":{
|
||||||
"ListenAddr":"0.0.0.0:9402",
|
"ListenAddr":"0.0.0.0:9402",
|
||||||
@@ -157,7 +160,7 @@ service.json如下:
|
|||||||
```
|
```
|
||||||
|
|
||||||
---------------
|
---------------
|
||||||
以上配置分为两个部分:Service与NodeService,NodeService中配置的对应结点中服务的配置,如果启动程序中根据nodeid查找该域的对应的服务,如果找不到时,从Service公共部分查找。
|
以上配置分为两个部分:Global,Service与NodeService。Global是全局配置,在任何服务中都可以通过cluster.GetCluster().GetGlobalCfg()获取,NodeService中配置的对应结点中服务的配置,如果启动程序中根据nodeid查找该域的对应的服务,如果找不到时,从Service公共部分查找。
|
||||||
|
|
||||||
**HttpService配置**
|
**HttpService配置**
|
||||||
* ListenAddr:Http监听地址
|
* ListenAddr:Http监听地址
|
||||||
|
|||||||
@@ -41,8 +41,9 @@ type NodeRpcInfo struct {
|
|||||||
var cluster Cluster
|
var cluster Cluster
|
||||||
|
|
||||||
type Cluster struct {
|
type Cluster struct {
|
||||||
localNodeInfo NodeInfo //本结点配置信息
|
localNodeInfo NodeInfo //本结点配置信息
|
||||||
masterDiscoveryNodeList []NodeInfo //配置发现Master结点
|
masterDiscoveryNodeList []NodeInfo //配置发现Master结点
|
||||||
|
globalCfg interface{} //全局配置
|
||||||
|
|
||||||
localServiceCfg map[string]interface{} //map[serviceName]配置数据*
|
localServiceCfg map[string]interface{} //map[serviceName]配置数据*
|
||||||
mapRpc map[int]NodeRpcInfo //nodeId
|
mapRpc map[int]NodeRpcInfo //nodeId
|
||||||
@@ -418,3 +419,7 @@ func HasService(nodeId int, serviceName string) bool {
|
|||||||
|
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (cls *Cluster) GetGlobalCfg() interface{} {
|
||||||
|
return cls.globalCfg
|
||||||
|
}
|
||||||
|
|||||||
@@ -10,12 +10,13 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
var json = jsoniter.ConfigCompatibleWithStandardLibrary
|
||||||
|
|
||||||
type NodeInfoList struct {
|
type NodeInfoList struct {
|
||||||
MasterDiscoveryNode []NodeInfo //用于服务发现Node
|
MasterDiscoveryNode []NodeInfo //用于服务发现Node
|
||||||
NodeList []NodeInfo
|
NodeList []NodeInfo
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cls *Cluster) ReadClusterConfig(filepath string) (*NodeInfoList,error) {
|
func (cls *Cluster) ReadClusterConfig(filepath string) (*NodeInfoList, error) {
|
||||||
c := &NodeInfoList{}
|
c := &NodeInfoList{}
|
||||||
d, err := ioutil.ReadFile(filepath)
|
d, err := ioutil.ReadFile(filepath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -26,119 +27,123 @@ func (cls *Cluster) ReadClusterConfig(filepath string) (*NodeInfoList,error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
return c,nil
|
return c, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cls *Cluster) readServiceConfig(filepath string) (map[string]interface{},map[int]map[string]interface{},error) {
|
func (cls *Cluster) readServiceConfig(filepath string) (interface{}, map[string]interface{}, map[int]map[string]interface{}, error) {
|
||||||
c := map[string]interface{}{}
|
c := map[string]interface{}{}
|
||||||
//读取配置
|
//读取配置
|
||||||
d, err := ioutil.ReadFile(filepath)
|
d, err := ioutil.ReadFile(filepath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil,nil, err
|
return nil, nil, nil, err
|
||||||
}
|
}
|
||||||
err = json.Unmarshal(d, &c)
|
err = json.Unmarshal(d, &c)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil,nil, err
|
return nil, nil, nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
GlobalCfg, ok := c["Global"]
|
||||||
serviceConfig := map[string]interface{}{}
|
serviceConfig := map[string]interface{}{}
|
||||||
serviceCfg,ok := c["Service"]
|
serviceCfg, ok := c["Service"]
|
||||||
if ok == true {
|
if ok == true {
|
||||||
serviceConfig = serviceCfg.(map[string]interface{})
|
serviceConfig = serviceCfg.(map[string]interface{})
|
||||||
}
|
}
|
||||||
|
|
||||||
mapNodeService := map[int]map[string]interface{}{}
|
mapNodeService := map[int]map[string]interface{}{}
|
||||||
nodeServiceCfg,ok := c["NodeService"]
|
nodeServiceCfg, ok := c["NodeService"]
|
||||||
if ok == true {
|
if ok == true {
|
||||||
nodeServiceList := nodeServiceCfg.([]interface{})
|
nodeServiceList := nodeServiceCfg.([]interface{})
|
||||||
for _,v := range nodeServiceList{
|
for _, v := range nodeServiceList {
|
||||||
serviceCfg :=v.(map[string]interface{})
|
serviceCfg := v.(map[string]interface{})
|
||||||
nodeId,ok := serviceCfg["NodeId"]
|
nodeId, ok := serviceCfg["NodeId"]
|
||||||
if ok == false {
|
if ok == false {
|
||||||
log.SFatal("NodeService list not find nodeId field")
|
log.SFatal("NodeService list not find nodeId field")
|
||||||
}
|
}
|
||||||
mapNodeService[int(nodeId.(float64))] = serviceCfg
|
mapNodeService[int(nodeId.(float64))] = serviceCfg
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return serviceConfig,mapNodeService,nil
|
return GlobalCfg, serviceConfig, mapNodeService, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cls *Cluster) readLocalClusterConfig(nodeId int) ([]NodeInfo,[]NodeInfo,error) {
|
func (cls *Cluster) readLocalClusterConfig(nodeId int) ([]NodeInfo, []NodeInfo, error) {
|
||||||
var nodeInfoList []NodeInfo
|
var nodeInfoList []NodeInfo
|
||||||
var masterDiscoverNodeList []NodeInfo
|
var masterDiscoverNodeList []NodeInfo
|
||||||
clusterCfgPath :=strings.TrimRight(configDir,"/") +"/cluster"
|
clusterCfgPath := strings.TrimRight(configDir, "/") + "/cluster"
|
||||||
fileInfoList,err := ioutil.ReadDir(clusterCfgPath)
|
fileInfoList, err := ioutil.ReadDir(clusterCfgPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil,nil,fmt.Errorf("Read dir %s is fail :%+v",clusterCfgPath,err)
|
return nil, nil, fmt.Errorf("Read dir %s is fail :%+v", clusterCfgPath, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
//读取任何文件,只读符合格式的配置,目录下的文件可以自定义分文件
|
//读取任何文件,只读符合格式的配置,目录下的文件可以自定义分文件
|
||||||
for _,f := range fileInfoList{
|
for _, f := range fileInfoList {
|
||||||
if f.IsDir() == false {
|
if f.IsDir() == false {
|
||||||
filePath := strings.TrimRight(strings.TrimRight(clusterCfgPath,"/"),"\\")+"/"+f.Name()
|
filePath := strings.TrimRight(strings.TrimRight(clusterCfgPath, "/"), "\\") + "/" + f.Name()
|
||||||
localNodeInfoList,err := cls.ReadClusterConfig(filePath)
|
localNodeInfoList, err := cls.ReadClusterConfig(filePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil,nil,fmt.Errorf("read file path %s is error:%+v" ,filePath,err)
|
return nil, nil, fmt.Errorf("read file path %s is error:%+v", filePath, err)
|
||||||
}
|
}
|
||||||
masterDiscoverNodeList = append(masterDiscoverNodeList,localNodeInfoList.MasterDiscoveryNode...)
|
masterDiscoverNodeList = append(masterDiscoverNodeList, localNodeInfoList.MasterDiscoveryNode...)
|
||||||
for _,nodeInfo := range localNodeInfoList.NodeList {
|
for _, nodeInfo := range localNodeInfoList.NodeList {
|
||||||
if nodeInfo.NodeId == nodeId || nodeId == 0 {
|
if nodeInfo.NodeId == nodeId || nodeId == 0 {
|
||||||
nodeInfoList = append(nodeInfoList,nodeInfo)
|
nodeInfoList = append(nodeInfoList, nodeInfo)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if nodeId != 0 && (len(nodeInfoList)!=1){
|
if nodeId != 0 && (len(nodeInfoList) != 1) {
|
||||||
return nil,nil,fmt.Errorf("%d configurations were found for the configuration with node ID %d!",len(nodeInfoList),nodeId)
|
return nil, nil, fmt.Errorf("%d configurations were found for the configuration with node ID %d!", len(nodeInfoList), nodeId)
|
||||||
}
|
}
|
||||||
|
|
||||||
for i,_ := range nodeInfoList{
|
for i, _ := range nodeInfoList {
|
||||||
for j,s := range nodeInfoList[i].ServiceList{
|
for j, s := range nodeInfoList[i].ServiceList {
|
||||||
//私有结点不加入到Public服务列表中
|
//私有结点不加入到Public服务列表中
|
||||||
if strings.HasPrefix(s,"_") == false && nodeInfoList[i].Private==false {
|
if strings.HasPrefix(s, "_") == false && nodeInfoList[i].Private == false {
|
||||||
nodeInfoList[i].PublicServiceList = append(nodeInfoList[i].PublicServiceList,strings.TrimLeft(s,"_"))
|
nodeInfoList[i].PublicServiceList = append(nodeInfoList[i].PublicServiceList, strings.TrimLeft(s, "_"))
|
||||||
}else{
|
} else {
|
||||||
nodeInfoList[i].ServiceList[j] = strings.TrimLeft(s,"_")
|
nodeInfoList[i].ServiceList[j] = strings.TrimLeft(s, "_")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
return masterDiscoverNodeList, nodeInfoList, nil
|
||||||
return masterDiscoverNodeList,nodeInfoList,nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cls *Cluster) readLocalService(localNodeId int) error {
|
func (cls *Cluster) readLocalService(localNodeId int) error {
|
||||||
clusterCfgPath :=strings.TrimRight(configDir,"/") +"/cluster"
|
clusterCfgPath := strings.TrimRight(configDir, "/") + "/cluster"
|
||||||
fileInfoList,err := ioutil.ReadDir(clusterCfgPath)
|
fileInfoList, err := ioutil.ReadDir(clusterCfgPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("Read dir %s is fail :%+v",clusterCfgPath,err)
|
return fmt.Errorf("Read dir %s is fail :%+v", clusterCfgPath, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
//读取任何文件,只读符合格式的配置,目录下的文件可以自定义分文件
|
//读取任何文件,只读符合格式的配置,目录下的文件可以自定义分文件
|
||||||
for _,f := range fileInfoList {
|
for _, f := range fileInfoList {
|
||||||
if f.IsDir() == false {
|
if f.IsDir() == false {
|
||||||
filePath := strings.TrimRight(strings.TrimRight(clusterCfgPath, "/"), "\\") + "/" + f.Name()
|
filePath := strings.TrimRight(strings.TrimRight(clusterCfgPath, "/"), "\\") + "/" + f.Name()
|
||||||
serviceConfig,mapNodeService,err := cls.readServiceConfig(filePath)
|
currGlobalCfg, serviceConfig, mapNodeService, err := cls.readServiceConfig(filePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
for _,s := range cls.localNodeInfo.ServiceList{
|
if currGlobalCfg != nil {
|
||||||
for{
|
cls.globalCfg = currGlobalCfg
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, s := range cls.localNodeInfo.ServiceList {
|
||||||
|
for {
|
||||||
//取公共服务配置
|
//取公共服务配置
|
||||||
pubCfg,ok := serviceConfig[s]
|
pubCfg, ok := serviceConfig[s]
|
||||||
if ok == true {
|
if ok == true {
|
||||||
cls.localServiceCfg[s] = pubCfg
|
cls.localServiceCfg[s] = pubCfg
|
||||||
}
|
}
|
||||||
|
|
||||||
//如果结点也配置了该服务,则覆盖之
|
//如果结点也配置了该服务,则覆盖之
|
||||||
nodeService,ok := mapNodeService[localNodeId]
|
nodeService, ok := mapNodeService[localNodeId]
|
||||||
if ok == false {
|
if ok == false {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
sCfg,ok := nodeService[s]
|
sCfg, ok := nodeService[s]
|
||||||
if ok == false{
|
if ok == false {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -152,22 +157,21 @@ func (cls *Cluster) readLocalService(localNodeId int) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cls *Cluster) parseLocalCfg(){
|
func (cls *Cluster) parseLocalCfg() {
|
||||||
cls.mapIdNode[cls.localNodeInfo.NodeId] = cls.localNodeInfo
|
cls.mapIdNode[cls.localNodeInfo.NodeId] = cls.localNodeInfo
|
||||||
|
|
||||||
for _,sName := range cls.localNodeInfo.ServiceList{
|
for _, sName := range cls.localNodeInfo.ServiceList {
|
||||||
if _,ok:=cls.mapServiceNode[sName];ok==false{
|
if _, ok := cls.mapServiceNode[sName]; ok == false {
|
||||||
cls.mapServiceNode[sName] = make(map[int]struct{})
|
cls.mapServiceNode[sName] = make(map[int]struct{})
|
||||||
}
|
}
|
||||||
|
|
||||||
cls.mapServiceNode[sName][cls.localNodeInfo.NodeId]= struct{}{}
|
cls.mapServiceNode[sName][cls.localNodeInfo.NodeId] = struct{}{}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (cls *Cluster) checkDiscoveryNodeList(discoverMasterNode []NodeInfo) bool {
|
||||||
func (cls *Cluster) checkDiscoveryNodeList(discoverMasterNode []NodeInfo) bool{
|
for i := 0; i < len(discoverMasterNode)-1; i++ {
|
||||||
for i:=0;i<len(discoverMasterNode)-1;i++{
|
for j := i + 1; j < len(discoverMasterNode); j++ {
|
||||||
for j:=i+1;j<len(discoverMasterNode);j++{
|
|
||||||
if discoverMasterNode[i].NodeId == discoverMasterNode[j].NodeId ||
|
if discoverMasterNode[i].NodeId == discoverMasterNode[j].NodeId ||
|
||||||
discoverMasterNode[i].ListenAddr == discoverMasterNode[j].ListenAddr {
|
discoverMasterNode[i].ListenAddr == discoverMasterNode[j].ListenAddr {
|
||||||
return false
|
return false
|
||||||
@@ -178,19 +182,19 @@ func (cls *Cluster) checkDiscoveryNodeList(discoverMasterNode []NodeInfo) bool{
|
|||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cls *Cluster) InitCfg(localNodeId int) error{
|
func (cls *Cluster) InitCfg(localNodeId int) error {
|
||||||
cls.localServiceCfg = map[string]interface{}{}
|
cls.localServiceCfg = map[string]interface{}{}
|
||||||
cls.mapRpc = map[int] NodeRpcInfo{}
|
cls.mapRpc = map[int]NodeRpcInfo{}
|
||||||
cls.mapIdNode = map[int]NodeInfo{}
|
cls.mapIdNode = map[int]NodeInfo{}
|
||||||
cls.mapServiceNode = map[string]map[int]struct{}{}
|
cls.mapServiceNode = map[string]map[int]struct{}{}
|
||||||
|
|
||||||
//加载本地结点的NodeList配置
|
//加载本地结点的NodeList配置
|
||||||
discoveryNode,nodeInfoList,err := cls.readLocalClusterConfig(localNodeId)
|
discoveryNode, nodeInfoList, err := cls.readLocalClusterConfig(localNodeId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
cls.localNodeInfo = nodeInfoList[0]
|
cls.localNodeInfo = nodeInfoList[0]
|
||||||
if cls.checkDiscoveryNodeList(discoveryNode) ==false {
|
if cls.checkDiscoveryNodeList(discoveryNode) == false {
|
||||||
return fmt.Errorf("DiscoveryNode config is error!")
|
return fmt.Errorf("DiscoveryNode config is error!")
|
||||||
}
|
}
|
||||||
cls.masterDiscoveryNodeList = discoveryNode
|
cls.masterDiscoveryNodeList = discoveryNode
|
||||||
@@ -209,39 +213,39 @@ func (cls *Cluster) InitCfg(localNodeId int) error{
|
|||||||
func (cls *Cluster) IsConfigService(serviceName string) bool {
|
func (cls *Cluster) IsConfigService(serviceName string) bool {
|
||||||
cls.locker.RLock()
|
cls.locker.RLock()
|
||||||
defer cls.locker.RUnlock()
|
defer cls.locker.RUnlock()
|
||||||
mapNode,ok := cls.mapServiceNode[serviceName]
|
mapNode, ok := cls.mapServiceNode[serviceName]
|
||||||
if ok == false {
|
if ok == false {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
_,ok = mapNode[cls.localNodeInfo.NodeId]
|
_, ok = mapNode[cls.localNodeInfo.NodeId]
|
||||||
return ok
|
return ok
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cls *Cluster) GetNodeIdByService(serviceName string,rpcClientList []*rpc.Client,bAll bool) (error,int) {
|
func (cls *Cluster) GetNodeIdByService(serviceName string, rpcClientList []*rpc.Client, bAll bool) (error, int) {
|
||||||
cls.locker.RLock()
|
cls.locker.RLock()
|
||||||
defer cls.locker.RUnlock()
|
defer cls.locker.RUnlock()
|
||||||
mapNodeId,ok := cls.mapServiceNode[serviceName]
|
mapNodeId, ok := cls.mapServiceNode[serviceName]
|
||||||
count := 0
|
count := 0
|
||||||
if ok == true {
|
if ok == true {
|
||||||
for nodeId,_ := range mapNodeId {
|
for nodeId, _ := range mapNodeId {
|
||||||
pClient := GetCluster().getRpcClient(nodeId)
|
pClient := GetCluster().getRpcClient(nodeId)
|
||||||
if pClient==nil || (bAll == false && pClient.IsConnected()==false) {
|
if pClient == nil || (bAll == false && pClient.IsConnected() == false) {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
rpcClientList[count] = pClient
|
rpcClientList[count] = pClient
|
||||||
count++
|
count++
|
||||||
if count>=cap(rpcClientList) {
|
if count >= cap(rpcClientList) {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil,count
|
return nil, count
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cls *Cluster) getServiceCfg(serviceName string) interface{}{
|
func (cls *Cluster) getServiceCfg(serviceName string) interface{} {
|
||||||
v,ok := cls.localServiceCfg[serviceName]
|
v, ok := cls.localServiceCfg[serviceName]
|
||||||
if ok == false {
|
if ok == false {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
@@ -249,8 +253,8 @@ func (cls *Cluster) getServiceCfg(serviceName string) interface{}{
|
|||||||
return v
|
return v
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cls *Cluster) GetServiceCfg(serviceName string) interface{}{
|
func (cls *Cluster) GetServiceCfg(serviceName string) interface{} {
|
||||||
serviceCfg,ok := cls.localServiceCfg[serviceName]
|
serviceCfg, ok := cls.localServiceCfg[serviceName]
|
||||||
if ok == false {
|
if ok == false {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"github.com/duanhf2012/origin/network"
|
"github.com/duanhf2012/origin/network"
|
||||||
"reflect"
|
"reflect"
|
||||||
|
"github.com/duanhf2012/origin/log"
|
||||||
)
|
)
|
||||||
|
|
||||||
type MessageJsonInfo struct {
|
type MessageJsonInfo struct {
|
||||||
@@ -44,18 +45,18 @@ func (jsonProcessor *JsonProcessor) SetByteOrder(littleEndian bool) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// must goroutine safe
|
// must goroutine safe
|
||||||
func (jsonProcessor *JsonProcessor ) MsgRoute(msg interface{},userdata interface{}) error{
|
func (jsonProcessor *JsonProcessor ) MsgRoute(clientId uint64,msg interface{}) error{
|
||||||
pPackInfo := msg.(*JsonPackInfo)
|
pPackInfo := msg.(*JsonPackInfo)
|
||||||
v,ok := jsonProcessor.mapMsg[pPackInfo.typ]
|
v,ok := jsonProcessor.mapMsg[pPackInfo.typ]
|
||||||
if ok == false {
|
if ok == false {
|
||||||
return fmt.Errorf("cannot find msgtype %d is register!",pPackInfo.typ)
|
return fmt.Errorf("cannot find msgtype %d is register!",pPackInfo.typ)
|
||||||
}
|
}
|
||||||
|
|
||||||
v.msgHandler(userdata.(uint64),pPackInfo.msg)
|
v.msgHandler(clientId,pPackInfo.msg)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (jsonProcessor *JsonProcessor) Unmarshal(data []byte) (interface{}, error) {
|
func (jsonProcessor *JsonProcessor) Unmarshal(clientId uint64,data []byte) (interface{}, error) {
|
||||||
typeStruct := struct {Type int `json:"typ"`}{}
|
typeStruct := struct {Type int `json:"typ"`}{}
|
||||||
defer jsonProcessor.ReleaseByteSlice(data)
|
defer jsonProcessor.ReleaseByteSlice(data)
|
||||||
err := json.Unmarshal(data, &typeStruct)
|
err := json.Unmarshal(data, &typeStruct)
|
||||||
@@ -78,7 +79,7 @@ func (jsonProcessor *JsonProcessor) Unmarshal(data []byte) (interface{}, error)
|
|||||||
return &JsonPackInfo{typ:msgType,msg:msgData},nil
|
return &JsonPackInfo{typ:msgType,msg:msgData},nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (jsonProcessor *JsonProcessor) Marshal(msg interface{}) ([]byte, error) {
|
func (jsonProcessor *JsonProcessor) Marshal(clientId uint64,msg interface{}) ([]byte, error) {
|
||||||
rawMsg,err := json.Marshal(msg)
|
rawMsg,err := json.Marshal(msg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil,err
|
return nil,err
|
||||||
@@ -103,16 +104,26 @@ func (jsonProcessor *JsonProcessor) MakeRawMsg(msgType uint16,msg []byte) *JsonP
|
|||||||
return &JsonPackInfo{typ:msgType,rawMsg:msg}
|
return &JsonPackInfo{typ:msgType,rawMsg:msg}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (jsonProcessor *JsonProcessor) UnknownMsgRoute(msg interface{}, userData interface{}){
|
func (jsonProcessor *JsonProcessor) UnknownMsgRoute(clientId uint64,msg interface{}){
|
||||||
jsonProcessor.unknownMessageHandler(userData.(uint64),msg.([]byte))
|
if jsonProcessor.unknownMessageHandler==nil {
|
||||||
|
log.SDebug("Unknown message received from ",clientId)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
jsonProcessor.unknownMessageHandler(clientId,msg.([]byte))
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (jsonProcessor *JsonProcessor) ConnectedRoute(userData interface{}){
|
func (jsonProcessor *JsonProcessor) ConnectedRoute(clientId uint64){
|
||||||
jsonProcessor.connectHandler(userData.(uint64))
|
if jsonProcessor.connectHandler != nil {
|
||||||
|
jsonProcessor.connectHandler(clientId)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (jsonProcessor *JsonProcessor) DisConnectedRoute(userData interface{}){
|
func (jsonProcessor *JsonProcessor) DisConnectedRoute(clientId uint64){
|
||||||
jsonProcessor.disconnectHandler(userData.(uint64))
|
if jsonProcessor.disconnectHandler != nil {
|
||||||
|
jsonProcessor.disconnectHandler(clientId)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (jsonProcessor *JsonProcessor) RegisterUnknownMsg(unknownMessageHandler UnknownMessageJsonHandler){
|
func (jsonProcessor *JsonProcessor) RegisterUnknownMsg(unknownMessageHandler UnknownMessageJsonHandler){
|
||||||
|
|||||||
@@ -21,6 +21,7 @@ type WSClient struct {
|
|||||||
cons WebsocketConnSet
|
cons WebsocketConnSet
|
||||||
wg sync.WaitGroup
|
wg sync.WaitGroup
|
||||||
closeFlag bool
|
closeFlag bool
|
||||||
|
messageType int
|
||||||
}
|
}
|
||||||
|
|
||||||
func (client *WSClient) Start() {
|
func (client *WSClient) Start() {
|
||||||
@@ -62,7 +63,7 @@ func (client *WSClient) init() {
|
|||||||
if client.cons != nil {
|
if client.cons != nil {
|
||||||
log.SFatal("client is running")
|
log.SFatal("client is running")
|
||||||
}
|
}
|
||||||
|
client.messageType = websocket.TextMessage
|
||||||
client.cons = make(WebsocketConnSet)
|
client.cons = make(WebsocketConnSet)
|
||||||
client.closeFlag = false
|
client.closeFlag = false
|
||||||
client.dialer = websocket.Dialer{
|
client.dialer = websocket.Dialer{
|
||||||
@@ -83,6 +84,9 @@ func (client *WSClient) dial() *websocket.Conn {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (client *WSClient) SetMessageType(messageType int){
|
||||||
|
client.messageType = messageType
|
||||||
|
}
|
||||||
func (client *WSClient) connect() {
|
func (client *WSClient) connect() {
|
||||||
defer client.wg.Done()
|
defer client.wg.Done()
|
||||||
|
|
||||||
@@ -102,7 +106,7 @@ reconnect:
|
|||||||
client.cons[conn] = struct{}{}
|
client.cons[conn] = struct{}{}
|
||||||
client.Unlock()
|
client.Unlock()
|
||||||
|
|
||||||
wsConn := newWSConn(conn, client.PendingWriteNum, client.MaxMsgLen)
|
wsConn := newWSConn(conn, client.PendingWriteNum, client.MaxMsgLen,client.messageType)
|
||||||
agent := client.NewAgent(wsConn)
|
agent := client.NewAgent(wsConn)
|
||||||
agent.Run()
|
agent.Run()
|
||||||
|
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ type WSConn struct {
|
|||||||
closeFlag bool
|
closeFlag bool
|
||||||
}
|
}
|
||||||
|
|
||||||
func newWSConn(conn *websocket.Conn, pendingWriteNum int, maxMsgLen uint32) *WSConn {
|
func newWSConn(conn *websocket.Conn, pendingWriteNum int, maxMsgLen uint32,messageType int) *WSConn {
|
||||||
wsConn := new(WSConn)
|
wsConn := new(WSConn)
|
||||||
wsConn.conn = conn
|
wsConn.conn = conn
|
||||||
wsConn.writeChan = make(chan []byte, pendingWriteNum)
|
wsConn.writeChan = make(chan []byte, pendingWriteNum)
|
||||||
@@ -30,7 +30,7 @@ func newWSConn(conn *websocket.Conn, pendingWriteNum int, maxMsgLen uint32) *WSC
|
|||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
err := conn.WriteMessage(websocket.BinaryMessage, b)
|
err := conn.WriteMessage(messageType, b)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -21,6 +21,7 @@ type WSServer struct {
|
|||||||
NewAgent func(*WSConn) Agent
|
NewAgent func(*WSConn) Agent
|
||||||
ln net.Listener
|
ln net.Listener
|
||||||
handler *WSHandler
|
handler *WSHandler
|
||||||
|
messageType int
|
||||||
}
|
}
|
||||||
|
|
||||||
type WSHandler struct {
|
type WSHandler struct {
|
||||||
@@ -32,6 +33,11 @@ type WSHandler struct {
|
|||||||
conns WebsocketConnSet
|
conns WebsocketConnSet
|
||||||
mutexConns sync.Mutex
|
mutexConns sync.Mutex
|
||||||
wg sync.WaitGroup
|
wg sync.WaitGroup
|
||||||
|
messageType int
|
||||||
|
}
|
||||||
|
|
||||||
|
func (handler *WSHandler) SetMessageType(messageType int){
|
||||||
|
handler.messageType = messageType
|
||||||
}
|
}
|
||||||
|
|
||||||
func (handler *WSHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
func (handler *WSHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
||||||
@@ -45,6 +51,7 @@ func (handler *WSHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
conn.SetReadLimit(int64(handler.maxMsgLen))
|
conn.SetReadLimit(int64(handler.maxMsgLen))
|
||||||
|
handler.messageType = websocket.TextMessage
|
||||||
|
|
||||||
handler.wg.Add(1)
|
handler.wg.Add(1)
|
||||||
defer handler.wg.Done()
|
defer handler.wg.Done()
|
||||||
@@ -64,7 +71,7 @@ func (handler *WSHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|||||||
handler.conns[conn] = struct{}{}
|
handler.conns[conn] = struct{}{}
|
||||||
handler.mutexConns.Unlock()
|
handler.mutexConns.Unlock()
|
||||||
|
|
||||||
wsConn := newWSConn(conn, handler.pendingWriteNum, handler.maxMsgLen)
|
wsConn := newWSConn(conn, handler.pendingWriteNum, handler.maxMsgLen,handler.messageType)
|
||||||
agent := handler.newAgent(wsConn)
|
agent := handler.newAgent(wsConn)
|
||||||
agent.Run()
|
agent.Run()
|
||||||
|
|
||||||
@@ -76,6 +83,13 @@ func (handler *WSHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|||||||
agent.OnClose()
|
agent.OnClose()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (server *WSServer) SetMessageType(messageType int){
|
||||||
|
server.messageType = messageType
|
||||||
|
if server.handler!= nil {
|
||||||
|
server.handler.SetMessageType(messageType)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func (server *WSServer) Start() {
|
func (server *WSServer) Start() {
|
||||||
ln, err := net.Listen("tcp", server.Addr)
|
ln, err := net.Listen("tcp", server.Addr)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
15
node/node.go
15
node/node.go
@@ -9,6 +9,7 @@ import (
|
|||||||
"github.com/duanhf2012/origin/profiler"
|
"github.com/duanhf2012/origin/profiler"
|
||||||
"github.com/duanhf2012/origin/service"
|
"github.com/duanhf2012/origin/service"
|
||||||
"github.com/duanhf2012/origin/util/timer"
|
"github.com/duanhf2012/origin/util/timer"
|
||||||
|
"github.com/duanhf2012/origin/util/buildtime"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
slog "log"
|
slog "log"
|
||||||
"net/http"
|
"net/http"
|
||||||
@@ -38,6 +39,7 @@ func init() {
|
|||||||
signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM,syscall.Signal(10))
|
signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM,syscall.Signal(10))
|
||||||
|
|
||||||
console.RegisterCommandBool("help",false,"<-help> This help.",usage)
|
console.RegisterCommandBool("help",false,"<-help> This help.",usage)
|
||||||
|
console.RegisterCommandString("name","","<-name nodeName> Node's name.",setName)
|
||||||
console.RegisterCommandString("start","","<-start nodeid=nodeid> Run originserver.",startNode)
|
console.RegisterCommandString("start","","<-start nodeid=nodeid> Run originserver.",startNode)
|
||||||
console.RegisterCommandString("stop","","<-stop nodeid=nodeid> Stop originserver process.",stopNode)
|
console.RegisterCommandString("stop","","<-stop nodeid=nodeid> Stop originserver process.",stopNode)
|
||||||
console.RegisterCommandString("config","","<-config path> Configuration file path.",setConfigPath)
|
console.RegisterCommandString("config","","<-config path> Configuration file path.",setConfigPath)
|
||||||
@@ -53,13 +55,20 @@ func usage(val interface{}) error{
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
fmt.Fprintf(os.Stderr, `orgin version: orgin/2.14.20201029
|
if len(buildtime.GetBuildDateTime())>0 {
|
||||||
Usage: originserver [-help] [-start node=1] [-stop] [-config path] [-pprof 0.0.0.0:6060]...
|
fmt.Fprintf(os.Stderr, "Welcome to Origin(build info: %s)\nUsage: originserver [-help] [-start node=1] [-stop] [-config path] [-pprof 0.0.0.0:6060]...\n",buildtime.GetBuildDateTime())
|
||||||
`)
|
}else{
|
||||||
|
fmt.Fprintf(os.Stderr, "Welcome to Origin\nUsage: originserver [-help] [-start node=1] [-stop] [-config path] [-pprof 0.0.0.0:6060]...\n")
|
||||||
|
}
|
||||||
|
|
||||||
console.PrintDefaults()
|
console.PrintDefaults()
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func setName(val interface{}) error {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
func setPprof(val interface{}) error {
|
func setPprof(val interface{}) error {
|
||||||
listenAddr := val.(string)
|
listenAddr := val.(string)
|
||||||
if listenAddr==""{
|
if listenAddr==""{
|
||||||
|
|||||||
@@ -175,10 +175,12 @@ func (slf *HttpSession) Write(msg []byte) {
|
|||||||
|
|
||||||
func (slf *HttpSession) WriteJsonDone(statusCode int,msgJson interface{}) error {
|
func (slf *HttpSession) WriteJsonDone(statusCode int,msgJson interface{}) error {
|
||||||
msg, err := json.Marshal(msgJson)
|
msg, err := json.Marshal(msgJson)
|
||||||
if err == nil {
|
if err != nil {
|
||||||
slf.Write(msg)
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
slf.statusCode = statusCode
|
||||||
|
slf.Write(msg)
|
||||||
slf.Done()
|
slf.Done()
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import (
|
|||||||
"github.com/duanhf2012/origin/network/processor"
|
"github.com/duanhf2012/origin/network/processor"
|
||||||
"github.com/duanhf2012/origin/node"
|
"github.com/duanhf2012/origin/node"
|
||||||
"github.com/duanhf2012/origin/service"
|
"github.com/duanhf2012/origin/service"
|
||||||
|
"sync/atomic"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
"runtime"
|
"runtime"
|
||||||
@@ -42,12 +43,12 @@ const Default_ReadDeadline = 180 //30s
|
|||||||
const Default_WriteDeadline = 180 //30s
|
const Default_WriteDeadline = 180 //30s
|
||||||
|
|
||||||
const (
|
const (
|
||||||
MaxNodeId = 1<<10 - 1 //Uint10
|
MaxNodeId = 1<<14 - 1 //最大值 16383
|
||||||
MaxSeed = 1<<22 - 1 //MaxUint24
|
MaxSeed = 1<<19 - 1 //最大值 524287
|
||||||
|
MaxTime = 1<<31 - 1 //最大值 2147483647
|
||||||
)
|
)
|
||||||
|
|
||||||
var seed uint32
|
var seed uint32
|
||||||
var seedLocker sync.Mutex
|
|
||||||
|
|
||||||
type TcpPack struct {
|
type TcpPack struct {
|
||||||
Type TcpPackType //0表示连接 1表示断开 2表示数据
|
Type TcpPackType //0表示连接 1表示断开 2表示数据
|
||||||
@@ -66,16 +67,14 @@ func (tcpService *TcpService) genId() uint64 {
|
|||||||
panic("nodeId exceeds the maximum!")
|
panic("nodeId exceeds the maximum!")
|
||||||
}
|
}
|
||||||
|
|
||||||
seedLocker.Lock()
|
newSeed := atomic.AddUint32(&seed,1) % MaxSeed
|
||||||
seed = (seed+1)%MaxSeed
|
nowTime := uint64(time.Now().Unix())%MaxTime
|
||||||
seedLocker.Unlock()
|
return (uint64(node.GetNodeId())<<50)|(nowTime<<19)|uint64(newSeed)
|
||||||
|
|
||||||
nowTime := uint64(time.Now().Second())
|
|
||||||
return (uint64(node.GetNodeId())<<54)|(nowTime<<22)|uint64(seed)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
func GetNodeId(agentId uint64) int {
|
func GetNodeId(agentId uint64) int {
|
||||||
return int(agentId>>54)
|
return int(agentId>>50)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (tcpService *TcpService) OnInit() error{
|
func (tcpService *TcpService) OnInit() error{
|
||||||
|
|||||||
@@ -7,19 +7,27 @@ import (
|
|||||||
"github.com/duanhf2012/origin/network"
|
"github.com/duanhf2012/origin/network"
|
||||||
"github.com/duanhf2012/origin/network/processor"
|
"github.com/duanhf2012/origin/network/processor"
|
||||||
"github.com/duanhf2012/origin/service"
|
"github.com/duanhf2012/origin/service"
|
||||||
|
"github.com/duanhf2012/origin/node"
|
||||||
"sync"
|
"sync"
|
||||||
|
"sync/atomic"
|
||||||
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
type WSService struct {
|
type WSService struct {
|
||||||
service.Service
|
service.Service
|
||||||
wsServer network.WSServer
|
wsServer network.WSServer
|
||||||
|
|
||||||
mapClientLocker sync.RWMutex
|
mapClientLocker sync.RWMutex
|
||||||
mapClient map[uint64] *WSClient
|
mapClient map[uint64] *WSClient
|
||||||
initClientId uint64
|
|
||||||
process processor.IProcessor
|
process processor.IProcessor
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var seed uint32
|
||||||
|
|
||||||
type WSPackType int8
|
type WSPackType int8
|
||||||
const(
|
const(
|
||||||
WPT_Connected WSPackType = 0
|
WPT_Connected WSPackType = 0
|
||||||
@@ -32,6 +40,12 @@ const Default_WS_MaxConnNum = 3000
|
|||||||
const Default_WS_PendingWriteNum = 10000
|
const Default_WS_PendingWriteNum = 10000
|
||||||
const Default_WS_MaxMsgLen = 65535
|
const Default_WS_MaxMsgLen = 65535
|
||||||
|
|
||||||
|
const (
|
||||||
|
MaxNodeId = 1<<14 - 1 //最大值 16383
|
||||||
|
MaxSeed = 1<<19 - 1 //最大值 524287
|
||||||
|
MaxTime = 1<<31 - 1 //最大值 2147483647
|
||||||
|
)
|
||||||
|
|
||||||
type WSClient struct {
|
type WSClient struct {
|
||||||
id uint64
|
id uint64
|
||||||
wsConn *network.WSConn
|
wsConn *network.WSConn
|
||||||
@@ -46,6 +60,7 @@ type WSPack struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (ws *WSService) OnInit() error{
|
func (ws *WSService) OnInit() error{
|
||||||
|
|
||||||
iConfig := ws.GetServiceCfg()
|
iConfig := ws.GetServiceCfg()
|
||||||
if iConfig == nil {
|
if iConfig == nil {
|
||||||
return fmt.Errorf("%s service config is error!", ws.GetName())
|
return fmt.Errorf("%s service config is error!", ws.GetName())
|
||||||
@@ -80,6 +95,10 @@ func (ws *WSService) OnInit() error{
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (ws *WSService) SetMessageType(messageType int){
|
||||||
|
ws.wsServer.SetMessageType(messageType)
|
||||||
|
}
|
||||||
|
|
||||||
func (ws *WSService) WSEventHandler(ev event.IEvent) {
|
func (ws *WSService) WSEventHandler(ev event.IEvent) {
|
||||||
pack := ev.(*event.Event).Data.(*WSPack)
|
pack := ev.(*event.Event).Data.(*WSPack)
|
||||||
switch pack.Type {
|
switch pack.Type {
|
||||||
@@ -88,9 +107,9 @@ func (ws *WSService) WSEventHandler(ev event.IEvent) {
|
|||||||
case WPT_DisConnected:
|
case WPT_DisConnected:
|
||||||
pack.MsgProcessor.DisConnectedRoute(pack.ClientId)
|
pack.MsgProcessor.DisConnectedRoute(pack.ClientId)
|
||||||
case WPT_UnknownPack:
|
case WPT_UnknownPack:
|
||||||
pack.MsgProcessor.UnknownMsgRoute(pack.Data,pack.ClientId)
|
pack.MsgProcessor.UnknownMsgRoute(pack.ClientId,pack.Data)
|
||||||
case WPT_Pack:
|
case WPT_Pack:
|
||||||
pack.MsgProcessor.MsgRoute(pack.Data, pack.ClientId)
|
pack.MsgProcessor.MsgRoute(pack.ClientId,pack.Data)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -99,20 +118,30 @@ func (ws *WSService) SetProcessor(process processor.IProcessor,handler event.IEv
|
|||||||
ws.RegEventReceiverFunc(event.Sys_Event_WebSocket,handler, ws.WSEventHandler)
|
ws.RegEventReceiverFunc(event.Sys_Event_WebSocket,handler, ws.WSEventHandler)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (ws *WSService) genId() uint64 {
|
||||||
|
if node.GetNodeId()>MaxNodeId{
|
||||||
|
panic("nodeId exceeds the maximum!")
|
||||||
|
}
|
||||||
|
|
||||||
|
newSeed := atomic.AddUint32(&seed,1) % MaxSeed
|
||||||
|
nowTime := uint64(time.Now().Unix())%MaxTime
|
||||||
|
return (uint64(node.GetNodeId())<<50)|(nowTime<<19)|uint64(newSeed)
|
||||||
|
}
|
||||||
|
|
||||||
func (ws *WSService) NewWSClient(conn *network.WSConn) network.Agent {
|
func (ws *WSService) NewWSClient(conn *network.WSConn) network.Agent {
|
||||||
ws.mapClientLocker.Lock()
|
ws.mapClientLocker.Lock()
|
||||||
defer ws.mapClientLocker.Unlock()
|
defer ws.mapClientLocker.Unlock()
|
||||||
|
|
||||||
for {
|
for {
|
||||||
ws.initClientId+=1
|
clientId := ws.genId()
|
||||||
_,ok := ws.mapClient[ws.initClientId]
|
_,ok := ws.mapClient[clientId]
|
||||||
if ok == true {
|
if ok == true {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
pClient := &WSClient{wsConn:conn, id: ws.initClientId}
|
pClient := &WSClient{wsConn:conn, id: clientId}
|
||||||
pClient.wsService = ws
|
pClient.wsService = ws
|
||||||
ws.mapClient[ws.initClientId] = pClient
|
ws.mapClient[clientId] = pClient
|
||||||
return pClient
|
return pClient
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -131,7 +160,7 @@ func (slf *WSClient) Run() {
|
|||||||
log.Debug("read client id %d is error:%+v",slf.id,err)
|
log.Debug("read client id %d is error:%+v",slf.id,err)
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
data,err:=slf.wsService.process.Unmarshal(bytes)
|
data,err:=slf.wsService.process.Unmarshal(slf.id,bytes)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
slf.wsService.NotifyEvent(&event.Event{Type:event.Sys_Event_WebSocket,Data:&WSPack{ClientId:slf.id,Type:WPT_UnknownPack,Data:bytes,MsgProcessor:slf.wsService.process}})
|
slf.wsService.NotifyEvent(&event.Event{Type:event.Sys_Event_WebSocket,Data:&WSPack{ClientId:slf.id,Type:WPT_UnknownPack,Data:bytes,MsgProcessor:slf.wsService.process}})
|
||||||
continue
|
continue
|
||||||
@@ -156,7 +185,7 @@ func (ws *WSService) SendMsg(clientid uint64,msg interface{}) error{
|
|||||||
}
|
}
|
||||||
|
|
||||||
ws.mapClientLocker.Unlock()
|
ws.mapClientLocker.Unlock()
|
||||||
bytes,err := ws.process.Marshal(msg)
|
bytes,err := ws.process.Marshal(clientid,msg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
15
util/buildtime/build.go
Normal file
15
util/buildtime/build.go
Normal file
@@ -0,0 +1,15 @@
|
|||||||
|
package buildtime
|
||||||
|
|
||||||
|
/*
|
||||||
|
//查询buildtime包中的位置,在github.com/duanhf2012/origin/util/buildtime.BuildTime中
|
||||||
|
go tool nm ./originserver.exe |grep buildtime
|
||||||
|
|
||||||
|
//编译传入编译时间信息
|
||||||
|
go build -ldflags "-X 'github.com/duanhf2012/origin/util/buildtime.BuildTime=20200101'"
|
||||||
|
*/
|
||||||
|
var BuildTime string
|
||||||
|
|
||||||
|
|
||||||
|
func GetBuildDateTime() string {
|
||||||
|
return BuildTime
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user