我正在使用在互联网上可用的示例代码,但是我得到了一个异常,我无法解决这个错误。
我得到了这个例外
BrokerUnreachableExceptionCaught没有一个指定的端点是可访问的。
不知道如何解决这个错误。有这么多的链接,已经发布了遇到的错误,但他们都没有它的解决办法。请在这件事上帮我。你的建议对我有帮助。请尽快帮忙。
一些链接
代码:
try
{
ConnectionFactory factory = new ConnectionFactory();
factory.UserName = "user";
factory.Password = "password";
factory.VirtualHost = "/";
factory.Protocol = Protocols.FromEnvironment();
factory.HostName = "localhost";
factory.Port = AmqpTcpEndpoint.UseDefaultPort;
IConnection conn = factory.CreateConnection();
//using (var connection = factory.CreateConnection())
//{
// using (var channel = connection.CreateModel())
// {
// channel.QueueDeclare("hello", false, false, false, null);
// string message = "Hello World!";
// var body = Encoding.UTF8.GetBytes(message);
// channel.BasicPublish("", "hello", null, body);
// Console.WriteLine(" [x] Sent {0}", message);
// }
//}
}
catch
{
}发布于 2013-09-22 22:13:30
引发的BrokerUnreachableException具有以下有用的属性:
ConnectionAttempts ConnectionErrors
看看这些,看看是否有额外的信息(例如,密码可能是不正确的)。
发布于 2019-06-12 14:42:54
RabbitMQ.Client内核中的RabbitMQ本地主机连接,在Nugget包中浏览Asp.net
//localhost连接,这些都适用于我。
var factory = new ConnectionFactory() { HostName = "localhost" };或
var factory = new ConnectionFactory();
using (var connection = factory.CreateConnection())
{
using (var channel = connection.CreateModel())
{
channel.QueueDeclare(queue: "HelloNewWorld",
durable: false,
exclusive: false,
autoDelete: false,
arguments: null);
string message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: "",
routingKey: "HelloNewWorld",
basicProperties: null,
body: body);
Console.WriteLine(" [x] Sent {0}", message);
}
}
//default localhost for rabbitmq
http://localhost:15672/queues

Asp.NetCore #RabbitMQ
https://stackoverflow.com/questions/18941745
复制相似问题