Spring RabbitMQ 教程导致连接被拒绝错误

2024-02-17

我是一名经验丰富的 Java 程序员,并且是第一次尝试 Spring Rabbit MQ。

我遵循了 messages-rabbitMQ 教程exactly使用 Maven。http://spring.io/guides/gs/messaging-rabbitmq/ http://spring.io/guides/gs/messaging-rabbitmq/

我在 CentOS 上作为用户帐户运行。

当我在教程最后运行应用程序时java -jar target/gs-messaging-rabbitmq-0.1.0.jar,我收到以下连接被拒绝错误。有人可以帮忙吗?

prompt> java -jar target/gs-messaging-rabbitmq-0.1.0.jar

  .   ____          _            __ _ _
 /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  '  |____| .__|_| |_|_| |_\__, | / / / /
 =========|_|==============|___/=/_/_/_/
 :: Spring Boot ::        (v1.2.3.RELEASE)

2015-05-13 11:49:44.833  INFO 26218 --- [           main] hello.Application                        : Starting Application v0.1.0 on minerva-02-33.gbcl.net with PID 26218 (/home/ccpm/test/spring_rabbitmq/target/gs-messaging-rabbitmq-0.1.0.jar started by ccpm in /home/ccpm/test/spring_rabbitmq)
2015-05-13 11:49:44.912  INFO 26218 --- [           main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@8146158: startup date [Wed May 13 11:49:44 PDT 2015]; root of context hierarchy
2015-05-13 11:49:45.863  INFO 26218 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration' of type [class org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration$$EnhancerBySpringCGLIB$$9a886eed] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2015-05-13 11:49:46.397  INFO 26218 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Registering beans for JMX exposure on startup
2015-05-13 11:49:46.404  INFO 26218 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase 2147483647
2015-05-13 11:49:46.433 ERROR 26218 --- [cTaskExecutor-1] o.s.a.r.l.SimpleMessageListenerContainer : Failed to check/redeclare auto-delete queue(s).

org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused
    at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:54)
    at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:207)
    at org.springframework.amqp.rabbit.connection.CachingConnectionFactory.createConnection(CachingConnectionFactory.java:441)
    at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils$1.createConnection(ConnectionFactoryUtils.java:80)
    at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:130)
    at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:67)
    at org.springframework.amqp.rabbit.core.RabbitTemplate.doExecute(RabbitTemplate.java:1035)
    at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:1028)
    at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:1004)
    at org.springframework.amqp.rabbit.core.RabbitAdmin.getQueueProperties(RabbitAdmin.java:254)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.redeclareElementsIfNecessary(SimpleMessageListenerContainer.java:947)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$300(SimpleMessageListenerContainer.java:82)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1065)
    at java.lang.Thread.run(Thread.java:745)
Caused by: java.net.ConnectException: Connection refused
    at java.net.PlainSocketImpl.socketConnect(Native Method)
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
    at java.net.Socket.connect(Socket.java:579)
    at com.rabbitmq.client.impl.FrameHandlerFactory.create(FrameHandlerFactory.java:32)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:615)
    at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:199)
    ... 12 common frames omitted

Waiting five seconds...
2015-05-13 11:49:51.437  WARN 26218 --- [cTaskExecutor-1] o.s.a.r.l.SimpleMessageListenerContainer : Consumer raised exception, processing can restart if the connection factory supports it. Exception summary: org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused
2015-05-13 11:49:51.437  INFO 26218 --- [cTaskExecutor-1] o.s.a.r.l.SimpleMessageListenerContainer : Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0
2015-05-13 11:49:51.441 ERROR 26218 --- [cTaskExecutor-2] o.s.a.r.l.SimpleMessageListenerContainer : Failed to check/redeclare auto-delete queue(s).

