云服务器价格_云数据库_云主机【优惠】最新活动-搜集站云资讯

全站加速_平安企业邮箱后缀_9元

小七 141 0

全站加速_平安企业邮箱后缀_9元

RPC被称为远程过程调用,这是服务之间通信的常用方法。RabbitMQ还可以支持RPC,信息大数据,下面是中RabbitMQ-RPC的一般介绍。在本博客中,我们将重点介绍如何使用Spring提供的RabbitTemplate和AsyncRabbtTemplate来使用RabbitMQ的RPC。

RabbitTemplate提供了上述方法来支持发送和接收消息。在方法定义中可以找到,可以通过提供必要的值(如exchange、routingkey和correlationData)来调用方法。客户机使用相关数据来验证来自服务器的响应。

要深入了解spring对Send和Receive所做的操作,我们可以通过将replyAddress设置为null或使用FastReplyTo设置为true来发现它支持直接回复。

如中所述

使用直接回复,RPC客户机应该:

从伪队列消费amq.rabbitmq.reply文件-至无确认模式。不需要首先声明这个"队列",尽管客户机可以这样做,如果它愿意的话。

客户机可以从amq.rabbitmq.reply文件-直接

rabbitmplate通过在PendingReply中从队列获取消息来检索消息。如果你看一下PendingReply的定义,大数据的应用,大数据中心是什么,你会发现这个队列是一个BlockingQueue,这意味着它在检索元素时会等待队列变为非空,大淘客网站,在存储元素时会等待队列中的空间变为可用,RabbitTemplate不支持RPC的异步化案例

Spring为Spring AMQP 1.6以来的异步案例提供AsyncRabbitTemplate,以允许发送和接收操作的调用者(sendAndReceive,convertSendAndReceive)不阻塞。

返回ListenableFuture的子类,云服务器怎么样,您只需添加ListenableFutureCallback即可处理结果。