我们使用外部 TCP/IP 接口，其中一项要求是保持连接打开，等待处理完成，然后将结果发送回 ACK。
假设我们想要使用 MessageBus (masstransit/nservicebus) 与处理模块通信并跟踪消息状态：接收、处理、成功、失败，那么实现这一目标的最佳方法是什么？
具体来说，当消息到达处理程序/消费者时，它如何知道 TCP/IP 连接？我应该将它存储在某个自定义容器中并将其注入消费者吗？
感谢任何指导。谢谢。
【问题讨论】：
消费者将知道如何启动和管理 TCP 连接生命周期。
当接收到消息时，处理程序可以调用代码，该代码根据消息数据执行某些操作。这是否涉及在某处的屏幕上显示绿色大象或打开端口、拨打电话、然后处理 ACK，都不会改变您处理消息的方式。
负责执行操作的实际代码可以打包成类似 nuget 包的东西，并暴露在某种通用接口上，如果这能让你更开心的话，但与具有双重角色的组件没有矛盾该消息的消息使用者和处理器。
将为每条消息创建一个新的消费者实例 接收。此外，在我的情况下，消费者无法启动 TCP/IP 连接，它已经在早些时候打开（并存储在某个地方 else) 并且消费者只需有权使用它。
对不起，我应该更仔细地阅读你原来的问题。
有一个从 NServiceBus 共享访问资源的解决方案，如文档 here 所述。
public class SomeEventHandler : IHandleMessages<SomeEvent>
{
private IMakeTcpCall _caller;
public SomeEventHandler(IMakeTcpCalls caller)
{
_caller = caller;
}
public Task Handle(SomeEvent message, IMessageHandlerContext context)
{
// Use the caller
var ack = _caller.Call(message.SomeData);
// Do something with ack
...
return Task.CompletedTask;
}
}
理想情况下，您应该有一个 DI 容器，它将 IMakeTcpCall 实例的生命周期作为单例来管理（尽管这在大容量场景中可能会变得很奇怪），这样您就可以重新使用打开的TCP 通道。
例如，Castle Windsor:
Component.For<IMakeTcpCalls>().ImplementedBy<MyThreadsafeTcpCaller>().LifestyleSingleton();
Castle Windsor integrates 与 NServiceBus
【讨论】：