结合Spring，运行RabbitMQ

RabbitMQ是用erlang实现的消息队列系统，遵循AMQP（高级消息队列协议）协议。性能还有可扩展性优于其他相似的框架，当然，新星kafka也不错，大家可以上网查一下各种MQ框架的优缺点。

参考一下其他文章：http://blog.csdn.net/linsongbin1/article/details/47781187

RabbitMQ主要有三种交换器：direct、fanout、topic

direct就是一对一传输

fanout就是匹配传输

topic就是主题分发传输

还是看代码吧

maven构建：pom.xml

    4.0.0

    com.xin
    com.xin.rabbitmq
    1.0-SNAPSHOT

    
        
        3.2.8.RELEASE
        
        1.6.6
        1.2.12
        
        4.10
    

    
        
        
            org.springframework
            spring-core
            ${spring.version}
        
        
            org.springframework
            spring-webmvc
            ${spring.version}
        
        
            org.springframework
            spring-context
            ${spring.version}
        
        
            org.springframework
            spring-context-support
            ${spring.version}
        
        
            org.springframework
            spring-aop
            ${spring.version}
        
        
            org.springframework
            spring-aspects
            ${spring.version}
        
        
            org.springframework
            spring-tx
            ${spring.version}
        
        
            org.springframework
            spring-jdbc
            ${spring.version}
        
        
            org.springframework
            spring-web
            ${spring.version}
        

        
        
            junit
            junit
            ${junit.version}
            test
        

        
        
        
            log4j
            log4j
            ${log4j.version}
        
        
            org.slf4j
            slf4j-api
            ${slf4j.version}
        
        
            org.slf4j
            slf4j-log4j12
            ${slf4j.version}
        
        

        
        
            org.springframework
            spring-test
            ${spring.version}
            test
        

        
        
            org.springframework.amqp
            spring-rabbit
            1.3.5.RELEASE
        

        
            javax.validation
            validation-api
            1.1.0.Final
        

        
            org.hibernate
            hibernate-validator
            5.0.1.Final
        

    
    
        
            
                src/main/resources
                ${basedir}/target/classes
                
                    **/*.properties
                    **/*.xml
                
                true
            
            
                src/main/resources
                ${basedir}/target/resources
                
                    **/*.properties
                    **/*.xml
                
                true
            
        

        
            
                org.apache.maven.plugins
                maven-compiler-plugin
                
                    1.6
                    1.6
                    UTF-8
                
            
            
                org.apache.maven.plugins
                maven-war-plugin
                2.1.1
                
                    ${warExcludes}
                
            
            
                org.apache.maven.plugins
                maven-surefire-plugin
                2.4.3
                
                    true
                
            
            
                true
                org.apache.maven.plugins
                maven-source-plugin
                
                    
                        attach-sources
                        
                            jar
                        
                    
                
            
            
                org.apache.maven.plugins
                maven-resources-plugin
                
                    UTF-8
                
            
        
    

log4j的配置文件：log4j.properties

log4j.rootLogger=DEBUG,Console,Stdout

#Console
log4j.appender.COnsole=org.apache.log4j.ConsoleAppender
log4j.appender.Console.layout=org.apache.log4j.PatternLayout
log4j.appender.Console.layout.COnversionPattern=%d [%t] %-5p [%c] - %m%n

log4j.logger.java.sql.ResultSet=INFO
log4j.logger.org.apache=INFO
log4j.logger.java.sql.COnnection=DEBUG
log4j.logger.java.sql.Statement=DEBUG
log4j.logger.java.sql.PreparedStatement=DEBUG

log4j.appender.Stdout = org.apache.log4j.DailyRollingFileAppender
log4j.appender.Stdout.File = E://logs/log.log
log4j.appender.Stdout.Append = true
log4j.appender.Stdout.Threshold = DEBUG
log4j.appender.Stdout.layout = org.apache.log4j.PatternLayout
log4j.appender.Stdout.layout.COnversionPattern= %-d{yyyy-MM-dd HH:mm:ss}  [ %t:%r ] - [ %p ]  %m%n

spring的配置文件：application.xml

生产端：MessageProducer

package com.xin.producer;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * Created by lhx on 2016/9/5 9:56
 *
 * @Description
 */
@Service
public class MessageProducer {

    private Logger logger = LoggerFactory.getLogger(MessageProducer.class);

    @Resource
    private AmqpTemplate amqpTemplate;

    public void sendMessage(Object message){
        logger.info("to send message:{}",message);
        amqpTemplate.convertAndSend("queueTestKey",message);
    }
}

package com.xin.consumer;

import com.xin.producer.MessageProducer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * Created by lhx on 2016/9/5 9:57
 *
 * @Description 消费接收
 */
public class MessageConsumer implements MessageListener {

    private Logger logger = LoggerFactory.getLogger(MessageConsumer.class);

    @Override
    public void onMessage(Message message) {
        logger.info("receive message:{}",message);
        System.out.println(new String(message.getBody()));
    }

    public static void main(final String... args) throws Exception {
        AbstractApplicationContext ctx = new ClassPathXmlApplicationContext("application.xml");
        MessageProducer messageProducer = (MessageProducer) ctx.getBean("messageProducer");
        messageProducer.sendMessage("-------------hello,xin3453465465467456456456^^^^^^66666!");
        Thread.sleep(1000);
        ctx.destroy();
    }

}

运行main函数，服务端推消息到客户端，客户端就会收到message，打印出来。

2016-09-06 10:29:27,659 [main] INFO  [com.xin.producer.TopicProducer] - to send message:++++++++++++++++++hello,xin3453465465467456456456^^^^^^66666!hello,xin
2016-09-06 10:29:27,676 [SimpleAsyncTaskExecutor-1] DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - Received message: (Body:'++++++++++++++++++hello,xin3453465465467456456456^^^^^^66666!hello,xin'MessageProperties [headers={}, timestamp=null, messageId=null, userId=null, appId=null, clusterId=null, type=null, correlatiOnId=null, replyTo=null, cOntentType=text/plain, cOntentEncoding=UTF-8, cOntentLength=0, deliveryMode=PERSISTENT, expiration=null, priority=0, redelivered=false, receivedExchange=topicExchange, receivedRoutingKey=info.debug, deliveryTag=1, messageCount=0])
(Body:'++++++++++++++++++hello,xin3453465465467456456456^^^^^^66666!hello,xin'MessageProperties [headers={}, timestamp=null, messageId=null, userId=null, appId=null, clusterId=null, type=null, correlatiOnId=null, replyTo=null, cOntentType=text/plain, cOntentEncoding=UTF-8, cOntentLength=0, deliveryMode=PERSISTENT, expiration=null, priority=0, redelivered=false, receivedExchange=topicExchange, receivedRoutingKey=info.debug, deliveryTag=1, messageCount=0])
++++++++++++++++++hello,xin3453465465467456456456^^^^^^66666!hello,xin

其他交换器的实现类似，请参考我的git项目：https://github.com/888xin/rabbitmq