2020/04/05

Typescriptでsocketio

背景

仕事でTypescriptを使用する機会が出てきたので、使い方を調査した

記事の目的

TypescriptでSocketIO通信を実装する

Typescript

ここでは、Typescriptについて記載する。

Typescriptとは

Typescript

Typescriptはマイクロソフトによって開発され、メンテナンスされているフリーでオープンソースのプログラミング言語である。TypeScriptはJavaScriptに対して、省略も可能な静的型付けとクラスベースオブジェクト指向を加えた厳密なスーパーセットとなっている。C#のリードアーキテクトであり、DelphiとTurbo Pascalの開発者でもあるアンダース・ヘルスバーグがTypeScriptの開発に関わっている。TypeScriptはクライアントサイド、あるいはサーバサイド (Node.js) で実行されるJavaScriptアプリケーションの開発に利用できる。

利点

  • 型チェックが強力で柔軟であるため、型の間違いによるバグを抑制できる
  • VSCodeなどで入力補完が利用でき、JSDocでコメントを作成しておくとドキュメントが不要

テンプレートのパッケージ構成

Typescriptでnodeモジュールを作成するための最小構成
  1. $ tree
  2. .
  3. ├── dist                   #トランスパイル済みJavascriptファイルの格納先
  4. ├── node_modules           # npm installでインストールした依存関係のあるnodeモジュールの格納先
  5. ├── package-lock.json      # npm installでインストールしたnodeモジュール情報（自動で生成される）
  6. ├── package.json           # このモジュールの情報
  7. ├── param                  # パラメータファイルの格納先（オプショナル）
  8. │   └── log-config.json   # log4js（ロガーモジュール）の設定ファイル
  9. ├── src                    # ソースファイルの格納場所
  10. │   └── app.ts            # mainのTypescriptファイル
  11. ├── test                   # テストコードの格納場所
  12. │   └── app.test.ts       # app.tsのテストコード
  13. ├── tsconfig.json          # Typescriptの設定ファイル
  14. └── tslint.json            # ts-lint(Typescriptのlintツール)の設定ファイル

package.json

テンプレートのpackage.jsonファイルを記載する。
  1. {
  2.   "name": "sample_app",(mainのファイル名)
  3.   "version": "1.0.0",(バージョン)
  4.   "description": "This is sample code",(モジュールの説明)
  5.   "main": "dist/app.js",(mainファイル)
  6.   "directories": {(ディレクトリ構成)
  7.     "src": "src",
  8.     "dist": "dist",
  9.     "param": "param",
  10.     "test": "test"
  11.   },
  12.   "scripts": {(スクリプトの設定)
  13.     "start": "npm run build && npm run watch", (ビルドして実行)
  14.     "build": "npm install && npm run build-ts && npm run tslint",(ビルド)
  15.     "serve": "nodemon dist/src/index.js",(サービスとして実行)
  16.     "watch": "npm install concurrently && concurrently -k -p \"[{name}]\" -n \"Typescript,Node\" -c \"yellow.bold,cyan.bold,green.bold\" \"npm run watch-ts\" \"npm run serve\"",(ビルドしつつウォッチ)
  17.     "test": "npm run build && jest --forceExit --detectOpenHandles",(テストコード実行)
  18.     "test-ci": "jest --coverage --forceExit --runInBand",(テストコード実行し、コードカバレッジを表示)
  19.     "build-ts": "tsc",(Typescriptのビルド)
  20.     "watch-ts": "tsc -w",(Typescriptのウォッチ)
  21.     "tslint": "tslint -c tslint.json -p tsconfig.json"(ts-lintを実行)
  22.   },
  23.   "author": "EmptySet",(作成者)
  24.   "license": "MIT",(ライセンス)
  25.   "devDependencies": {(依存モジュール、バージョン。npm install -Dでインストールされる)
  26.     "@babel/core": "*",
  27.     "@babel/preset-env": "*",
  28.     "@babel/preset-react": "*",
  29.     "@babel/preset-typescript": "*",
  30.     "@types/jest": "*",
  31.     "@types/uuid": "^7.0.2",
  32.     "async-mutex": "^0.1.4",
  33.     "babel-jest": "*",
  34.     "jest": "^25.2.6",
  35.     "log4js": "^6.1.2",
  36.     "socket.io": "^2.3.0",
  37.     "socket.io-client": "^2.3.0",
  38.     "ts-jest": "^25.3.0",
  39.     "tslint": "6.1.0",
  40.     "typescript": "3.8.3"
  41.   },
  42.   "dependencies": {(依存モジュール、バージョン。npm installでインストールされる)
  43.     "@types/express": "^4.17.4",
  44.     "@types/jest": "^25.1.5",
  45.     "@types/node": "^13.9.5",
  46.     "@types/socket.io": "^2.1.4",
  47.     "@types/socket.io-client": "^1.4.32",
  48.     "express": "^4.17.1",
  49.     "jest-cli": "^25.2.6",
  50.     "log4js": "6.1.2",
  51.     "tsc": "^1.20150623.0",
  52.     "uuid": "^7.0.2"
  53.   },
  54.   "jest": {(jest(テストツール)の設定)
  55.     "transform": {
  56.       "^.+\\.ts$": "ts-jest"
  57.     },
  58.     "testMatch": [
  59.       "**/test/**/*.test.ts"
  60.     ],
  61.     "moduleFileExtensions": [
  62.       "ts",
  63.       "js"
  64.     ],
  65.     "globals": {
  66.       "ts-jest": {
  67.         "tsConfig": "tsconfig.json"
  68.       }
  69.     }
  70.   }
  71. }

