rabbitmq的使用方法
本篇内容介绍了“rabbitmq的使用方法”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
1、登录管理员界面
http://122.51.74.196:15672/
用户名:guest
密码:guest
2、消息发送程序设置
添加pom依赖包
<dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit-test</artifactId> <scope>test</scope> </dependency>
实现消息
@SpringBootTest public class mq { @Autowired RabbitTemplate rabbitTemplate; /** * 发送消息 */ @Test public void sendMsg(){ rabbitTemplate.convertAndSend("com.springboot.exchange","com.springboot.mq","我是张三"); Map<String,Object> hash = new HashMap<String, Object>(); hash.put("megkey",Arrays.asList("121",12,"",21)); rabbitTemplate.convertAndSend("com.springboot.exchange","com.springboot.mq",hash); } /** * 接受消息 */ @Test public void getMsg(){ Object mqmsg = rabbitTemplate.receiveAndConvert("com.springboot.mq"); System.out.println(mqmsg.toString()); } }
“rabbitmq的使用方法”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站,小编将为大家输出更多高质量的实用文章!