基于ActiveMQ的请求-应答模式
时间:2022-07-24
本文章向大家介绍基于ActiveMQ的请求-应答模式,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
基于ActiveMQ的请求-应答模式
一. 使用场景
基于ActiveMQ的请求-应答模式,相当于通过消息队列,请求端注册了一个异步回调,在发送消息时指定回调消息的目的地和关联的id,这样应答端在收到请求消息时,可以在处理后,将处理结果的应答消息发送到回调的目的地中。
二. 代码实例
首先是请求和响应的消息定义:
/**
* @Auther: ZhangShenao
* @Date: 2019/2/12 18:40
* @Description:请求消息
*/
@Getter
@Setter
@ToString
public class RequestDto {
//业务id
private String uid;
//业务数据
private String payload;
}
/**
* @Auther: ZhangShenao
* @Date: 2019/2/12 18:33
* @Description:响应消息
*/
@Getter
@Setter
@ToString
public class ResponseDto {
//业务id
private String uid;
//处理结果
private boolean success;
}
请求端:
/**
* @Auther: ZhangShenao
* @Date: 2019/2/12 18:09
* @Description:Request-Response模式的请求端
*/
@Service
public class Producer {
//保存所有请求的业务id和响应结果
private static final Map<String, Boolean> replies = new ConcurrentHashMap<>();
@Autowired
@Qualifier(Constants.JMS_QUEUE_TEMPLATE)
private JmsTemplate queueTemplat;
public void sendMessage(RequestDto dto) {
queueTemplat.send(Constants.QueueNames.REQUEST_QUEUE, session -> {
TextMessage message = session.createTextMessage(dto.getPayload());
//设置消息关联id,将请求和应答消息关联起来
message.setJMSCorrelationID(dto.getUid());
//设置消息回复的目的地
message.setJMSReplyTo(new ActiveMQQueue(Constants.QueueNames.RESPONSE_QUEUE));
//记录发送的请求
replies.putIfAbsent(dto.getUid(), false);
return message;
});
}
@JmsListener(destination = Constants.QueueNames.RESPONSE_QUEUE, containerFactory = Constants.QUEUE_LISTENER_CONTAINER_FACTORY)
public void onReply(ResponseDto dto) {
replies.put(dto.getUid(), dto.isSuccess());
System.err.println("On Reply: " + dto);
}
}
响应端:
/**
* @Auther: ZhangShenao
* @Date: 2019/2/12 18:42
* @Description:Request-Response模式的响应端
*/
@Service
public class Consumer {
@Autowired
@Qualifier(Constants.JMS_QUEUE_TEMPLATE)
private JmsTemplate queueTemplat;
@JmsListener(destination = Constants.QueueNames.REQUEST_QUEUE, containerFactory = Constants.QUEUE_LISTENER_CONTAINER_FACTORY)
public void onRequest(TextMessage message) throws JMSException {
//获取消息回复目的地和关联id,向回复目的地发送回复消息
Destination replyTo = message.getJMSReplyTo();
ResponseDto response = new ResponseDto();
response.setUid(message.getJMSCorrelationID());
response.setSuccess(true);
queueTemplat.convertAndSend(replyTo,response);
}
}
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 牛客网-从头到尾打印链表
- 牛客网-重建二叉树
- 牛客网-旋转数组的最小数字
- 别再暴力匹配字符串了,高效的KMP,才是真的香
- 一文透析SpringCloud,关于Bus消息总线,总算梳理清楚了
- LeetCode 102. 二叉树的层序遍历
- 剑指Offer LeetCode 面试题10- II. 青蛙跳台阶问题
- 剑指Offer LeetCode 面试题10- I. 斐波那契数列
- 蓝桥杯 1的个数
- 蓝桥杯-试题 算法训练 数据交换
- 解决mysql导入新数据库大小写问题(Table 'zup.Domain_System' doesn't exist)
- 蓝桥杯vip试题 报时助手
- 蓝桥杯-基础练习 查找整数
- 蓝桥杯-基础练习 数列排序
- 无线网络-何为ISM频段?