tsconfig.json

tsconfig.jsonファイルを記載する。
  1. {
  2.     "compilerOptions": {
  3.         "module": "commonjs",(モジュールコードのバージョン)
  4.         "target": "es2017",(ECMAScriptのバージョン)
  5.         "noImplicitAny": true,(Any型を許容しない)
  6.         "moduleResolution": "node",(構造の単位)
  7.         "sourceMap": true,(tsファイルとjsファイル間のマップファイルを作成)
  8.         "outDir": "./dist",(ビルド後のファイルの格納先)
  9.         "baseUrl": ".",(ソースファイルのベースのパス)
  10.         "rootDir":"./src",(ルートディレクトリ)
  11.         "paths": {(パスの定義)
  12.             "*": [
  13.                 "node_modules/*",
  14.                 "src/*",
  15.                 "test/*"
  16.             ]
  17.         }
  18.     },
  19.     "include": [(includeするファイル)
  20.         "src/**/*"
  21.     ]
  22. }

tslint.json

tslint.jsonファイルを記載する。
  1. {
  2.     "rules": {
  3.         "class-name": true,
  4.         "comment-format": [
  5.             true,
  6.             "check-space"
  7.         ],
  8.         "indent": [
  9.             true,
  10.             "spaces"
  11.         ],
  12.         "one-line": [
  13.             true,
  14.             "check-open-brace",
  15.             "check-whitespace"
  16.         ],
  17.         "no-var-keyword": true,
  18.         "quotemark": [
  19.             true,
  20.             "double",
  21.             "avoid-escape"
  22.         ],
  23.         "semicolon": [
  24.             true,
  25.             "always",
  26.             "ignore-bound-class-methods"
  27.         ],
  28.         "whitespace":[
  29.             true,
  30.             "check-branch",
  31.             "check-decl",
  32.             "check-operator",
  33.             "check-module",
  34.             "check-separator",
  35.             "check-type"
  36.         ],
  37.         "typedef-whitespace": [
  38.             true,
  39.             {
  40.                 "call-signature": "nospace",
  41.                 "index-signature": "nospace",
  42.                 "parameter": "nospace",
  43.                 "property-declaration": "nospace",
  44.                 "variable-declaration": "nospace"
  45.             },
  46.             {
  47.                 "call-signature": "onespace",
  48.                 "index-signature": "onespace",
  49.                 "parameter": "onespace",
  50.                 "property-declaration": "onespace",
  51.                 "variable-declaration": "onespace"
  52.             }
  53.         ],
  54.         "no-internal-module": true,
  55.         "no-trailing-whitespace": true,
  56.         "no-null-keyword": true,
  57.         "prefer-const": true,
  58.         "jsdoc-format": true
  59.     }
  60. }

/src/app.ts

