我想创建一个类(类似于RabbitMQ连接的包装器),以将消息发布到交易所。这将是另一个系统使用的类库。
我的问题很简单:如何关闭和打开连接?
我最初的想法是这样的:
public class RabbitConnection
{
private readonly IConnection conn;
public RabbitConnection() {
try {
var factory = new ConnectionFactory() {...}
this.conn = factory.CreateConnection();
}
catch {
...
}
}
...
public void Publish<T>(T @event) where T : class {
using (var channel = conn.CreateModel()) {
...
channel.BasicPublish(...);
}
}
}
这不是不是寻找最佳模式的最佳方法吗?
谢谢前进!