rabbitmq坑点与异常处理

摘要:
一、Noneofthespecifiedendpointswerereachable这个异常在创建连接时抛出(CreateConnection()),原因一般是ConnectionFactory参数设置不对,比如HostName、UserName、Password标准设置:varfactory=newConnectionFactory();factory.UserName=QueueSetttio
一、None of the specified endpoints were reachable
这个异常在创建连接时抛出(CreateConnection()),原因一般是ConnectionFactory参数设置不对,比如HostName、UserName、Password
标准设置:
var factory = new ConnectionFactory();
factory.UserName = QueueSetttiong.UserName; //用户名
factory.Password = QueueSetttiong.Password; //密码
factory.HostName = QueueSetttiong.HostName; //Rabbitmq服务IP,不包含端口
factory.Port = AmqpTcpEndpoint.UseDefaultPort;
factory.VirtualHost = QueueSetttiong.VirtualHost; //默认为"/"
factory.Protocol = Protocols.DefaultProtocol;
部署生产后,factory配置都ok,但是还是抛异常None of the specified endpoints were reachable,最后发现原因是生产机器防火墙未打开RabbitMQ的端口,RabbitMQ的默认端口是:5672

另外一个可能的原因:未设置VirtualHost的权限

设置方法:RabbitmqWeb管理网站-->Admin

未设置权限时:

rabbitmq坑点与异常处理第1张

设置权限:(点击admin进入设置页面)

rabbitmq坑点与异常处理第2张

二、异常:unable to connect to node rabbit@10: nodedown

网上说要修改主机名,找半天不知道怎么修改,重新安装Rabbitmq服务端即可,有时候需要重启

三、异常:Message:Already closed: The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=320, text="CONNECTION_FORCED - broker forced connection closure with reason 'shutdown'", classId=0, methodId=0, cause= StackTrace

原因:队列服务端重启后,队列发布端断开了接口,无法再次发送消息

解决:发送端设置断开连接后自动启动属性,默认为断开后每隔五秒钟重试连接

var factory = new ConnectionFactory();

factory.AutomaticRecoveryEnabled = true; //设置端口后自动恢复连接属性即可

四、Rabbitmq实际数据文件、日志文件、配置文件路径

地址栏输入:%APPDATA%RabbitMQ

C:UsersAdministratorAppDataRoamingRabbitMQ

信息来源:C:Program Files (x86)RabbitMQ Server abbitmq_server-3.5.1etc 中的README.txt

免责声明:文章转载自《rabbitmq坑点与异常处理》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇linux系统统计某一行出现特定字符的次数[JavaWeb]SpringSecurity-OAuth2.0 统一认证、资源分离的配置,用于分布式架构、模块化开发的认证体系下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

Tp5使用消息队列实现邮键发送

1、首先,compare需要下载安转包,如果你有的话就可以直接使用这个扩展包  消息队列扩展 composer require topthink/think-queue 在extra文件夹中的queue.php进行配置 return [ 'connector' => 'database', 'table' => 'j...

CentOS7安装OpenStack(Rocky版)-01.控制节点的系统环境准备

分享一下Rocky版本的OpenStack安装管理经验: OpenStack每半年左右更新一版,目前是版本是201808月发布的版本-R版(Rocky),目前版本安装方法优化较好,不过依然是比较复杂 官方文档地址:https://docs.openstack.org/install-guide/openstack-services.html 本文主要分享控...

Ubuntu18.04安装RabbitMQ

一.安装erlang 由于rabbitMq需要erlang语言的支持,在安装rabbitMq之前需要安装erlang sudo apt-get install erlang-nox 二.安装Rabbitmq 更新源 sudo apt-get update 安装 sudo apt-get install rabbitmq-server 启动、停止、重启...

十二、消息驱动(SpringCloud Stream)

https://spring.io/projects/spring-cloud-stream#overviewhttps://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.1.RELEASE/reference/html/ 一、消息驱动概述   官网定义Spring Cloud St...

rabbitmq 和 kafka 简单的性能测试

测试环境:ubuntu 15.10 64位 cpu:inter core i7-4790 3.60GHZ * 8 内存:16GB 硬盘:ssd 120GB 软件环境:rabbmitmq 3.6.0 kafka0.8.1 (均为单机本机运行) PS:测试结果均为单操作测试,即生产的时候没有消费操作 测试结果: kafka :消费速度: 37,586 /s 生...

rabbitMQ Connection timed out

在VM中部署了一个rabbitMQ server ,在物理机上按照rabbitMQ官网上的 java的教程访问VM中的rabbitMQ报如下错误: Exception in thread "main" java.net.ConnectException: Connection timed out: connect at java.net.DualStac...