×

Loading...
Ad by
Ad by

@Calgary

是MICROSOFT MQ吗? 你的REQUIREMENT是不是关键业务?如果不是,

grumpyoldtroll(Toronto Sunshine)
典型的简单POINT-TO-POINT模式,写一个CLIENT根据你的要求往QUEUE里写MESSAGE(TEXT,XML OR OBJECT), 缺省情况下应是PERSISTENT MESSAGE.
另写一个LISTERNER,从QUEUE里拿MESSAGE,转换成SQL命令,检查DATABASE,如ACTIVE, 把SQL发到SQL DATABASE去运行.在DATABASE INACTIVE或SQL运行出错,MESSAGE会放回QUEUE里,等待下一次的运行.

如是关键业务,要考虑TRANSACTION,而且最好是TWO PHASE COMMIT PROTOCOL.
1) MESSQGE PROVIDER是不是XA-COMPLIANT的.
2) 需要TRANSACTION SERVER (TX & XA).,有FAILURE RECOVERY功能.
3) XA-COMPLIANT DATABASE DRIVER
4) SQL DATABASE是否能FAILURE RECOVERY.
5) 如不能支持DISTRIBUTED TRANSACTION,可以分别用MESSAGE PROVIDER和
SQLＳＥＲＶＥＲ的ＬＯＣＡＬ　ＴＲＡＮＳＡＣＴＩＯＮ．另外，需要写ＣＯＭＰＥＮＳＡＣＴＩＯＮ　ＴＲＡＮＳＡＣＴＩＯＮ．
(#2315518@0)
Last Updated: 2005-5-27
This post has been archived. It cannot be replied.
Report

Replies, comments and Discussions:

  • 工作学习 / 专业技术讨论 / 请教:哪位有Message Queue的编程经验啊？我只有个大概的概念。现在要做的是： -qco(Expecting...); 2005-5-25 {181} (#2312835@0)
    程序不停地向SQL Server写数据,需要一种机制可以Queue住所有没完成的命令,当SQL Server出了问题,恢复正常以后还能把原来要写的数据写入.看了几个SDK下的例子还是摸不着头脑.哪位可指教一下,谢谢.
    • I am familiar with WMQ only but the concept should be similar. You can check the 'persistent' attribute of the Queue and consume message in some transaction context. -davidchencaro(david chen); 2005-5-25 (#2312888@0)
      • 谢谢。我这种情况，我的程序是sending application，SQL Server是receiving apllication 对吗？ -qco(Expecting...); 2005-5-26 (#2314778@0)
    • .NET? -yuxiliu(Nescafe); 2005-5-25 {121} (#2313412@0)
      Send message: object -> serialize to Q (binary or xml).
      Read message: deserialize from the Q (binary or xml) -> object.
      • 还没用上.net, 还是C++. 谢谢 -qco(Expecting...); 2005-5-26 (#2314782@0)
    • 是MICROSOFT MQ吗? 你的REQUIREMENT是不是关键业务?如果不是, -grumpyoldtroll(Toronto Sunshine); 2005-5-27 {735} (#2315518@0)
      典型的简单POINT-TO-POINT模式,写一个CLIENT根据你的要求往QUEUE里写MESSAGE(TEXT,XML OR OBJECT), 缺省情况下应是PERSISTENT MESSAGE.
      另写一个LISTERNER,从QUEUE里拿MESSAGE,转换成SQL命令,检查DATABASE,如ACTIVE, 把SQL发到SQL DATABASE去运行.在DATABASE INACTIVE或SQL运行出错,MESSAGE会放回QUEUE里,等待下一次的运行.

      如是关键业务,要考虑TRANSACTION,而且最好是TWO PHASE COMMIT PROTOCOL.
      1) MESSQGE PROVIDER是不是XA-COMPLIANT的.
      2) 需要TRANSACTION SERVER (TX & XA).,有FAILURE RECOVERY功能.
      3) XA-COMPLIANT DATABASE DRIVER
      4) SQL DATABASE是否能FAILURE RECOVERY.
      5) 如不能支持DISTRIBUTED TRANSACTION,可以分别用MESSAGE PROVIDER和
      SQLＳＥＲＶＥＲ的ＬＯＣＡＬ　ＴＲＡＮＳＡＣＴＩＯＮ．另外，需要写ＣＯＭＰＥＮＳＡＣＴＩＯＮ　ＴＲＡＮＳＡＣＴＩＯＮ．
      • 谢谢。关键业务是指银行之类的业务吧？我这个算不上。这个Sender和Listener必须是不同的应用程序还是不同的线程就可以?我开始还以为不用写Listener的程序，SQL Server就是Listener呢？　 -qco(Expecting...); 2005-5-27 (#2315752@0)

More Topics

  • 老程序员第一次用copilot的一点点体会
  • 现在社区游泳池招救生员巡逻，过一会还要不停的点人头，这工作是否很快就被AI代替了，装一个摄像头后面是AI处理系统，这样只招一个等着救人就行了，人头沉下水一定时间立马强光照射，还可以分析水下人的状况来判断是否溺水等
  • 新冠疫苗引发心肌炎? 最新研究这样看
  • 这道几何题有解吗?
  • SAM 2 Demo
    • 枫下论坛主坛 /  工作学习 /  专业技术讨论