码迷,mamicode.com
首页 > 其他好文 > 详细

RabbitMQ中的RPC实现

时间:2018-07-08 15:40:06      阅读:152      评论:0      收藏:0      [点我收藏+]

标签:throws   ann   over   cep   print   group   class   throw   icp   

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实现

标签:throws   ann   over   cep   print   group   class   throw   icp   

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

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!