app.tsを記載する。
  1. /**
  2.  * SocketIO sample
  3.  * @summary This is socketIO sample code (get rtt)
  4.  * @author EmptySet
  5.  * @version 1.0
  6.  * @todo Something
  7.  */
  9. // ロガーモジュール
  10. import * as Logger from "log4js";
  11. Logger.configure("./param/log-config.json");
  12. // SocketIOのモジュール
  13. import * as socketio_client from "socket.io-client";
  14. import * as socketio from "socket.io";
  15. // UUID作成モジュール
  16. import * as UUID from "uuid";
  17. // Expressモジュール(サーバアプリ)
  18. import * as express from "express";
  19. // HTTPサーバモジュール
  20. import * as http from "http";
  22. // データの型を設定
  23. /**
  24.  * Header in data
  25.  */
  26. interface Header {
  27.     "type": string;
  28.     "uuid": string;
  29.     "version": number;
  30.     "time_stamp": string;
  31. }
  32. /**
  33.  * Body in data
  34.  */
  35. interface Body {
  36.     "time_stamp": Array<number>;
  37. }
  39. /**
  40.  * Data format
  41.  */
  42. export interface Data {
  43.     "header": Header;
  44.     "body": Body;
  45. }
  47. /**
  48.  * SocketIOクライアントクラス
  49.  */
  50. class Client {
  51.     // ロガー
  52.     protected logger: Logger.Logger;
  53.     // SocketIOクライアント
  54.     protected io: SocketIOClient.Socket;
  55.     // SocketIOのパラメータ
  56.     protected url: string;
  57.     protected port: number;
  58.     protected token: string;
  59.     protected namespace: string;
  60.     // 接続状態フラグ(true: 接続, false: 未接続)
  61.     protected is_connection: boolean;
  63.     // コンストラクタ
  64.     /**
  65.      * Set parameters of socketIO
  66.      * @param url Server URL (e.g. azure.com)
  67.      * @param port Port number (e.g. 80)
  68.      * @param token Token in query
  69.      * @param namespace Socket namespace
  70.      */
  71.     constructor(url: string, port: number, token: string, namespace: string) {
  72.         // ロガー名を設定
  73.         this.set_logger("client");
  74.         // クライアントのパラメータを設定
  75.         this.url   = url;
  76.         this.port  = port;
  77.         this.token = token;
  78.         this.namespace = namespace;
  79.         // 接続状態を初期化
  80.         this.is_connection = false;
  81.     }
  83.     /**
  84.      * Check connection status
  85.      * @param class_name Please set class name
  86.      */
  87.     set_logger(class_name: string) {
  88.         this.logger = Logger.getLogger(class_name);
  89.     }
  91.     /**
  92.      * Check connection status
  93.      * @return Connect(true) or not(false)
  94.      */
  95.     protected check_connection(): boolean {
  96.         return this.is_connection;
  97.     }
  99.     /**
  100.      * Set connection status
  101.      * @param flg Connect(true) or not(false)
  102.      */
  103.     protected set_connection(flg: boolean) {
  104.         this.is_connection = flg;
  105.     }
  107.     /**
  108.      * Connect to server
  109.      */
  110.     protected connect() {
  111.         this.logger.info("Try connect to server");
  112.         // 接続重複時に、前の接続を切断
  113.         if (this.check_connection()) {
  114.             this.logger.warn("Connection is duplicated. Disconnect from old connection.");
  115.             this.disconnect();
  116.         }
  117.         // サーバーに接続
  118.         const uri: string = `http://${this.url}:${this.port}/${this.namespace}`;
  119.         try {
  120.             this.io = socketio_client.connect(uri, {
  121.                 transports: ["websocket"],
  122.                 forceNew: true,
  123.                 reconnection: true,
  124.                 query: {
  125.                     token: this.token
  126.                 }
  127.             });
  128.         } catch (e) {
  129.             this.logger.error(`Cannot connect to server ${e}`);
  130.         }
  131.     }
  133.     /**
  134.      * Disconnect from server
  135.      */
  136.     protected disconnect() {
  137.         this.logger.info("Disconnect from server");
  138.         // サーバーから切断
  139.         try {
  140.             this.io.disconnect();
  141.         } catch (e) {
  142.             this.logger.error(`Cannot disconnect from server. ${e}`);
  143.         } finally {
  144.              this.set_connection(false);
  145.         }
  146.     }
  148.     /**
  149.      * Run client module.
  150.      * Connect to server and set events
  151.      */
  152.     async run () {
  153.         this.connect();
  155.         this.io.on("connect", (socket: socketio.Socket) => {
  156.             this.set_connection(true);
  157.             this.logger.info(`Connected to server. id: ${this.io.id}`);
  158.             // 接続したソケットに対して、コールバックイベントを設定
  159.             this.set_event(socket);
  160.         });
  161.         // 切断イベントを設定
  162.         this.io.on("disconnect", (socket: socketio.Socket) => {
  163.             this.set_connection(false);
  164.             this.logger.info(`Disconnected from server. id: ${this.io.id}`);
  165.         });
  166.     }
  167.     /**
  168.      * Set callback events
  169.      * @param socket socket instance
  170.      */
  171.     async set_event(socket: socketio.Socket) {}
  172. }
  173. /**
  174.  * SocketIO server class
  175.  */
  176. export class Server {
  177.     // ロガー名を設定
  178.     protected logger: Logger.Logger;
  179.     // SocketIOサーバー関連
  180.     protected server: http.Server;
  181.     protected io: SocketIO.Server;
  182.     protected nsp_1: SocketIO.Namespace;
  183.     protected nsp_2: SocketIO.Namespace;
  184.     // SocketIOサーバーのパラメータ
  185.     protected url: string;
  186.     protected port: number;
  187.     protected token: string;
  188.     protected namespace: Array<string>;
  189.     // 接続数
  190.     protected number_of_connection: number;
  192.     // コンストラクタ
  193.     /**
  194.      * Set parameters of socketIO
  195.      * @param url Server URL (e.g. azure.com)
  196.      * @param port Port number (e.g. 80)
  197.      * @param token Token in query
  198.      * @param namespace Socket namespace
  199.      */
  200.     constructor(url: string, port: number, token: string, namespace: ArrayArray<string>) {
  201.         // ロガーを設定
  202.         this.set_logger("server");
  203.         // パラメータを設定
  204.         this.url   = url;
  205.         this.port  = port;
  206.         this.token = token;
  207.         this.namespace = namespace;
  208.         // 接続数を設定
  209.         this.number_of_connection = 0;
  210.         // サーバーを設定
  211.         const app: express.Express = express();
  212.         this.server = http.createServer(app);
  213.         this.io = socketio(this.server, {
  214.             pingInterval: 1000,
  215.             pingTimeout: 5000
  216.         });
  217.     }
  219.     /**
  220.      * Check connection status
  221.      * @param class_name Please set class name
  222.      */
  223.     protected set_logger(class_name: string) {
  224.         this.logger = Logger.getLogger(class_name);
  225.     }
  227.     /**
  228.      * Check connection status
  229.      * @return Connect(true) or not(false)
  230.      */
  231.     protected check_connection(): number {
  232.         return this.number_of_connection;
  233.     }
  235.     /**
  236.      * Add number of connection
  237.      */
  238.     protected add_connection() {
  239.         this.number_of_connection ++;
  240.         this.logger.debug(`Number of connection is ${this.number_of_connection}`);
  241.     }
  243.     /**
  244.      * Add number of connection
  245.      */
  246.     protected remove_connection() {
  247.         if (this.number_of_connection == 0) {
  248.             this.logger.error("Number of connection is invalid");
  249.             return;
  250.         }
  251.         this.number_of_connection --;
  252.         this.logger.debug(`Number of connection is ${this.number_of_connection}`);
  253.     }
  255.     protected listen() {
  256.         this.server.listen(this.port, this.url);
  257.     }
  259.     /**
  260.      * Disconnect from server
  261.      */
  262.     protected disconnect(socket: socketio.Socket) {
  263.         this.logger.info("Disconnect from server");
  264.         // 切断処理
  265.         try {
  266.             socket.disconnect();
  267.             this.logger.info(`Disconnected from server. (ID: ${socket.id})`);
  268.         } catch (e) {
  269.             this.logger.error(`Cannot disconnect from server. ${e}`);
  270.         }
  271.     }
  273.     /**
  274.      * Run server module.
  275.      * Listen and set events
  276.      */
  277.     async run () {
  278.         this.listen();
  279.         // 接続イベント
  280.         this.io.on("connect", (socket: socketio.Socket) => {
  281.             this.logger.info(`Connected to client. id: ${socket.id}`);
  282.             this.add_connection();
  283.         });
  284.         // 切断イベント
  285.         this.io.on("disconnect", (socket: socketio.Socket) => {
  286.             this.logger.info(`disconnected from client. id: ${socket.id}`);
  287.             this.remove_connection();
  288.         });
  289.         // 独自のイベントを設定
  290.         this.set_event();
  291.     }
  292.     /**
  293.      * Set callback events
  294.      * @param socket socket instance
  295.      */
  296.     async set_event() {
  297.   // Namespace: this.namespace[0]のイベント設定
  298.         this.io.of(this.namespace[0]).on("connect", (socket: socketio.Socket) => {
  299.             this.logger.info(`Connected to client. id: ${socket.id}`);
  300.             // this.namespace[0]のその他イベント設定
  301.             socket.on("ping_", (msg: Data) => {
  302.                 this.logger.info(`Get ping. msg: ${JSON.stringify(msg)}`);
  303.                 const data: Data = msg;
  304.                 // 時刻取得
  305.                 const d = new Date();
  306.                 data.header.time_stamp = d.toISOString();
  307.                 data.body.time_stamp.push(d.getTime() / 1000);
  308.                 this.io.of(this.namespace[1]).json.emit("ping_", data);
  309.             });
  310.         });
  311.   // Namespace: this.namespace[1]のイベント設定
  312.         this.io.of(this.namespace[1]).on("connect", (socket: socketio.Socket) => {
  313.             this.logger.info(`Connected to client. id: ${socket.id}`);
  314.             // this.namespace[1]のその他イベント設定
  315.             socket.on("pong_", (msg: Data) => {
  316.                 this.logger.info(`Get pong. msg: ${JSON.stringify(msg)}`);
  317.                 const data: Data = msg;
  318.                 // 時刻取得
  319.                 const d = new Date();
  320.                 data.header.time_stamp = d.toISOString();
  321.                 data.body.time_stamp.push(d.getTime() / 1000);
  322.                 this.io.of(this.namespace[0]).json.emit("pong_", msg);
  323.             });
  324.         });
  325.     }
  326. }
  327. // Ping送信クラス(Clientクラスを継承)
  328. /**
  329.  * Ping class
  330.  */
  331. export class Ping extends Client {
  332.     private socket: socketio.Socket;
  333.     /**
  334.      * Emit ping
  335.      */
  336.     ping() {
  337.         this.logger.info("Ping");
  338.         // 接続状態をチェック
  339.         if (!this.check_connection()) {
  340.             this.logger.warn("Has not connect to server.");
  341.             return;
  342.         }
  343.         // 時刻を取得
  344.         const d = new Date();
  345.         // 送信するデータを定義
  346.         const data: Data = {
  347.             header: {
  348.                 type: "PingPong",
  349.                 time_stamp: d.toISOString(),
  350.                 uuid: UUID.v4(),
  351.                 version: 0
  352.             },
  353.             body: {
  354.                 time_stamp: [
  355.                     d.getTime() / 1000
  356.                 ]
  357.             }
  358.         };
  359.         // データを送信
  360.         try {
  361.             this.io.compress(true).emit("ping_", data);
  362.             this.logger.info("Emit ping data");
  363.             this.logger.debug(`Ping data: ${JSON.stringify(data)}, ${this.io.nsp}`);
  364.         } catch (e) {
  365.             this.logger.error(`Cannot emit pong. ${e}`);
  366.         }
  367.     }
  368.     // pongデータを受信し、RTTを算出
  369.     /**
  370.      * Get pong data and calculate RTT
  371.      * @param msg Pong message
  372.      */
  373.     protected get_rtt(msg: Data): number {
  374.         const data: Data = msg;
  375.         // 時刻を算出
  376.         const d = new Date();
  377.         data.header.time_stamp = d.toISOString();
  378.         data.body.time_stamp.push(d.getTime() / 1000);
  379.         // RTTを算出
  380.         const rtt: number = data.body.time_stamp[data.body.time_stamp.length - 1] - data.body.time_stamp[0];
  381.         this.logger.info(`RTT: ${rtt} [s]`);
  382.         return rtt;
  383.     }
  384.     /**
  385.      * Set callback events
  386.      * @param socket socket instance
  387.      */
  388.     async set_event (socket: socketio.Socket) {
  389.         // ロガー名を設定
  390.         this.socket = socket;
  391.         this.io.on("pong_", (msg: Data) => {
  392.             this.get_rtt(msg);
  393.         });
  394.     }
  395. }
  396. // Pong返信クラス(Clientクラスを継承)
  397. /**
  398.  * Pong class
  399.  */
  400. export class Pong extends Client {
  401.     /**
  402.      * Get ping message and emit pong message
  403.      * @param msg Ping message
  404.      */
  405.     protected pong(msg: Data, socket: socketio.Socket) {
  406.         this.logger.info("Pong");
  407.         const data: Data = msg;
  408.         // 時刻を取得
  409.         const d = new Date();
  410.         data.header.time_stamp = d.toISOString();
  411.         data.body.time_stamp.push(d.getTime() / 1000);
  412.         // Pongデータを送信
  413.         try {
  414.             this.io.compress(true).emit("pong_", data);
  415.             this.logger.info("Emit pong data");
  416.             this.logger.debug(`Pong data: ${data}`);
  417.         } catch (e) {
  418.             this.logger.error(`Cannot emit pong. ${e}`);
  419.         }
  420.     }
  421.     /**
  422.      * Set callback events
  423.      * @param socket socket instance
  424.      */
  425.     async set_event (socket: socketio.Socket) {
  426.         // ロガー名を設定
  427.         this.io.on("ping_", (msg: Data) => {
  428.             this.pong(msg, socket);
  429.         });
  430.     }
  431. }
  433. // Sleep関数
  434. /**
  435.  * Sleep function
  436.  * @param milliseconds Sleep time [ms]
  437.  */
  438. function sleep(milliseconds: number) {
  439.     return new Promise<void>(resolve => {
  440.       setTimeout(() => resolve(), milliseconds);
  441.     });
  442.   }
  444. // main関数(async: 非同期)
  445. async function main() {
  446.     const logger: Logger.Logger = Logger.getLogger("system");
  447.     const server = new Server("localhost", 10000, "secret", ["ping", "pong"]);
  448.     server.run();
  449.     // await: 同期待ち
  450.     await sleep(1000);
  451.     const ping = new Ping("localhost", 10000, "secret", "ping");
  452.     ping.set_logger("ping");
  453.     ping.run();
  454.     await sleep(1000);
  455.     const pong = new Pong("localhost", 10000, "secret", "pong");
  456.     pong.set_logger("pong");
  457.     pong.run();
  459.     await sleep(1000);
  460.     ping.ping();
  461. }
  463. exports.main = main;
  465. if (require.main == module) {
  466.     main();
  467. }

