3

我想将来自 PostgreSQL 的所有通知转发到 RabbitMQ 中的任务队列,其名称与NOTIFY channel. PostgreSQL 有类似的东西LISTEN *吗?

检查斯基特的来源似乎PQnotifies可能很有趣。PostgreSQL 关于 libpq 的文档也提到PQconsumeInput了一种使用服务器输入的方式。从文档中:

PQconsumeInput 通常返回 1 表示“无错误”,但如果出现某种故障则返回 0(在这种情况下可以查询 PQerrorMessage)。请注意,结果并未说明是否实际收集了任何输入数据。调用 PQconsumeInput 后​​,应用程序可以检查 PQisBusy 和/或 PQnotifies 以查看它们的状态是否已更改。

我在正确的道路上吗?由于我使用的是 .NET,因此我不想编写任何 C,因此欢迎提出任何建议。

我试过pgsql-listen-exchange但要么我做错了,要么插件不适用于 RabbitMQ 3.6(只有 3.5 版本)。我创建了一个问题

特定于 RabbitMQ:作为从 PostgreSQL 监听所有内容的替代方案,我想我可以创建一个交换器并为队列进行轮询,然后为每个队列创建一个监听器。也会对此进行调查。

4

0 回答 0