RabbitMq传递对象

Love The Way You Lie 2022-05-08 06:14 218阅读 0赞

对象

public class Order implements Serializable {
    	private String no = null;
    	public String getNo() {
    		return no;
    	}
    	public void setNo(String no) {
    		this.no = no;
    	}
    }

生产者：

public void sendOrder(String no) {
    		rabbitTemplate.setConfirmCallback(this);
    		Order order = new Order();
    		order.setNo(no);
    		/* 消息ID */
                    CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());  
    		this.rabbitTemplate.convertAndSend("orderExchange", "topic.message", order, correlationData);  
    	}

消费者：

public void onMessage(Message message, Channel channel) throws Exception {
    		Order order=(Order)SerializationUtils.deserialize(message.getBody());
    		long id = message.getMessageProperties().getDeliveryTag();
    		System.out.println("===接收到的消息:" + order.getNo() + ",id：" + id);
    		channel.basicAck(id, false);
    	}

这里要引进lang3的包

<dependency>
    			<groupId>org.apache.commons</groupId>
    			<artifactId>commons-lang3</artifactId>
    			<version>3.8</version>
    		</dependency>

发表评论取消回复

表情：

评论列表（有 0 条评论，218人围观）

还没有评论，来说两句吧...

相关阅读

相关 RabbitMQ消息传递流程

*两个新名词** 本篇文章以上篇文章《[Rabbit的基础概念][Rabbit]》为基础，且在上篇文章的前提下又引入了两个新的概念： **连接( Connection...

喜欢ヅ旅行/ 2024年04月18日 20:32/ 0 赞/ 57 阅读

相关 RabbitMQ 七种消息传递形式

1. RabbitMQ 架构简介 2. 准备工作 3. 消息收发 3.1 Hello World 3.2 Work qu

古城微笑少年丶/ 2024年04月08日 11:47/ 0 赞/ 68 阅读

相关 RabbitMQ是如何实现消息传递的？

RabbitMQ是如何实现消息传递的？ RabbitMQ是一个开源的消息代理（Message Broker），它实现了高级消息队列协议（AMQP），用于在应用程序之间进行

男娘i/ 2024年03月03日 02:57/ 0 赞/ 87 阅读

相关 RabbitMQ 消息可靠性传递

1 简介什么是消息的可靠性投递，保证消息百分百发送到消息队列中去，保证mq节点成功接受消息。消息发送端需要接受到mq服务端接受到消息的确认应答。完善的消息补偿机制，发送

迷南。/ 2023年01月16日 02:48/ 0 赞/ 137 阅读

相关 android传递数据bundle封装传递map对象

转自:http://my.oschina.net/baishi/blog/182931 android开发默认情况下，通过Bundle bundle=new Bundle()

秒速五厘米/ 2022年08月09日 09:55/ 0 赞/ 260 阅读

相关 socket传递对象

怎样使用Java Socket来传输对象。首先需要一个普通的对象类，由于需要序列化这个对象以便在网络上传输，所以实现java.io.Serializable接口就是必不可

秒速五厘米/ 2022年05月28日 13:19/ 0 赞/ 167 阅读

相关对象的引用传递

在讲解对象引用传递之前，给大家两个简单的例子： -------------------- 例子1： public class Student{

叁歲伎倆/ 2022年05月21日 09:13/ 0 赞/ 178 阅读

相关 springMVC传递对象参数

基础类型如果传递的json数据为基础类型（Int，String等）的话，则只需要用@RequestParam标注方法中的参数就行了。 ajax代码 $.ajax

柔光的暖阳◎/ 2022年05月17日 10:28/ 0 赞/ 233 阅读

相关 RabbitMq传递对象

对象 public class Order implements Serializable { private String no = null;

Love The Way You Lie/ 2022年05月08日 06:14/ 0 赞/ 219 阅读

相关 RabbitMQ消息传递

首先，你要知道RabbitMQ基本的消息传递有几种第一：点对点，p2p方式，也就是单播模式，称为direct，我们要在消息队列queue中指定路由键Routing key，

太过爱你忘了你带给我的痛/ 2021年12月03日 13:41/ 0 赞/ 326 阅读