/test/app.test.ts

テストコードapp.test.tsを記載する。
  1. /**
  2.  * SocketIO sample test
  3.  * @summary This is socketIO sample test code (get rtt)
  4.  * @author EmptySet
  5.  * @version 1.0
  6.  * @todo Something
  7.  */
  9. // app.tsをインポート
  10. import * as rtt from "../src/app";
  11. // ロガーのインポート
  12. import * as Logger from "log4js";
  13. Logger.configure("./param/log-config.json");
  15. const logger = Logger.getLogger("test");
  17. describe("Ping class module test", () => {
  18.     const ping = new rtt.Ping("localhost", 10000, "secret", "ping");
  19.     it("Set parameters", () => {
  20.         expect(ping["url"]).toBe("localhost");
  21.         expect(ping["port"]).toBe(10000);
  22.         expect(ping["token"]).toBe("secret");
  23.         expect(ping["namespace"]).toBe("ping");
  24.     });
  25.     it("Check connection status function", () => {
  26.         expect(ping["check_connection"]()).toBe(false);
  27.         ping["set_connection"](true);
  28.         expect(ping["check_connection"]()).toBe(true);
  29.         ping["set_connection"](false);
  30.         expect(ping["check_connection"]()).toBe(false);
  31.     });
  32.     it("Check rtt calculation function", () => {
  33.         const d = new Date();
  34.         const data = {
  35.             header: {
  36.                 type: "PingPong",
  37.                 time_stamp:　"2020-04-01T00:00:00.000Z",
  38.                 uuid: "test",
  39.                 version: 0
  40.             },
  41.             body: {
  42.                 time_stamp: [
  43.                     d.getTime() / 1000,
  44.                     1500000000,
  45.                     1500000001
  46.                 ]
  47.             }
  48.         };
  49.         expect(ping["get_rtt"](data)).toBeLessThanOrEqual(0.01);
  50.     });
  51. });

