| | |
| | | } |
| | | |
| | | func NewMicroNode(ctx context.Context,q chan os.Signal, serverId string, reg *RegisterInfo, fnLog func(v ...interface{})) (*MicroNode, error){ |
| | | conf := NewConfig(KEY_REGISTER,512,5,1000,100,1000, fnLog) |
| | | conf := NewConfig(KEY_REGISTER,512,5,1000,1000,1000, fnLog) |
| | | handle, err := Register(ctx, q, conf, reg) |
| | | if err != nil { |
| | | return nil, err |
| | |
| | | Proc: *ms.procInfo, |
| | | } |
| | | |
| | | t := time.NewTicker(4 * time.Second) |
| | | t := time.NewTicker(1 * time.Second) |
| | | defer t.Stop() |
| | | |
| | | for { |
| | |
| | | //收到其它进程的请求消息 |
| | | go ms.serve(msgR, keyR) |
| | | } |
| | | |
| | | time.Sleep(50 * time.Millisecond) |
| | | } |
| | | } |
| | | } |
| | |
| | | Body: rb, |
| | | } |
| | | ms.printLog("2:", time.Since(t)) |
| | | t = time.Now() |
| | | mi,err := ms.handle.Request(serverId, msgR, milliSecs) |
| | | if mi == nil || err != nil { |
| | | return nil, err |
| | | } |
| | | ms.printLog("3:", time.Since(t)) |
| | | t = time.Now() |
| | | ri := new(Reply) |
| | | err = json.Unmarshal(mi.Body, ri) |
| | | if err != nil { |
| | | ms.printLog("unmarshal mi.Body err:", err) |
| | | ri = &Reply{ |
| | | Success: false, |
| | | Msg: "服务请求失败", |
| | | Data: "服务请求失败", |
| | | } |
| | | } |
| | | ms.printLog("4:", time.Since(t)) |
| | | return ri, nil |
| | | return ms.handle.Request(serverId, msgR, milliSecs) |
| | | } |
| | | |
| | | func (ms *MicroNode) RequestTopic(serverId string, request Request, milliSecs int) (*Reply,error) { |
| | |
| | | Body: rb, |
| | | } |
| | | |
| | | mi, err := ms.handle.Request(serverId, msgR, milliSecs) |
| | | if err != nil { |
| | | return nil, err |
| | | } |
| | | var ri *Reply |
| | | err = json.Unmarshal(mi.Body, ri) |
| | | if err != nil { |
| | | ri = &Reply{ |
| | | Success: false, |
| | | Msg: "服务请求失败", |
| | | Data: "服务请求失败", |
| | | } |
| | | } |
| | | return ri, nil |
| | | return ms.handle.Request(serverId, msgR, milliSecs) |
| | | } |
| | | |
| | | func (ms *MicroNode) RequestOnly(rData []byte, nodes []bhomebus.NetNode) ([]byte, error) { |
| | | return ms.handle.RequestOnly(rData, nodes) |
| | | } |
| | | |
| | | //获取本机中某一个主题的 key (结果只有一个元素) |
| | |
| | | ms.printLog("requestCenter reply:", cr, "err:", err) |
| | | return nil, err |
| | | } |
| | | if cr.Status == REPLY_SUCCESS && cr.Body != nil { |
| | | var list []RegisteredClient |
| | | err = json.Unmarshal(cr.Body, &list) |
| | | if cr.Success { |
| | | rd,err := json.Marshal(cr.Data) |
| | | if err == nil { |
| | | return list, nil |
| | | var list []RegisteredClient |
| | | err = json.Unmarshal(rd, &list) |
| | | if err == nil { |
| | | return list, nil |
| | | } else { |
| | | ms.printLog("unmarshal to RegisteredClient list err:", err) |
| | | } |
| | | } else { |
| | | ms.printLog("unmarshal to RegisteredClient list err:", err) |
| | | return nil, fmt.Errorf("marshal reply.Data err:%s", err.Error()) |
| | | } |
| | | } else { |
| | | ms.printLog("request center failed,status:", cr.Status, "desc:", cr.Desc) |
| | | ms.printLog("request center failed,status:", cr.Success, "msg:", cr.Msg, " data:", cr.Data) |
| | | } |
| | | return nil, fmt.Errorf("GetRegisteredClient list failed") |
| | | } |
| | |
| | | } |
| | | |
| | | var reqBody Request |
| | | var ri *Reply |
| | | err := json.Unmarshal(msgR.Body, &reqBody) |
| | | if err != nil { |
| | | ms.printLog("serve unmarshal msgR.Body err:", err) |
| | | return |
| | | } |
| | | |
| | | ms.printLog("reqBody:", reqBody, "to key: ", p) |
| | | var ri *Reply |
| | | if f,ok := ms.handlers[reqBody.Path];ok { |
| | | ri = f(&reqBody) |
| | | ms.printLog("call funcMap f,reply:", *ri) |
| | | ri = &Reply { |
| | | Msg: err.Error(), |
| | | } |
| | | } else { |
| | | ms.printLog("ms.funcMap not eixst path") |
| | | ri = &Reply{ |
| | | Success: false, |
| | | Msg: "请求的接口不存在,请检查url", |
| | | Data: "请求的接口不存在,请检查url", |
| | | ms.printLog("srcProc:", msgR.SrcProc,"reqBody Path:", reqBody.Path, " contentType:", reqBody.ContentType, " formMap:",reqBody.FormMap, " postFormMap:", reqBody.PostFormMap, "to key: ", p) |
| | | |
| | | if f,ok := ms.handlers[reqBody.Path];ok { |
| | | reqBody.SrcProc = msgR.SrcProc |
| | | ri = f(&reqBody) |
| | | ms.printLog("call funcMap f,reply:", *ri) |
| | | } else { |
| | | ms.printLog("ms.funcMap not eixst path: ", reqBody.Path) |
| | | ri = &Reply{ |
| | | Success: false, |
| | | Msg: "请求的接口不存在,请检查url", |
| | | Data: "请求的接口不存在,请检查url", |
| | | } |
| | | } |
| | | } |
| | | rd,err := json.Marshal(*ri) |
| | | if err != nil { |
| | | ms.printLog("marshal *ri err:", err) |
| | | } |
| | | rMsg := MsgInfo{ |
| | | Body: rd, |
| | | } |
| | | retErr := ms.handle.Reply(p, rMsg) |
| | | |
| | | retErr := ms.handle.Reply(p, ri) |
| | | if retErr != nil { |
| | | ms.printLog("retErr:", retErr) |
| | | } |
| | |
| | | |
| | | //发布到本机 |
| | | func (ms *MicroNode) Publish(topic string,msg []byte) error { |
| | | nodes := append([]bhomebus.NetNode{}, bhomebus.NetNode{}) |
| | | nodes := append([]bhomebus.NetNode{}, bhomebus.NetNode{ |
| | | Key: 8, |
| | | }) |
| | | return ms.PublishNet(nodes, topic, msg) |
| | | } |
| | | |