首页 文章
  • 2 votes
     answers
     views

    处理事务性WCF MSMQ异步部分排序的消息

    我已经尝试过MsmqIntergrationBinding和NetMsmqBinding,但我正在努力实现我的异步处理事务性WCF MSMQ部分排序消息的目标 . 我想使用WCF来侦听事务队列上的消息 . 为了处理消息,我根据消息内容将传入消息解复用为各种(内存中)队列<> . 消息以异步方式处理时,MSMQ事务保持打开状态,但WCF Dispatcher可以继续接受任何下一条消息 ....
  • 0 votes
     answers
     views

    使用nssm创建节点脚本无法启动

    我正在使用NSSM来创建节点进程 . 我有一个简单的脚本,侦听发送到MSMQ队列的消息,该队列使用node-msmq https://www.npmjs.com/package/node-msmq const msmq = require('node-msmq'); const fs = require('fs'); var queue = msmq.openOrCreateQueue('.\...
  • 27 votes
     answers
     views

    如何研究.NET中的非托管内存泄漏?

    我有一个在MSMQ上运行的WCF服务 . 内存随着时间的推移逐渐增加,表明存在某种内存泄漏 . 我在本地运行该服务并使用PerfMon监控一些计数器 . 总CLR内存管理堆字节保持相对恒定,而进程的私有字节随时间增加 . 这让我相信存在某种非托管内存泄漏 . 假设存在非托管内存泄漏问题,我该如何解决这个问题?是否有任何工具可以用来向我提供有关导致非托管内存泄漏的提示?此外,我所有的服务都是从事务队...
  • 7 votes
     answers
     views

    绑定到群集MSMQ实例的MSMQ消息卡在传出队列中

    我们已经为一组NServiceBus服务聚集了MSMQ,一切都运行良好,直到它没有 . 一台服务器上的传出队列开始填满,很快整个系统都挂起了 . 更多细节: 我们在服务器N1和N2之间有一个集群MSMQ . 其他群集资源只是作为本地(即NServiceBus分发服务器)直接在群集队列上运行的服务 . 所有工作进程都位于不同的服务器上,即Services3和Services4 . 对于那些不熟悉NS...
  • 2 votes
     answers
     views

    NServiceBus和具有MSMQ群集的远程输入队列

    我们希望将NServiceBus的发布/订阅功能与MSMQ群集一起使用 . 让我详细解释一下: 我们有一个SQL Server集群,它也承载MSMQ集群 . 除了SQL Server和MSMQ,我们无法在此群集上托管任何其他应用程序 . 这意味着我们的订户不允许在计算机上运行 . 我们有多个应用服务器托管不同类型的应用程序(从ASP.NET MVC到SharePoint Server 20...
  • 1 votes
     answers
     views

    NServiceBus分发服务器无法在群集MSMQ上创建队列

    我正在尝试在Windows故障转移群集上设置NServiceBus分发服务器 . 我成功地遵循了“官方”指南,大多数事情似乎都很好用 . 除了实际启动集群上的分发服务器 . 当它启动时,它尝试在集群MSMQ上创建它的队列,但是被拒绝权限: Unhandled Exception:Magnum.StateMachine.StateMachineException:在Topshelf.Interna...
  • 1 votes
     answers
     views

    NServiceBus分发工作程序创建一个名为PRIVATE $ \ order_queue $的队列

    我创建了一个NServiceBus分发服务器和Worker,在不同的机器上运行 . 当我运行worker时,它成功地向Distributor发送一条消息(我可以看到它通过Storage队列处理),但由于某种原因,在Distributor上创建了一个输出队列 'DIRECT = TCP:xx.xx.xx.xx \ PRIVATE $ \ order_queue $当队列应该被称为'DIRECT = ...
  • 1 votes
     answers
     views

    Nservicebus传奇超时

    我有一个saga,如果从调用返回的状态成功,saga结束,则每隔30秒检查一次API调用的状态,如果不是saga等待30秒并再次尝试 . 如果API调用在60分钟内没有返回成功的响应,那么saga将超时并结束 . 我在解决60分钟超时问题时遇到了问题 . 我的代码是 public class MonitorSubmissionFeedSagaData: IContainSagaData { ...
  • 3 votes
     answers
     views

    MSMQ异步异常行为 - .NET 4.0 vs .NET 2.0

    我最近在MSMQ中遇到了异步操作的问题 . 在.NET 2.0,3.0和3.5中,如果存在挂起的异步接收,并且队列被删除,则调用回调,并在调用EndReceive时抛出异常 . 在.NET 4.0中,永远不会调用回调,但AppDomain.UnhandledException事件处理程序可以捕获该异常 . 在调试器中运行时,应用程序将直接终止,而Visual Studio不会发出异常通知 . 此代...
  • 0 votes
     answers
     views

    使用MSMQ队列来分离消息 生产环境 者和消费者?

    对于将报告发布到SOAP服务的一些Windows服务(c#),我将不胜感激 . 它从数据库中获取一组有限的报告(Oracle AQ表中的报告),将它们聚合到一条消息中,并将此消息转发给WCF SOAP服务 . 如果已成功通过SOAP传输报告,则会将其标记为“已发送” . 否则,它们将再次添加到AQ表(通过db作业) . 所以我提出了以下设计 . 什么是最好的方式去?队列是否会在可扩展性,稳健性,解...
  • 0 votes
     answers
     views

    访问继承类型的内部类

    希望扩展 BeginReceive 方法,并将 MessageQueue.ReceiveCompleted 的事件处理程序传递给REFERENCE TCPClient 对象 . 因此,我可以将其作为对象传递,但它将通过VALUE传递,因此将是 TCPClient 对象的副本 . 不好! 所以,我决定尝试编写自己的重载方法等 . 调试.NET 4.5.2框架代码,我看到 BeginReceive(...
  • 8 votes
     answers
     views

    “执行操作的资源不足 . ”当事务包含多条消息时,MSMQ

    我正在将应用程序从一个服务器移动到另一个服务器,新服务器返回“着名的” - “资源不足以执行操作” . 消息当代码尝试向队列发送多条消息时,该进程被包装在一个事务(TransactionScope)中 . 旧服务器正确执行代码,所有消息(约150个)按预期发送到队列,但新服务器在apporx 27处失败 . 现在消息大小很小,队列中的消息数为零 . 我've read the ' Insuffic...

热门问题