zoukankan      html  css  js  c++  java
  • RabbitMQ学习以及与Spring的集成(三)

    本文介绍RabbitMQ与Spring的简单集成以及消息的发送和接收。

    在RabbitMQ的Spring配置文件中,首先需要增加命名空间。

    xmlns:rabbit="http://www.springframework.org/schema/rabbit"

    其次是模式文档,这里按1.0的来。

    xsi:schemaLocation="
         http://www.springframework.org/schema/rabbit
         http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd"

    配置connection-factory元素。

    <rabbit:connection-factory id="connectionFactory"
                                   username="mmq" password="mmq" host="192.168.1.138" port="5672" virtual-host="/vhost1" />

    配置connection-factory元素实际是注册一个org.springframework.amqp.rabbit.connection.CachingConnectionFactory实例。

    参数介绍:

    id:bean的id值。

    host:RabbitMQ服务器地址。默认值"localhost"。

    port:RabbitMQ服务端口,默认值"5672"。

    virtual-host:虚拟主机,默认是"/"。

    usernamepassword就是访问RabbitMQ服务的账户和密码了。

    channel-cache-size:channel的缓存数量。新版本默认是25。

    消息队列queue的配置。

     <!--定义queue queueTest -->
        <rabbit:queue name="queueTest" durable="true" auto-delete="false" exclusive="false"  />

    参数介绍:

    name:queue的名字。

    durable:是否为持久的。默认是true,RabbitMQ重启后queue依然存在。

    auto-delete:表示消息队列没有在使用时将被自动删除。默认是false。

    exclusive:表示该消息队列是否只在当前connection生效。默认false。

     交换器exchange的配置。

    <rabbit:direct-exchange name="exchangeTest" durable="true" auto-delete="false">
            <rabbit:bindings>
                <rabbit:binding queue="queueTest" key="queueTestKey"></rabbit:binding>
            </rabbit:bindings>
        </rabbit:direct-exchange>

    参数介绍:

    name:exchange的名字。

    durable:是否为持久的,默认为true,RabbitMQ重启后exhange依然存在。

    auto-delete:表示exchange在未被使用时是否自动删除,默认是false。

    key:queue在该direct-exchange中的key值。当消息发送给该direct-exchange中指定key为设置值时,消息将会转发给queue参数指定的消息队列。

    Spring为方便使用RabbitMQ服务,提供一个操作模板类:org.springframework.amqp.rabbit.core.RabbitTemplate。

    <rabbit:template id="amqpTemplate"  connection-factory="connectionFactory" exchange="exchangeTest" />

    配置也很简单。template还有其他的配置项,可以自己查看xsd文件中的说明。

    最后一个配置项是消息consumer。其实也可以叫做listener。简单的配置如下。

    <rabbit:listener-container connection-factory="connectionFactory">
            <rabbit:listener  queues="queueTest" ref="messageConsumer"/>
        </rabbit:listener-container>

    messageConsumer是一个简单bean类,可以用注解标识。

    @Component("messageConsumer")
    public class MessageConsumer implements MessageListener {
      public void onMessage(Message message) {}  
    }

    类作为消息监听器,必须实现接口MessageListener或者是接口ChannelAwareMessageListener。

    另一种配置方式是使用method参数,指定消息处理的方法,以org.springframework.amqp.core.Message类作为方法参数。

    配置完成并写好消息监听处理类后就可以尝试发送消息了。

    public class MessageProducer{
      @Resource
       private AmqpTemplate amqpTemplate;
    
       public void sendMessage(){
            Message message = MessageBuilder.withBody("hello rabbit".getBytes("utf-8"))
                        .setMessageId(System.currentTimeMillis()+"")
                        .build();
            this.amqpTemplate.send("queueTestKey", message);
    
       }  
    
    }

    消息监听方法。

    public void onMessage(Message message){
       String content = new String(message.getBody(),"utf-8");
       system.out.println(content);
    }

    消息内容发送时会被转换为字节数组,默认以UTF-8进行编码。如果想要发送对象信息,按照类实例的序列化和反序列化进行操作即可。

  • 相关阅读:
    快学Scala 第6章 对象
    Ch05 类
    Ch04 映射和元组
    Ch03 数组相关操作
    Ch02 控制结构和函数
    Ch01 基础
    28.创建对象两种方式、对象的方法、属性、获取属性值的两种方法、属性名含特殊符号时获取属性值的方法、添加属性及值的方法、删除属性的方法、使用方式、遍历对象属性for(var prop in obj)
    27.函数循环扩展作业、非常重要涉及编程思想(一天看一遍) 编程思想其实就是算法,、感悟、演算
    26 .闭包 、函数表达式在for中无法接受实时改变的变量、 在for里要将函数表达式封装成闭包才能接受实时变化的参数,并要将函数表达式return出去
    25.函数例题-预解析 作用域 、函数变量优先级、全局变量污染(直接在全局声明 、 函数里的变量没声明)但是函数里的变量没声明造成的全局变量污染有个前提,函数要被调用)
  • 原文地址:https://www.cnblogs.com/derry9005/p/6491215.html
Copyright © 2011-2022 走看看