qtp-client

Description

• 接口列表

connect(port, host)

onConnect

onClose

send(msgtype, body, service=0)

sendWithOption(msgtype, options, body, service)

subscribe(topic, keys)

addSlot(..slots)

subscribeWithOption(topic, options, body, service, version, opposite)

setCompress(value: boolean);

附录

• Slot 结构

 {
   service : number
   msgtype : number
   callback: Function
   context : optional
 }

• Option结构

  {
    id: number;
    value: Buffer;
  }

Example

const qtpmodule = require('../lib/qtp.service');

let qtp = new qtpmodule.QtpService();
qtp.connect(6001, '172.24.13.23');
qtp.onConnect = () => {
  console.info(`onConnect`);
  qtp.send(101, JSON.stringify({ data: { user_id: 19999, password: "2cb6703cc7cb7d564008ddbfaad68eE2" } }), 10);
};

qtp.onTopic(5002, (key, body)=> {
  console.info(msg.toString());
}, this);

qtp.onClose = () => {
  console.info("onClose");
};

qtp.addSlot({
  service: 10,
  msgtype: 102,
  callback: (msg) => {
    // qtp.sendToCMS("getProduct", JSON.stringify({ data: { body: { userid: 100101 } } }));
    qtp.subscribe(5002, [1114113], false, 50);
  }
});

qtp.addSlotOfCMS("getProduct", (arg) => {
  // setTimeout(() => {
  //   qtp.dispose();
  //   qtp.connect(6001, '172.24.13.23');
  // }, 10000);
}, this);

qtp.addSlot({
  service: 40,
  msgtype: 1,
  callback: (msg) => {
    console.info(msg.toString());
  }
});

// subscribeWithOption
let options = [];
let userOpt = new QtpMessageOption();
userOpt.id = 111;
userOpt.value = Buffer.from("1213");
options.push(userOpt);
qtp.subscribeWithOption([topic], options, null, 20, 0);
qtp.onTopic(5002, (key, body)=> {
  console.info(body.toString());
}, this);

ChangLog

• version 1.0.7 update

• version 1.0.6 update

• version 1.0.5 add CMS-special interface;

• version 1.0.4

  fix subscribe issue;