首页 > 其他 > 详细

RabbitMQ中的RPC实现

时间:2018-07-08 15:10:51      阅读:232      评论:0      收藏:0      [点我收藏+]

1、先上例子:

pom依赖:

<dependencies>
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>4.6.0</version>
</dependency>
</dependencies>

 

 1         DefaultConsumer c = new DefaultConsumer(channel) {
 2             @Override
 3             public void handleDelivery(String consumerTag, Envelope envelope, BasicProperties properties, byte[] body)
 4                     throws IOException {
 5                 System.out.println(new String(body));
 6 
 7                 AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder();
 8                 builder.correlationId(properties.getCorrelationId());
 9                 AMQP.BasicProperties prop = builder.build();
10 
11                 channel.basicPublish("", properties.getReplyTo(), prop, (new String(body) + "-回复").getBytes());
12 
13             }
14         };
   <dependencies>
        <dependency>
            <groupId>com.rabbitmq</groupId>
            <artifactId>amqp-client</artifactId>
            <version>4.6.0</version>
        </dependency>
    </dependencies>

  

RabbitMQ中的RPC实现

原文:https://www.cnblogs.com/dairongsheng/p/9280037.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!