简介
@rabbotio/pigato 是一个 Node.js 的跨进程消息传递库，让不同的进程之间可以互相通信。它使用 ZeroMQ 库作为传输层，实现了消息的多播、异步请求-响应等功能。利用这个库，我们可以构建分布式应用，将一些处理任务分散到不同的机器上。
安装
@rabbotio/pigato 是一个 npm 包，可以使用 npm 命令行工具安装：
npm install --save @rabbotio/pigato
同时需要安装 zeromq 库，这里以 Ubuntu 为例，使用 apt-get 命令安装：
sudo apt-get install libzmq3-dev
使用
创建服务端
服务端可以监听一个或多个地址，等待客户端的请求。在服务端可以注册处理函数，当有请求到达时进行相应的处理。
-- -------------------- ---- ------- ----- ------ - ---------------------------- ----- ------- - --- -------------------------------------- --------------------- ----- ------ -- - --------------------- ------- ----------- ----------- ------- ---------- ---
上面的代码创建了一个监听本地 5000 端口的服务端，并且注册了一个处理函数，它接收一个请求，返回一个字符串的问候语。
创建客户端
创建客户端可以连接到多个服务端，并且可以发送请求，等待响应。
-- -------------------- ---- -------
----- ------ - ----------------------------
----- ------ - --- --------------------------------------
----------------------- ----- ----- -- -
-- ----- -
--------------------- ---- ----- -----------
- ---- -
--------------------- -------- ------------
-
---上面的代码创建了一个连接到本地 5000 端口的客户端，并且发送了一个请求 'World'，等待响应打印出来。
示例
为了更好地演示 @rabbotio/pigato 的使用方法，我们创建一个示例程序，它会分别开启一个服务端和两个客户端。客户端通过传递参数来向服务端请求数据，服务端根据请求数据返回处理结果。
服务端
-- -------------------- ---- -------
----- ------ - ----------------------------
----- ------- - --- ------------------------------
--------------------- ----- ------ -- -
--------------------- ------- -----------
----- ----- - ---------------
----- ------ - --------------
----- ------ - ----------------
------ -------- -
---- -------
----------- --------
------
---- ------------
----------- ------------
------
--------
-------------- ----------
------
-
---服务端监听所有地址的 5000 端口，首先解析请求参数，然后根据不同的操作返回相应的数据。
客户端 1
-- -------------------- ---- -------
----- ------ - ----------------------------
----- ------ - --- --------------------------------------
--------------------------- --------- ----- ----- -- -
-- ----- -
--------------------- ---- ----- -----------
- ---- -
--------------------- -------- ------------
-
---客户端 1 连接到本地 5000 端口，并且请求服务端发回请求参数。
客户端 2
-- -------------------- ---- -------
----- ------ - ----------------------------
----- ------ - --- --------------------------------------
--------------------------- ----- ----- -- -
-- ----- -
--------------------- ---- ----- -----------
- ---- -
--------------------- -------- ------ --------------------------------
-
---客户端 2 连接到本地 5000 端口，并且请求服务端发回当前时间戳。
运行示例程序，服务端和两个客户端分别在不同的终端中开启。请求参数以冒号分割多个部分。
-- -------------------- ---- ------- - -- - - ---- ------------------ ------ ------- - -- - - ---- ------------------- -------- -------- ------- -------- - -- - - ---- ------------------- -------- -------- ---------- ----------
总结
本文介绍了 npm 包 @rabbotio/pigato 的使用方法，包括创建监听服务端和连接客户端，以及如何发送请求和处理响应。示例程序演示了如何通过这个库来构建分布式应用。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6005671981e8991b448e3704