如何解决RabbitMQ频道创建准则
| 我正在编写一个简单的类，我的应用程序将使用该类使用RabbitMQ发送和接收消息。 我已经找到了尽可能多的关于RabbitMQ的方法，博客文章，白皮书和类似文章。 大多数示例都显示使用包装在using块中的连接和通道，并且与之相反，您可能应该将它们实现为单例。 特别是关于通道，我已经看到有评论说，同时使用单个通道的线程不应超过一个。 我正在用C＃编写我的库。这是一个单例，在第一次实例化时连接了静态连接。 我曾考虑过对频道进行相同的操作，但是我打算使用相同的库来允许发布/订阅多个交换/队列。发布和订阅都可以从多个线程完成。 最后是我的问题： 我应该如何实施渠道创建？ 每条消息？ 每个消费者都有一个独特的私人渠道，发布者将访问权同步到一个独特的渠道吗？ 你抓住我的漂移。 请记住，我打算使用一台服务器，其中包含数十个使用者/发布者，但不多。 谢谢！解决方法
编辑（2016-1-26）：通道不是线程安全的。在2015年4月至2015年5月之间，相关文档已更改。新文本：
通道实例不得在线程之间共享。应用程序应该更喜欢每个线程使用一个Channel，而不是在多个线程之间共享同一Channel。尽管可以安全地并发调用通道上的某些操作，但某些操作却不能并发调用，这将导致错误的帧交错在电线上。线程之间共享通道也会干扰*发布者确认。
从您的问题看来，您似乎没有预定义的固定数量的线程，这些线程大部分都可以发布/订阅RabbitMQ（在这种情况下，您可以考虑创建通道作为线程初始化的一部分，或者使用
ThreadLocal<IModel>
ConcurrentQueue<IModel>
using Microsoft.Extensions.ObjectPool;
using Microsoft.Extensions.Options;
using RabbitMQ.Client;
public class RabbitModelPooledObjectPolicy : IPooledObjectPolicy<IModel>
{
private readonly RabbitOptions _options;
private readonly IConnection _connection;
public RabbitModelPooledObjectPolicy(IOptions<RabbitOptions> optionsAccs)
{
_options = optionsAccs.Value;
_connection = GetConnection();
}
private IConnection GetConnection()
{
var factory = new ConnectionFactory()
{
HostName = _options.HostName,UserName = _options.UserName,Password = _options.Password,Port = _options.Port,VirtualHost = _options.VHost,};
return factory.CreateConnection();
}
public IModel Create()
{
return _connection.CreateModel();
}
public bool Return(IModel obj)
{
if (obj.IsOpen)
{
return true;
}
else
{
obj?.Dispose();
return false;
}
}
}
services.AddSingleton<ObjectPoolProvider,DefaultObjectPoolProvider>();
services.AddSingleton(s =>
{
var provider = s.GetRequiredService<ObjectPoolProvider>();
return provider.Create(new RabbitModelPooledObjectPolicy());
});
var channel = pool.Get();
try
{
channel.BasicPublish(...);
}
finally
{
pool.Return(channel);
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。