activeMQ 传递数据,只能用基本类型,只有几种,其他的要序列化
2017-09-05 15:00
393 查看
我的做法,如果是用数组,集合,对象的话就做出json传递,传过去,如果是数组,集合就使用jsonutil工具,变成list,对象的话就转回对象;
数据简单,我就直接 用textMessage 传
如果数据复杂
就用session.createMapMessage();
生产
@Override
public JKResult delContractById(final String id) {
contractProductService.deleteProductByContractId(id);
contractDao.delContractById(id);
jmsTemplate.send(deleDestination, new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
MapMessage map = session.createMapMessage();
String json = JsonUtils.objectToJson(id);
map.setString("id", json);
return map;
}
});
return JKResult.ok();
}消费
try {
if(mapMessage.getString("ids") !=null||!"".equals(mapMessage.getString("ids"))){
String ids = (String) mapMessage.getObject("ids");
List<String> list = JsonUtils.jsonToList(ids, String.class);
for (String id : list) {
Thread.sleep(1000);
solrServer.deleteById(id);
solrServer.commit();
}
}
数据简单,我就直接 用textMessage 传
如果数据复杂
就用session.createMapMessage();
生产
@Override
public JKResult delContractById(final String id) {
contractProductService.deleteProductByContractId(id);
contractDao.delContractById(id);
jmsTemplate.send(deleDestination, new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
MapMessage map = session.createMapMessage();
String json = JsonUtils.objectToJson(id);
map.setString("id", json);
return map;
}
});
return JKResult.ok();
}消费
try {
if(mapMessage.getString("ids") !=null||!"".equals(mapMessage.getString("ids"))){
String ids = (String) mapMessage.getObject("ids");
List<String> list = JsonUtils.jsonToList(ids, String.class);
for (String id : list) {
Thread.sleep(1000);
solrServer.deleteById(id);
solrServer.commit();
}
}
相关文章推荐
- 基本数据类型的包装类型作为参数传递,以及其他引用类型作为参数传递,以及List中值的交换的一些问题
- 基本数据类型的包装类型作为参数传递,以及其他引用类型作为参数传递,以及List中值的交换的一些问题
- 基本数据类型的包装类型作为参数传递,以及其他引用类型作为参数传递,以及List中值的交换的一些问题
- 基本数据类型的包装类型作为参数传递,以及其他引用类型作为参数传递,以及List中值的交换的一些问题
- 基本数据类型的包装类型作为参数传递,以及其他引用类型作为参数传递,以及List中值的交换的一些问题
- 基本数据类型的包装类型作为参数传递,以及其他引用类型作为参数传递,以及List中值的交换的一些问题
- 基本数据类型的包装类型作为参数传递,以及其他引用类型作为参数传递,以及List中值的交换的一些问题
- 基本数据类型的包装类型作为参数传递,以及其他引用类型作为参数传递,以及List中值的交换的一些问题
- 基本数据类型的包装类型作为参数传递,以及其他引用类型作为参数传递,以及List中值的交换的一些问题
- JAVA基础 day23 IO流的其他类 (对象的序列化 管道流 RandomAccessFile类(随机读取文件) DateStream(操作基本数据类型的流) 操作数组的流 )字符编码问题
- SQL_VARIANT_PROPERTY 返回有关 sql_variant 值的基本数据类型和其他信息
- Android开发:使用序列化接口Parcelable、Serializable实现Activity间传递复杂数据类型参数
- Parcelable 与Serializable(两种序列化方式用于传输非基本类型的数据)
- 基本数据类型和引用数据类型参数的传递
- AIDL进程间传递复杂数据类型—AIDL传递其他AIDL接口
- Android JNI和NDK学习(08)--JNI实例一 传递基本类型数据
- c++primer第二章“c++定义了几种基本类型,还提供了可用于自定义数据类型的机制,此外,我们还能修改已有的类型以形成复合类型”
- JS开发中基本数据类型具体有哪几种
- 2013年8月17日、二维数组定义的格式|用java表现一个描述小汽车|基本数据类型参数传递|
- 基本数据类型参数传递与引用数据类型参数传递区别