axon-rpc-call
v1.0.3
Published
service rpc call
Downloads
7
Readme
service point need env
XC_REG_CENTER_REDIS_URL redis://:@127.0.0.1:6379/1
roomHttpService 192.168.0.244 8100 8100
[serviceName ,serviceIP, listenPort, servicePort]
client point need env
XC_REG_CENTER_REDIS_URL redis://:@127.0.0.1:6379/1
const XCRPC = require("./index")
const axonDebug = require('debug')('axon_debug_run')
let rep = new XCRPC.Responder({name: "myS1"})
rep.on("/user/query", (req, reply) => {
axonDebug("req", "/user/query")
req.query.uid = req.query.uid + 1
setTimeout(() => {
reply(null, req)
axonDebug("__________")
}, 1000 * 1)
})
let i = 0;
setInterval(async () => {
let req = new XCRPC.Requester({name: "myS1"})
req.send({
type: "/user/query",
query: {
uid: i++
}
}, (err, result) => {
axonDebug(`请求结果`, err, result)
})
let result = await req.send({
type: "/user/query",
query: {
uid: i++
}
})
axonDebug(`promise 请求结果`, result)
}, 5000)