ts-dde

Dynamic Data Exchange (DDE) 动态数据交换模块

此模块基于node-dde, 将原有 edge 依赖更新至edge-js 12.3.1,并使用 typescript 重构。

安装

npm install ts-dde --save

例子

Client

异步监听 advise 获取 service-topic-item 三级命名结构数据。

• 单个主题：

import { DdeClient } from 'ts-dde';

const client = new DdeClient({
  services: {
    myapp: {
      mytopic1: ['myitem1', 'myitem2'],
    },
  },
});

client.on('advise', (data) => {
  console.log('Service: ' + data.service + ', Topic: ' + data.topic + ', Item: ' + data.item + ', Text: ' + data.text);
});

client.connect();

client.startAdvise();

• 多个主题：

import { DdeClient } from 'ts-dde';

const client = new DdeClient({
  services: {
    myapp: {
      mytopic1: ['myitem1', 'myitem2'],
      mytopic2: ['myitem1', 'まいあいてむ２'],
    },
  },
});

client.on('advise', (data) => {
  console.log('Service: ' + data.service + ', Topic: ' + data.topic + ', Item: ' + data.item + ', Text: ' + data.text);
});

client.connect();

client.startAdvise();

Server

异步推送 advise 数据至客户端:

import { DdeServer } from 'ts-dde';

const server = new DdeServer('myapp');

server.on('disconnect', function(service, topic) {
  console.log('OnDisconnect: ' + 'Service: ' + service + ', Topic: ' + topic);
});

server.on('advise', function(topic, item, format) {
  console.log('OnAdvise: ' + 'Topic: ' + topic + ', Item: ' + item + ', Format: ' + format);
});

let i = 0;
server.onAdvise = function() {
  return 'advise-' + i++;
};

setInterval(function() {
  server.advise('*', '*');
}, 1000);

server.register();

方法

DdeClient

| 方法名 | 说明 | 使用例 | | ---------------- | ------------------------------------------------- | ------------------------------------------------------ | | connect | 连接服务器 | client.connect() | | disconnect | 断开与服务器的连接 | client.disconnect() | | pause | 暂停服务 | client.pause() | | resume | 恢复服务 | client.resume() | | execute | 通过指定的 DDE 通道，向应用程序发送一条或一组命令 | client.execute(command, timeout) | | poke | 向应用程序发送数据 | client.poke(item, data, timeout) | | request | 向接收应用程序查询信息,并以字符串方式返回该信息 | client.request(item, format, timeout) | | startAdvise | 循环获取数据 | client.startAdvise(item, format, hot, timeout) | | stopAdvise | 停止接收数据 | client.stopAdvise(item, timeout) | | beginExecute | 开始发送命令 | client.beginExecute(command, oncomplete) | | beginPoke | 开始发送数据 | client.beginPoke(item, data, format, oncomplete) | | beginRequest | 开始请求数据 | client.beginRequest(item, format, oncomplete) | | beginStartAdvise | 开始监听数据 | client.beginStartAdvise(item, format, hot, oncomplete) | | beginStopAdvise | 开始停止监听 | client.beginStopAdvise(item, oncomplete) | | dispose | 释放资源 | client.dispose() | | service | 获取服务名 | client.service() | | topic | 获取主题 | client.topic() | | isConnected | 是否已连接 | client.isConnected() | | isPaused | 是否已暂停 | client.isPaused() |

DdeServer

| 方法名 | 说明 | 使用例 | | ------------ | ---------------- | -------------------------- | | register | 注册服务 | server.register() | | unregister | 注销服务 | server.unregister() | | advise | 建立数据传输接口 | server.advise(topic, item) | | disconnect | 断开连接 | server.disconnect() | | pause | 暂停服务 | server.pause() | | resume | 恢复服务 | server.resume() | | dispose | 释放资源 | server.dispose() | | service | 获取服务名 | server.service() | | isRegistered | 是否已注册 | server.isRegistered() |