介绍
WebSocket2MySQL 是一款非常实用的 npm 包，可以连接 WebSocket 服务器和 MySQL 数据库，并将 WebSocket 服务器上的数据实时写入 MySQL 数据库。该包的作用是将 WebSocket 服务器上的实时数据永久存储，以备日后使用。本文将详细介绍如何使用 WebSocket2MySQL。
安装
使用 npm 安装：
npm install websocket2mysql
使用
WebSocket2MySQL 支持 ES6 的模块导入和 CommonJS 的 require 方式引入。下面分别介绍这两种使用方式。
ES6 的模块导入方式
-- -------------------- ---- ------- ------ --------------- ---- ------------------ ----- ------ - - ---------------- --- ----- ------------ ----- ------- --------- ----------- --------- --------------- -- ----- ------ - --- ----------------------- ----------------------- --------------- ----------------- ------ ---------- -- - --------------------- ----- ----------------------- -- ------ --------------- --- ------------------ ------- -- - ----------------------- ------- ---
CommonJS 的 require 方式引入方式
-- -------------------- ---- ------- ----- --------------- - --------------------------- ----- ------ - - ---------------- --- ----- ------------ ----- ------- --------- ----------- --------- --------------- -- ----- ------ - --- ----------------------- ----------------------- --------------- ----------------- ------ ---------- -- - --------------------- ----- ----------------------- -- ------ --------------- --- ------------------ ------- -- - ----------------------- ------- ---
参数说明
WebSocket2MySQL 构造函数的参数有两个，config 用来配置 MySQL 数据库，url 是 WebSocket 服务器的地址。
-- -------------------- ---- ------- ----- ------ - - ---------------- --- ----- ------------ ----- ------- --------- ----------- --------- --------------- -- ----- ------ - --- ----------------------- -----------------------
WebSocket2MySQL 实例的 start 方法用来连接 MySQL 数据库和 WebSocket 服务器。
server.start();
WebSocket2MySQL 实例有两个事件，分别为 data 和 error。data 事件用来监听 WebSocket 服务器上的数据，error 事件用来监听错误信息。
server.on('data', (data, tableName) => {
console.log(`Received data: ${JSON.stringify(data)} in table: ${tableName}`);
});
server.on('error', (error) => {
console.error('Error:', error);
});示例代码
下面我们通过示例代码演示 WebSocket2MySQL 的使用。我们先在本地启动一个 WebSocket 服务器，代码如下所示。
-- -------------------- ---- -------
----- --------------- - ----------------------------
----- ---- - ----------------
----- ------ - --------------------------- --------- -- -
---------------- ------- - - -------- ------- --- - - -------------
------------------------
---------------
---
------------------- -- -- -
---------------- ------- - - ------ -- --------- -- ---- -------
---
----- -------- - --- -----------------
----------- -------
---
---------------------- --------- -- -
---------------- ------- - - ---------- ---- ------ - - -------------- - -----
----- ---------- - -------------------- ----------------
---------------- ------- - - ---------- ------------
-------------- -- -
----- ------- - -------- ---- -- ----- --------------------
----------------------------
----------------- -------- -------------
-- ------
---该 WebSocket 服务器每隔 5 秒向客户端发送一条包含当前时间的消息。
接下来我们通过 WebSocket2MySQL 将该 WebSocket 服务器上的数据存储在 MySQL 数据库中，代码如下所示。
-- -------------------- ---- ------- ----- --------------- - --------------------------- ----- ------ - - ---------------- --- ----- ------------ ----- ------- --------- ----------- --------- --------------- -- ----- ------ - --- ----------------------- ----------------------- --------------- ----------------- ------ ---------- -- - --------------------- ----- ----------------------- -- ------ --------------- --- ------------------ ------- -- - ----------------------- ------- ---
这样，我们就可以通过 WebSocket2MySQL 将 WebSocket 服务器上的实时数据永久存储在 MySQL 数据库中了。
总结
WebSocket2MySQL 提供了一种非常便捷的方式，可以将 WebSocket 服务器上的实时数据存储在 MySQL 数据库中。本文介绍了 WebSocket2MySQL 的安装和使用方法，并提供了示例代码。希望本文能够对大家使用 WebSocket2MySQL 有所帮助。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/600566aa81e8991b448e2e34