接上一篇:企业实战06_SSM整合ActiveMQ支持多种类型消息https://blog.csdn.net/weixin_40816738/article/details/100572147
1、StreamMessage java原始值数据流
2、MapMessage 键值对
3、TextMessage 字符串
4、ObjectMessage 一个序列化的java对象
5、BytesMessage 一个字节的数据流
此文章为企业实战的展示操作,如果有地方不懂请留言,我看到后,会进行统一回复,让我们一起进步,为自己加油!!!
项目名 | 项目说明 |
---|---|
ssm-activemq | 父工程,统一版本控制 |
producer | 生产者 |
consumer | 消费者 |
base-pojo | 公共实体类 |
base-dao | 公共接口,数据库连接 |
文章目录
- 七、测试验证
- 7.1. @Test 测试 先启动生产者,在启动消费者
- 7.2. @Test先启动消费者,在启动生产者
- 7.3. 浏览器测试不分前后
- 7.3.1 测试点对点场景
- 7.3.2 测试发布订阅场景
七、测试验证
7.1. @Test 测试 先启动生产者,在启动消费者
这种场景,生产者会把消息推送到MQ中存储,消费者再启动后,由监听拉取MQ消息,如果在指定的消息队列中有消息并且没有失效,就会被拉取,如果没有,则一直保持着这种接收消息的状态。
7.2. @Test先启动消费者,在启动生产者
这种场景,生产者会把消息推送到MQ中,由于消费者已经启动,由监听拉取MQ消息,很快在指定的消息队列中拉取消息。
7.3. 浏览器测试不分前后
7.3.1 测试点对点场景
测试链接 | 场景说明 |
---|---|
http://localhost:8080/queue/str | String类型消息传递 |
http://localhost:8080/queue/objList | List类型消息传递 |
http://localhost:8080/queue/map | Map类型消息传递 |
http://localhost:8080/queue/obj | Obj类型消息传递 |
7.3.2 测试发布订阅场景
测试链接 | 场景说明 |
---|---|
http://localhost:8080/topic/str | String类型消息传递 |
http://localhost:8080/topic/objList | List类型消息传递 |
http://localhost:8080/topic/map | Map类型消息传递 |
http://localhost:8080/topic/obj | Obj类型消息传递 |
本专栏项目下载链接:
下载方式 | 链接详细 |
---|---|
GitLab项目 | https://gitlab.com/gb-heima/ssm-activemq |
Git | git clone git@gitlab.com:gb-heima/ssm-activemq.git |
zip包 | https://gitlab.com/gb-heima/ssm-activemq/-/archive/master/ssm-activemq-master.zip |
Fork地址 | https://gitlab.com/gb-heima/ssm-activemq/-/forks/new |