Q 语言 - 进程间通信

KDB+ 允许一个进程通过进程间通信与另一进程进行通信。 Kdb+ 进程可以连接到同一台计算机、同一网络甚至远程上的任何其他 kdb+。 我们只需要指定端口，然后客户端就可以与该端口通信。 任何 q 进程都可以与任何其他 q 进程通信，只要它可以在网络上访问并且正在侦听连接。

• 服务器进程侦听连接并处理任何请求

• 客户端进程发起连接并发送要执行的命令

客户端和服务器可以在同一台机器上，也可以在不同的机器上。 一个进程既可以是客户端，也可以是服务器。

沟通可以是，

• 同步（等待返回结果）

• 异步（无需等待，不返回结果）

初始化服务器

q 服务器通过指定要侦听的端口来初始化，

q –p 5001 / command line
\p 5001   / session command

通信句柄

通信句柄是一个以":"开头的符号，其形式为 −

`:[server]:port-number

示例

`::5001              / server and client on same machine
`:jack:5001          / server on machine jack
`:192.168.0.156      / server on specific IP address
`:www.myfx.com:5001  / server at www.myfx.com

为了启动连接，我们使用函数"hopen"，它返回一个整数连接句柄。 该句柄用于所有后续客户端请求。 例如 −

q)h:hopen `::5001

q)h"til 5"
0 1 2 3 4

q)hclose h

同步和异步消息

一旦我们有了句柄，我们就可以同步或异步发送消息。

同步消息 − 发送消息后，它会等待并返回结果。 其格式如下 −

handle “message”

异步消息 − 发送消息后，立即开始处理下一条语句，无需等待并返回结果。 其格式如下 −

neg[handle] “message”

需要响应的消息，例如函数调用或选择语句，通常会使用同步形式； 而不需要返回输出的消息（例如向表中插入更新）将是异步的。