本篇内容介绍了“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的使用方法”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注天达云网站,小编将为大家输出更多高质量的实用文章!