我在上一节讲述了如何使用Rabbitmq图形化界面在我们学习这个的基础使用,然后我们现在就要做的就是用java进行rabbitmq操作
首先在黑马课上有一个mq-demo文件这个资料,各位可以去微信程序里面下载对应资料包,然后会在百度网盘里
链接:https://pan.baidu.com/s/1VFdBOQYZVACxUBkzBuLVHA
提取码:nefi
这个就是这个demo,是一个分布式微服务框架的文件,然后,我们放到我们idea里面以后就直接开始进行以下操作即可
我们在这个publish这个模块的这个application.yml里面添加对应的spring配置
logging: pattern: dateformat: MM-dd HH:mm:ss:SSS spring: rabbitmq: host: localhost port: 5672 virtual-host: /hmall username: hmall password: 123
这些是整个文件对应的代码不需要删除(直接copy),当然这个是基于windows系统下,你的host是localhost,如果是虚拟机,填写主机地址,用户名和密码自己写自己的
然后我们就可以开始写java代码了,在这里我们写一个单元测试,在publisher目录下这个test文件里面创建一个com.itheima.publisher
然后就可以开始书写了,类名自己创建
package com.itheima.publisher; import org.junit.jupiter.api.Test; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; /** * 功能: * 作者:LiCooer * 日期:2024/4/8 16:22 */ @SpringBootTest public class SpringAmqpTest { @Autowired private RabbitTemplate rabbitTemplate; @Test void testSendMessage2Queue() { String queueName = "simple.queue"; String msg = "hello , amqp!"; rabbitTemplate.convertAndSend(queueName , msg); } }
这个就是我们对应的java代码,然后就可以单元测试运行
如果出现了问题直接老方法,google,chatgpt,或者在评论写出自己的问题
这样我们就可以看到了,至此,本文结束了,你在本篇文章需要确保学会了如果用java代码传递消息
标签:java,com,菜菜,RabbitMQ,host,springframework,org,import,第二篇 From: https://www.cnblogs.com/codeforceshobby/p/18122273