org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused
    at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:54)
    at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:207)
    at org.springframework.amqp.rabbit.connection.CachingConnectionFactory.createConnection(CachingConnectionFactory.java:441)
    at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils$1.createConnection(ConnectionFactoryUtils.java:80)
    at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:130)
    at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:67)
    at org.springframework.amqp.rabbit.core.RabbitTemplate.doExecute(RabbitTemplate.java:1035)
    at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:1028)
    at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:1004)
    at org.springframework.amqp.rabbit.core.RabbitAdmin.getQueueProperties(RabbitAdmin.java:254)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.redeclareElementsIfNecessary(SimpleMessageListenerContainer.java:947)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$300(SimpleMessageListenerContainer.java:82)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1065)
    at java.lang.Thread.run(Thread.java:745)
Caused by: java.net.ConnectException: Connection refused
    at java.net.PlainSocketImpl.socketConnect(Native Method)
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
    at java.net.Socket.connect(Socket.java:579)
    at com.rabbitmq.client.impl.FrameHandlerFactory.create(FrameHandlerFactory.java:32)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:615)
    at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:199)
    ... 12 common frames omitted

您没有安装 RabbitMQ 服务器。幸运的是,这很容易做到。你提到你使用的是CentOS,在这里你可以下载RabbitMQ服务器:https://www.rabbitmq.com/install-rpm.html https://www.rabbitmq.com/install-rpm.html

您需要执行几个步骤,包括安装 Erlang。

Spring 示例假设您已经了解一些有关使用消息代理的信息。这本身就是您需要使用的一项技术,就像您必须学习使用数据库或操作系统一样。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Spring RabbitMQ 教程导致连接被拒绝错误 的相关文章

