解决SpringAMQP工作队列模型程序报错:WARN 48068:Failed to declare queue: simple.queue

这里写目录标题

  • 1.运行环境
  • 2.报错信息
  • 3.解决方案
  • 4.查看解决之后的效果

1.运行环境

使用docker运行了RabbitMQ的服务器:

在这里插入图片描述

在idea中导入springAMQP的jar包,分别编写了子模块生产者publisher,消费者consumer:

1.在publisher中运行测试代码:
在这里插入图片描述
2.在consumer中配置队列监听器并运行主类:
在这里插入图片描述

2.报错信息

先运行consumer主类再运行publisher测试类,查看队列信息的发送和接收:

运行主类时出现了以下报错:
在这里插入图片描述

3.解决方案

查看rabbitMQ是否存在该队列信息:
在这里插入图片描述
在publisher中与MQ服务器建立连接,创建对应队列即可:
在这里插入图片描述
具体代码如下:也就是官网中简单模型的hello world案例

当然,主机名,端口号,账户密码这些需要根据实际情况修改

public class PublisherTest {@Testpublic void testSendMessage() throws IOException, TimeoutException {// 1.建立连接ConnectionFactory factory = new ConnectionFactory();// 1.1.设置连接参数,分别是:主机名、端口号、vhost、用户名、密码factory.setHost("192.168.61.141");factory.setPort(5672);factory.setVirtualHost("/");factory.setUsername("root");factory.setPassword("123456");// 1.2.建立连接Connection connection = factory.newConnection();// 2.创建通道ChannelChannel channel = connection.createChannel();// 3.创建队列String queueName = "simple.queue";channel.queueDeclare(queueName, false, false, false, null);// 4.发送消息String message = "hello, rabbitmq!";channel.basicPublish("", queueName, null, message.getBytes());System.out.println("发送消息成功:【" + message + "】");// 5.关闭通道和连接channel.close();connection.close();}
}

4.查看解决之后的效果

运行测试类:
在这里插入图片描述
在这里插入图片描述
再次运行消费者主类:
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/486987.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

git 使用总结

文章目录 git merge 和 git rebasegit mergegit rebase总结 git merge 和 git rebase git merge git merge 最终效果说明: 假设有一个仓库情况如下,现需要进行 merge: merge 操作流程: merge 的回退操作: git reba…

【区块链】智能交易模式下的数据安全流通模型

【区块链】智能交易模式下的数据安全流通模型 写在最前面**区块链智能交易模式概述****数据安全流通的挑战****数据安全流通模型的核心要素****实现数据安全流通的区块链技术****区块链智能交易模式下数据安全流通模型的设计原则****数据安全流通模型的应用案例分析****面临的挑…

burpsuite插件编写之如何隐秘的划水

老板以为你在认真挖洞,没想到你居然在摸鱼哈哈哈哈。 一、开发环境准备 idea、jdk、maven 安装好即可 二、开发知识准备 有空可以看看下面的示例和api 官方各种示例代码:Burp extensions - PortSwigger 官方API文档:Generated Documentation (Untitled) 在burp的扩展那…

《图解密码技术》总结

一:首先在此介绍一些密码的常识: 1>不要使用保密的密码算法 2>使用低强度的密码比不进行任何加密更加危险 3>任何密码总有一天都会被破译 4>密码只是信息安全的一部分 二:逐章总结: 第一章:环游密码世…

黄海北部泥质沉积体地层界面如何划分?

黄海沉积物中存在北黄海泥M1、海阳东泥M2、老黄河口泥M3、南黄海中部泥M4和南黄海东部泥M5等泥质沉积,见下图。其中北黄海泥M1、海阳东泥M2和南黄海中部泥M4在空间上是连在一起的沉积体,从庙岛群岛起沿山东半岛北部向东绕过山东半岛东端向南延伸&#xf…

基于JAVA的公司货物订单管理系统 开源项目

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 客户管理模块2.2 商品维护模块2.3 供应商管理模块2.4 订单管理模块 三、系统展示四、核心代码4.1 查询供应商信息4.2 新增商品信息4.3 查询客户信息4.4 新增订单信息4.5 添加跟进子订单 五、免责说明 一、摘要 1.1 项目…

华为OD机试真题-CPU算力分配-2023年OD统一考试(C卷)--Python--开源

题目: ** ** 考察内容: 排序(sort)求和(sum) 数学转化 循环(从小开始)break 代码: """ 题目分析: a和b初始总算力不同 从A组中选出的算力尽可能小 交换以后,a和b的…

【C++精简版回顾】5.字符串

1.字符串的四种初始化方式 string str "ilove"; string str1("ilove"); string str2(str1); string str3 str1; 2.针对字符串的一些函数 &#xff08;1&#xff09;字符串长度 cout<<str.length()<<endl;&#xff08;2&#xff09;查找字…

SpringCloud-Gateway解决跨域问题

Spring Cloud Gateway是一个基于Spring Framework的微服务网关&#xff0c;用于构建可扩展的分布式系统。在处理跨域问题时&#xff0c;可以通过配置网关来实现跨域资源共享&#xff08;CORS&#xff09;。要解决跨域问题&#xff0c;首先需要在网关的配置文件中添加相关的跨域…

CondaValueError: Malformed version string ‘~‘: invalid character(s)

使用conda 安装一些库时出现以下报错&#xff1a; CondaValueError: Malformed version string ~: invalid character(s)尝试进行更新conda conda upgrade -n base conda或者如果是环境方面的问题&#xff0c; conda upgrade -n base -c defaults --override-channels conda如…

CUDA自学笔记001 CUDA编程模型、CUDA线程模型及其管理、CUDA内存模型及其管理

CUDA编程模型 我们使用CUDA_C语言进行CUDA编程&#xff0c; 1&#xff0c;CUDA编程模型提供了线程抽象接口用于控制GPU中的线程 2&#xff0c;CUDA编程模型提供了内存访问控制&#xff0c;我们可以实现主机和GPU设备内存的控制&#xff0c;我们可以实现CPU和GPU之间内存的数据传…

jquery 简介与解析

jQuery是一个快速、小巧且功能丰富的JavaScript库。它简化了诸如HTML文档遍历和操作、事件处理、动画以及Ajax操作等任务。jQuery的设计理念是“写得更少&#xff0c;做得更多”&#xff0c;这意味着通过jQuery&#xff0c;可以用更少的代码完成更多的工作。 主要特点&#xff…