首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >用RabbitMQ连接C#

用RabbitMQ连接C#
EN

Stack Overflow用户
提问于 2013-09-22 08:16:26
回答 2查看 11.3K关注 0票数 2

我正在使用在互联网上可用的示例代码,但是我得到了一个异常,我无法解决这个错误。

我得到了这个例外

BrokerUnreachableExceptionCaught没有一个指定的端点是可访问的。

不知道如何解决这个错误。有这么多的链接,已经发布了遇到的错误,但他们都没有它的解决办法。请在这件事上帮我。你的建议对我有帮助。请尽快帮忙。

一些链接

  • http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2012-September/022407.html
  • http://comments.gmane.org/gmane.comp.networking.rabbitmq.general/18329

代码:

代码语言:javascript
复制
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
{
}
EN

回答 2

Stack Overflow用户

回答已采纳

发布于 2013-09-22 22:13:30

引发的BrokerUnreachableException具有以下有用的属性:

ConnectionAttempts ConnectionErrors

看看这些,看看是否有额外的信息(例如,密码可能是不正确的)。

票数 3
EN

Stack Overflow用户

发布于 2019-06-12 14:42:54

RabbitMQ.Client内核中的RabbitMQ本地主机连接,在Nugget包中浏览Asp.net

//localhost连接,这些都适用于我。

代码语言:javascript
复制
var factory = new ConnectionFactory() { HostName = "localhost" };

代码语言:javascript
复制
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

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/18941745

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档