随机推荐

  • 为什么不使用工厂模式进行排序? [关闭]

    就目前情况而言 这个问题不太适合我们的问答形式 我们希望答案得到事实 参考资料或专业知识的支持 但这个问题可能会引发辩论 争论 民意调查或扩展讨论 如果您觉得这个问题可以改进并可能重新开放 访问帮助中心 help reopen questi
  • 有没有一种优雅的方法来解析单词并在大写字母前添加空格

    我需要解析一些数据并且我想转换 AutomaticTrackingSystem to Automatic Tracking System 本质上是在任何大写字母之前放置一个空格 当然除了第一个字母 您可以使用环视 例如 string tes
  • 在 Mac 上覆盖 python 3.x 中的打印行

    我正在尝试编写一个涉及使用硬币翻转 正面或反面的程序 但这样它会打印 正面 然后用 反面 替换 并继续这样做 直到决定答案 目前 当我运行该程序时 它每次都会在下一行打印 正面 或 背面 这种情况在空闲和终端上都会发生 我尝试过使用回车符
  • 在运行时创建证书和通行证类型 ID

    我的 Passbook 相关应用最近根据准则 23 3 被拒绝 23 3 通行证必须由将以其自己的名称 商标或品牌分发通行证的实体签署 否则应用程序将被拒绝 并且 Passbook 凭据可能会被撤销 我有几个问题 并与苹果公司的某人通了电话
  • jQuery 和 IE 在 $('#someDiv').hide(); 上崩溃

    好吧 过了一会儿我挠了挠头 啊 试图找出为什么 IE 在加载我的一个加载了 jQuery 的页面时会直接崩溃 我将罪魁祸首缩小到这一行 div questions hide 当我说 IE 崩溃时 我的意思是它完全崩溃了 试图进行网页恢复 但
  • 在 https:// 上使用 ws://(混合内容)

    我有一个 html5 页面 var connection new WebSocket ws foo bar 8888 但我收到一个错误 混合内容 页面位于 https foo bar https foo bar 通过 HTTPS 加载 但尝
  • PHP PDO 准备好的语句需要转义吗?

    On the PDO 准备页面 http www php net manual en pdo prepare php它指出 并且无需手动引用参数 有助于防止 SQL 注入攻击 知道了这一点 是否有像 mysql real escape st
  • 将 git 与 CVS 结合使用的最佳实践

    使用 git 与 CVS 存储库交互的最佳实践和技巧是什么 我写了一个类似问题的答案here https stackoverflow com questions 584522 how to export revision history f
  • 按钮是否允许显示:网格? [复制]

    这个问题在这里已经有答案了 按钮是否允许显示 网格 或者更一般地说 是否有任何元素不能使用display grid 考虑 button div display grid grid template columns 50px 50px Nev
  • 从 DOS 命令行关闭正在运行的应用程序

    start 命令可以在批处理文件中启动像记事本这样的应用程序 如下所示 start notepad start my love mp3 但是如何从命令行关闭正在运行的应用程序呢 我发现taskkill在我的搜索中 但我认为这不是正确的命令
  • 如何显示当前运行的python模块的路径? [复制]

    这个问题在这里已经有答案了 如何显示当前运行的python模块的路径 哪个会打印 Users user documents python bla py如果 bla py 被放置在 Users user documents python 如果
  • 将二进制格式字符串转换为 int,在 C 中

    如何将二进制字符串 如 010011101 转换为 int 以及如何将 int 如 5 转换为 C 中的字符串 101 The strtol标准库中的函数采用 base 参数 在本例中为 2 int fromBinary const cha
  • S3 上的静态网站,路由为 53 - 无法访问网站

    我在 S3 上托管了一个静态网站 并设置了合适的存储桶策略 在另一个选项卡中查看 端点 效果非常好 此后 我在路线 53 中创建了一个托管区域 为其提供了理想的人类可读地址 创建托管区域后 我新创建的托管区域中有两条记录 其中一条记录属于类
  • Django 根据子级过滤父级

    我有发票型号 class Invoice models Model name models ForeignKey Patient on delete models CASCADE 我有另一个发票金额模型 其中包含发票的 FK class I
  • Firebase 远程通知未收到?

    我尝试通过云消息从 Firebase 控制台发送远程通知 但我的手机没有收到任何警报 我已将证书上传到 Firebase 并且正在使用 Firebase 教程提供的默认代码来接收通知 Here is a picture of my cert
  • tkinter OptionMenu 问题(bug?):GUI 和程序值未保持同步(python 3.x)

    在某些情况下 下面的演示 OpenMenu 小部件上显示的值与程序使用的值不匹配 这会导致当用户期望选项 A 时执行选项 B 导致 WTF 用户的反应 不幸的是 OptionMenu 小部件没有我与其他小部件一起使用来轻松处理问题的 命令
  • 如何在 PostgreSQL 中获得随机笛卡尔积?

    我有两张桌子 custassets and tags 为了生成一些测试数据 我想做一个INSERT INTO一个多对多表SELECT从每个表中获取随机行 以便一个表中的随机主键与第二个表中的随机主键配对 令我惊讶的是 这并不像我最初想象的那
  • aframe 不渲染映射到画布的 Lottie json 纹理,但可以在 Three.js 中使用

    所以我基本上试图通过 aframe 将 json 渲染到画布上 你确实成功地将其映射到 Three js 中的画布上 但是当我尝试在 aframe 中复制它时 它只显示一个白色框架 它显示它在那里 但没有显示动画 无法在 aframe 中渲
  • C# SSIS 数据流组件 - 创建自定义输入列

    我正在尝试创建我的第一个数据流组件 该组件将获取输入地址 通过 PAF api 运行它 并从文件源或数据库表中吐出格式正确的地址和原始输入列 我需要以特定格式提供源输入地址 因此我需要用户将源输入列映射到特定的自定义输入列 我能够使用 in
  • Spring RabbitMQ 教程导致连接被拒绝错误

    我是一名经验丰富的 Java 程序员 并且是第一次尝试 Spring Rabbit MQ 我遵循了 messages rabbitMQ 教程exactly使用 Maven http spring io guides gs messaging