增加协议头

This commit is contained in:
boyce
2019-03-11 10:32:06 +08:00
parent 6beddd664d
commit 451d756dc9
2 changed files with 5 additions and 2 deletions

View File

@@ -96,6 +96,7 @@ func (s *COriginNode) Start() {
//停止运行程序
s.Stop()
service.GetLogger().Printf(sysmodule.LEVER_INFO, "Node stop run...")
}
func (s *COriginNode) Stop() {
@@ -113,6 +114,7 @@ func NewOrginNode() *COriginNode {
//安装系统服务
syslogservice := &sysservice.LogService{}
syslogservice.InitLog("syslog", sysmodule.LEVER_INFO)
service.InstanceServiceMgr().Setup(syslogservice)
//初始化集群对象

View File

@@ -18,7 +18,8 @@ import (
)
type HttpRequest struct {
Body string
Header http.Header
Body string
}
type HttpRespone struct {
@@ -111,7 +112,7 @@ func (slf *HttpServerService) httpHandler(w http.ResponseWriter, r *http.Request
}
strCallPath := "_" + vstr[1] + ".HTTP_" + vstr[2]
request := HttpRequest{string(msg)}
request := HttpRequest{r.Header, string(msg)}
var resp HttpRespone
cluster.InstanceClusterMgr().Call(strCallPath, &request, &resp)