実行時

  1. $npm run start
  2. ...
  3. 10:39:17 PM - Starting compilation in watch mode...
  4. [Typescript] 
  5. [Node] [nodemon] 2.0.2
  6. [Node] [nodemon] to restart at any time, enter `rs`
  7. [Node] [nodemon] watching dir(s): *.*
  8. [Node] [nodemon] watching extensions: js,mjs,json
  9. [Node] [nodemon] starting `node dist/src/index.js dist/src/app.js`
  10. [Node] [2020-04-05T22:39:19.023] [INFO] ping - Try connect to server
  11. [Node] [2020-04-05T22:39:19.066] [INFO] server - Connected to client. id: 9tfP7UDHqlCblBzRAAAA
  12. [Node] [2020-04-05T22:39:19.067] [DEBUG] server - Number of connection is 1
  13. [Node] [2020-04-05T22:39:19.076] [INFO] server - Connected to client. id: /ping#9tfP7UDHqlCblBzRAAAA
  14. [Node] [2020-04-05T22:39:19.077] [INFO] ping - Connected to server. id: /ping#9tfP7UDHqlCblBzRAAAA
  15. [Node] [2020-04-05T22:39:20.041] [INFO] pong - Try connect to server
  16. [Node] [2020-04-05T22:39:20.044] [INFO] server - Connected to client. id: wTjYvamapXXZV1yDAAAB
  17. [Node] [2020-04-05T22:39:20.045] [DEBUG] server - Number of connection is 2
  18. [Node] [2020-04-05T22:39:20.046] [INFO] server - Connected to client. id: /pong#wTjYvamapXXZV1yDAAAB
  19. [Node] [2020-04-05T22:39:20.047] [INFO] pong - Connected to server. id: /pong#wTjYvamapXXZV1yDAAAB
  20. [Node] [2020-04-05T22:39:21.044] [INFO] ping - Ping
  21. [Node] [2020-04-05T22:39:21.046] [INFO] ping - Emit ping data
  22. [Node] [2020-04-05T22:39:21.046] [DEBUG] ping - Ping data: {"header":{"type":"PingPong","time_stamp":"2020-04-05T13:39:21.044Z","uuid":"cb6087b4-68d1-447a-b4d2-8e1271b9f735","version":0},"body":{"time_stamp":[1586093961.044]}}, /ping
  23. [Node] [2020-04-05T22:39:21.048] [INFO] server - Get ping. msg: {"header":{"type":"PingPong","time_stamp":"2020-04-05T13:39:21.044Z","uuid":"cb6087b4-68d1-447a-b4d2-8e1271b9f735","version":0},"body":{"time_stamp":[1586093961.044]}}
  24. [Node] [2020-04-05T22:39:21.050] [INFO] pong - Pong
  25. [Node] [2020-04-05T22:39:21.051] [INFO] pong - Emit pong data
  26. [Node] [2020-04-05T22:39:21.051] [DEBUG] pong - Pong data: [object Object]
  27. [Node] [2020-04-05T22:39:21.051] [INFO] server - Get pong. msg: {"header":{"type":"PingPong","time_stamp":"2020-04-05T13:39:21.050Z","uuid":"cb6087b4-68d1-447a-b4d2-8e1271b9f735","version":0},"body":{"time_stamp":[1586093961.044,1586093961.048,1586093961.05]}}
  28. [Node] [2020-04-05T22:39:21.052] [INFO] ping - RTT: 0.00800013542175293 [s]
  29. [Typescript] 
  30. ...

まとめ

  • TypescriptでSocketIOの通信モジュールを実装し、nodeで実行する方法を調査、記載した

参考文献


変更履歴

  1. 2020/04/05: 新規作成
時刻:
ラベル: ,

0 件のコメント:

コメントを投稿

登録: コメントの投稿 (Atom)

MQTTの導入

背景 IoTデバイスの接続環境構築のため、MQTT(mosquitto)の導入を行った。 記事の目的 MQTT(mosquitto)をUbuntuに導入する mosquitto ここではmosquittoについて記載する。 MQTT MQTT(Message Qu...