具體如果安裝rabbitmq在本例子中不涉及，主要講解在springboot中如果傳送和接收rabbitmq訊息。

1.新增依賴

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

2.spring-rabbitmq 配置
本示例中使用了maven的filter
開發環境:
#rabbitMq配置

spring.rabbitmq.addresses=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=admin
spring.rabbitmq.virtual-host=/
spring.rabbitmq.exchange=site
spring.rabbitmq.createTopic=dev.gov.site.createormodify
spring.rabbitmq.changeTopic=dev.gov.site.statuschange

在application.properties檔案中：
#rabbitMq配置
spring.rabbitmq.a[email protected]@
[email protected]@
[email protected]@
[email protected]@
[email protected]@
[email protected]@
[email protected]@
[email protected]@

3.使用java配置rabbitmq具體細節

@Configuration
@ComponentScan
 
("com.trs.comms.amqp")
@ConfigurationProperties(prefix = "spring.rabbitmq")
public class CommsAmqpAutoConfiguration {

    private String exchange;
    private String createTopic;
    private String changeTopic;

    //構造ConnectionFactory 
    @Bean
    @ConfigurationProperties(prefix = "spring.rabbitmq")
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory factory = new CachingConnectionFactory();
        factory.setPublisherConfirms(Boolean.TRUE);
        return factory;
    }

    @Bean
    @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
    public RabbitTemplate rabbitTemplate() {
        return new RabbitTemplate(connectionFactory());
    }

    //指定從哪個exchange接收資料
    @Bean
    public TopicExchange topicExchange() {
        return new TopicExchange(exchange);
    }

    // 持久化佇列
    @Bean
    public Queue queue() {
        return new Queue("site", true);
    }

    //繫結佇列，並接收指定topic的資料
    @Bean
    public Binding bindingCreate() {
        return BindingBuilder.bind(queue()).to(topicExchange()).with(createTopic);
    }

    @Bean
    public Binding bindingChange() {
        return BindingBuilder.bind(queue()).to(topicExchange()).with(changeTopic);
    }

    //設定監聽
    @Bean
    public SimpleMessageListenerContainer messageContainer(ConnectionFactory connectionFactory, AmqpConsumer amqpConsumer) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
        container.setQueues(queue());
        container.setExposeListenerChannel(true);
        container.setMaxConcurrentConsumers(1);
        container.setConcurrentConsumers(1);
        container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
        //設定監聽器，執行具體的業務
        container.setMessageListener(amqpConsumer);
        return container;
    }

    public void setExchange(String exchange) {
        this.exchange = exchange;
    }

    public void setCreateTopic(String createTopic) {
        this.createTopic = createTopic;
    }

    public void setChangeTopic(String changeTopic) {
        this.changeTopic = changeTopic;
    }
}

4.具體監聽器：

/**
 * Description: 訊息監聽
 */
@Component
public class AmqpConsumer implements ChannelAwareMessageListener{

    private static final Log logger = LogFactory
            .getLog(AmqpConsumer.class);

    private final AmqpSiteService amqpSiteServiceImpl;

    @Autowired
    public AmqpConsumer(AmqpSiteService amqpSiteServiceImpl) {
        this.amqpSiteServiceImpl = amqpSiteServiceImpl;
    }


    @Override
    public void onMessage(Message message, Channel channel) throws Exception {
        try {
            //具體業務
            amqpSiteServiceImpl.doWithSite(new String(message.getBody(), "UTF-8"));

//手動應答，告訴rabbitmq我業務執行完成，訊息可以丟棄了
           channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
            logger.info("站點同步成功！");
        } catch (Exception e) {
            throw new RuntimeException("站點同失敗！！" + e);
        }
    }
}

5.測試用例

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = CommsISearchConfiguration.class)
public class AmqpTest {

    @Autowired
    public RabbitTemplate rabbitTemplate;

    @Test
    public void testSend() {
        String siteData = "{" +
                "\"TYPE\": 11," +
                "\"DATA\":{" +
                "\"HASCHILDREN\":\"true\"," +
                "\"OPERTIME\":\"\"," +
                "\"CRTIME\":\"2017-06-14 19:22:05\"," +
                "\"MEDIATYPE\":\"1\"," +
                "\"TRUENAME\":\"劉珍華\"," +
                "\"ISSUBSCRIBE\":\"1\"," +
                "\"STATUS\":\"0\"," +
                "\"DATAPATH\":\"chengdushi1\"," +
                "\"MPID\":\"89011234567890\"," +
                "\"SCHEDULE\":\"0\"," +
                "\"CHNLOUTLINETEMP\":\"641\"," +
                "\"ISDISTRIBUTABLE\":\"1\"," +
                "\"SITENAME\":\"成都市\"," +
                "\"OUTLINETEMPLATE\":\"250\"," +
                "\"ATTRIBUTE\":\"PUBLISHLIMIT=&PUBSTARTDATE=\"," +
                "\"CHNLDATAPATH\":\"chengdushi2\"," +
                "\"PUBLISHPRO\":\"1\"," +
                "\"SITEORDER\":\"188\"," +
                "\"CLASSIFICATIONID\":\"95\"," +
                "\"SITEID\":\"176\"," +
                "\"LASTMODIFYTIME\":\"2017-08-31 16:00:35\"," +
                "\"SITETYPE\":\"4\"," +
                "\"VIEWINFOID\":\"111\"," +
                "\"DETAILTEMPLATE\":\"446\"," +
                "\"SITEDESC\":\"成都市\"," +
                "\"ISMOBILE\":\"0\"," +
                "\"PARENTID\":\"0\"," +
                "\"ISPUSHABLE\":\"1\"," +
                "\"CRUSER\":\"dev\"" +
                "}" +
                "}";

        rabbitTemplate.convertAndSend("site", "dev.gov.site.createormodify", siteData);
    }

}