Needling Perl Mongers

    qtp-client

    1.0.27 • Public • Published

    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;

    Keywords

    Install

    npm i qtp-client

    DownloadsWeekly Downloads

    0

    Version

    1.0.27

    License

    MIT

    Unpacked Size

    75.5 kB

    Total Files

    14

    Last publish

    Collaborators

    • easier-chan