如何创建一个通知服务器,在数据库发生变化时通知Delphi应用程序?

tpu*_*nen 4 php python java mysql delphi

我们需要能够通知Delphi应用程序,以防MySQL中的某些表发生变化.

Delphi客户端位于防火墙后面的Internet中,在连接到我们需要实现的通知服务器之前,必须对它们进行身份验证.服务器可以使用例如Java,PHP或Python进行编程,并且必须支持数千个客户端.

通常,数据库中的一个更改只需要通知单个客户端,我不认为性能会成为瓶颈.当影响特定客户端的更改发生时,必须能够通知数千个客户端中的任何一个.

我一直在考虑一个解决方案:

  1. MySQL触发器将通知通知服务器
  2. Delphi客户端连接到消息传递队列并使用它获取通知

我的问题:

  1. 从触发器向外部服务器通知更改的最佳方法是什么
  2. 选择哪种消息队列解决方案?

mjn*_*mjn 5

回答第一个问题:

在Stack Overflow上查看此问题和答案:

添加数据库中的新行时,必须调用外部命令行程序

理论上,可以使用简单的用户定义函数将"行更改"消息触发到消息代理/队列.但这涉及可能失败的外部系统(至少是一个网络子系统) - 并且可能发生坏事.

不需要对数据库系统进行危险修改的不同解决方案将是应用程序的多层设计.然后,托管业务逻辑的服务器应用程序需要生成"数据库内容已更改"事件,将它们发布到消息代理上的发布和订阅消息通道(也称为"主题"),以便每个客户端立即收到此消息的副本或者如果客户端重新连接(使用' 持久订阅 ').


我在这里写了一篇关于这个主题的相关博客文章:Firebird数据库事件和面向消息的中间件

回答第二个问题:

Second Life的创建者评估了几个消息代理并发布了他们的结果 - 对于某些产品,Delphi客户端库存在或可以使用标准协议实现:消息队列评估说明

从那时起,其他产品已经发布,其中一些产品也可以通过非Java协议与Delphi客户端集成,例如:

  • 打开Message Queue(OpenMQ)4.4,它是Sun GlassFish v3应用程序服务器中的默认 JMS提供程序代理
  • JBoss HornetQ 2.1将成为JBoss应用服务器6中的默认JMS提供者.在相同的服务器硬件和操作系统设置上,HornetQ 2.0.GA获得的分数比先前发布的SPECjms2007基准测试结果高出307%.

一个非常流行的开源消息代理,可以从Delphi,Java,PHP,C#(和其他)客户端使用

所有代理都是为数千个并发客户端和每秒数万条消息而设计的.它们通常也支持群集和故障转移,但这不是JMS规范的一部分.

如果速度不是那么重要,但您需要高可用性(即使您的内部系统已关闭),Amazon Simple Queue Service(Amazon SQS)也是一种基于云的服务,可以使用REST和Soap样式接口进行访问.