rabbitMQ學習筆記(六) topic類型消息。

上一節中使用了消息路由，消費者可以選擇性的接收消息。 但是這樣還是不夠靈活。 

比如某個消費者要訂閱娛樂新聞消息 。 包括新浪、網易、騰訊的娛樂新聞。那么消費者就需要綁定三次，分別綁定這三個網站的消息類型。 如果新聞門戶更多了，那么消費者將要綁定個更多的消息類型， 其實消費者只是需要訂閱娛樂新聞，不管是哪個網站的新聞，都需要。 那么在rabbitMQ中可以使用topic類型。 模糊匹配消息類型。

模糊匹配中的 *代表一個  #代表零個或多個

示例：

package com.zf.rabbitmq06;

import java.io.IOException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ConsumerCancelledException;
import com.rabbitmq.client.QueueingConsumer;
import com.rabbitmq.client.QueueingConsumer.Delivery;
import com.rabbitmq.client.ShutdownSignalException;

/**
 * 接收消息
 * @author zhoufeng
 *
 */
public class Recv06_01 {

    public static void main(String[] args) throws IOException, ShutdownSignalException, ConsumerCancelledException, InterruptedException {
        
        ConnectionFactory connFac = new ConnectionFactory() ;
        
        connFac.setHost("127.0.0.1");
        
        Connection conn = connFac.newConnection() ;
        
        Channel channel = conn.createChannel() ;
        
        
        String exchangeName = "exchange03";
        
        channel.exchangeDeclare(exchangeName, "topic") ;
        
        String queueName = channel.queueDeclare().getQueue() ;
        
        //第三個參數就是type，這里表示只接收type01類型的消息。
        channel.queueBind(queueName, exchangeName, "#.type01") ;
        
        
        //配置好獲取消息的方式
        QueueingConsumer consumer = new QueueingConsumer(channel) ;
        channel.basicConsume(queueName, true, consumer) ;
        
        //循環獲取消息
        while(true){
            
            //獲取消息，如果沒有消息，這一步將會一直阻塞
            Delivery delivery = consumer.nextDelivery() ;
            
            String msg = new String(delivery.getBody()) ;  
            
            System.out.println("received message[" + msg + "] from " + exchangeName);
        }
        
    }
    
}

package com.zf.rabbitmq06;

import java.io.IOException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**
 * 發送消息
 * @author zhoufeng
 *
 */
public class Sender06 {
    
    public static void main(String[] args) throws IOException {
        
        ConnectionFactory connFac = new ConnectionFactory() ;
        
        //RabbitMQ-Server安裝在本機，所以直接用127.0.0.1
        connFac.setHost("127.0.0.1");
        
        //創建一個連接
        Connection conn = connFac.newConnection() ;
        
        //創建一個渠道
        Channel channel = conn.createChannel() ;
        
        String exchangeName = "exchange03";
        
        String messageType = "fs.type01";
        
        channel.exchangeDeclare(exchangeName, "topic") ;
        
        //定義Queue名
        String msg = "Hello World!";
        
        //發送消息
        channel.basicPublish( exchangeName , messageType , null , msg.getBytes());
        
        System.out.println("send message[" + msg + "] to "+ exchangeName +" success!");
        
        channel.close(); 
        conn.close(); 
        
    }

}

使用topic之后 。不管Sender端發送的消息類型是fs.type01 還是 xx.type01 還是 type01 ，消費者都會收到消息