RabbitMQ 에서 가장 많이 사용 하 는 3 대 모드 인 스 턴 스 분석

이 글 은 RabbitMQ 에서 가장 자주 사용 하 는 3 대 모델 인 스 턴 스 분석 을 소개 합 니 다.이 글 은 예시 코드 를 통 해 매우 상세 하 게 소개 되 어 여러분 의 학습 이나 업무 에 대해 어느 정도 참고 학습 가 치 를 가지 고 있 으 므 로 필요 한 분 들 은 참고 하 시기 바 랍 니 다.
직접 모드

Direct Exchange 에 보 낸 모든 메 시 지 는 RouteKey 에서 지정 한 Queue 로 전 송 됩 니 다

Direct 모드 는 RabbitMQ 가 자체 적 으로 가지 고 있 는 Exchange:default Exchange 를 사용 할 수 있 기 때문에 Exchange 를 어떠한 바 인 딩(binding)작업 도 할 필요 가 없습니다

메시지 전달 시 RouteKey 가 완전히 일치 해 야 대기 열 에서 받 을 수 있 습 니 다.그렇지 않 으 면 이 메 시 지 는 버 려 집 니 다

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

public class DirectProducer {
  public static void main(String[] args) throws Exception {
    //1.      ConnectionFactory      
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    factory.setVirtualHost("/");
    factory.setUsername("guest");
    factory.setPassword("guest");

    //2.            
    Connection connection = factory.newConnection();

    //3.    Connection     Channel
    Channel channel = connection.createChannel();

    //4.   
    String exchangeName = "test_direct_exchange";
    String routingKey = "item.direct";

    //5.   
    String msg = "this is direct msg";
    channel.basicPublish(exchangeName, routingKey, null, msg.getBytes());
    System.out.println("Send message : " + msg);

    //6.     
    channel.close();
    connection.close();
  }
}

import com.rabbitmq.client.*;
import java.io.IOException;

public class DirectConsumer {

  public static void main(String[] args) throws Exception {
    //1.      ConnectionFactory      
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    factory.setVirtualHost("/");
    factory.setUsername("guest");
    factory.setPassword("guest");
    factory.setAutomaticRecoveryEnabled(true);
    factory.setNetworkRecoveryInterval(3000);
   
    //2.            
    Connection connection = factory.newConnection();

    //3.    Connection     Channel
    Channel channel = connection.createChannel();

    //4.   
    String exchangeName = "test_direct_exchange";
    String queueName = "test_direct_queue";
    String routingKey = "item.direct";
    channel.exchangeDeclare(exchangeName, "direct", true, false, null);
    channel.queueDeclare(queueName, false, false, false, null);

    //        ，         
    channel.queueBind(queueName, exchangeName, routingKey);

    //5.           
    Consumer consumer = new DefaultConsumer(channel) {
      @Override
      public void handleDelivery(String consumerTag, Envelope envelope,
                    AMQP.BasicProperties properties, byte[] body)
          throws IOException {
        String message = new String(body, "UTF-8");
        System.out.println(" [x] Received '" + message + "'");
      }
    };

    //6.    Channel        
    channel.basicConsume(queueName, true, consumer);

  }
}

 Send message : this is direct msg
 
 [x] Received 'this is direct msg'

Topic 모드
마스크 를 사용 하여 모호 한 매 칭 을 할 수 있 습 니 다.

기호'\#'는 하나 이상 의 단어 와 일치 합 니 다

기호'*'의 일치 가 많 지 않 고 적지 않 은 단어

예컨대

'log.\#'log.info.oa'와 일치 합 니 다

"log.*"는"log.erro"와 만 일치 합 니 다

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

public class TopicProducer {

  public static void main(String[] args) throws Exception {
    //1.      ConnectionFactory      
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    factory.setVirtualHost("/");
    factory.setUsername("guest");
    factory.setPassword("guest");

    //2.            
    Connection connection = factory.newConnection();

    //3.    Connection     Channel
    Channel channel = connection.createChannel();

    //4.   
    String exchangeName = "test_topic_exchange";
    String routingKey1 = "item.update";
    String routingKey2 = "item.delete";
    String routingKey3 = "user.add";

    //5.   
    String msg = "this is topic msg";
    channel.basicPublish(exchangeName, routingKey1, null, msg.getBytes());
    channel.basicPublish(exchangeName, routingKey2, null, msg.getBytes());
    channel.basicPublish(exchangeName, routingKey3, null, msg.getBytes());
    System.out.println("Send message : " + msg);

    //6.     
    channel.close();
    connection.close();
  }
}

import com.rabbitmq.client.*;
import java.io.IOException;

public class TopicConsumer {

  public static void main(String[] args) throws Exception {
    //1.      ConnectionFactory      
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    factory.setVirtualHost("/");
    factory.setUsername("guest");
    factory.setPassword("guest");
    factory.setAutomaticRecoveryEnabled(true);
    factory.setNetworkRecoveryInterval(3000);

    //2.            
    Connection connection = factory.newConnection();

    //3.    Connection     Channel
    Channel channel = connection.createChannel();

    //4.   
    String exchangeName = "test_topic_exchange";
    String queueName = "test_topic_queue";
    String routingKey = "item.#";
    channel.exchangeDeclare(exchangeName, "topic", true, false, null);
    channel.queueDeclare(queueName, false, false, false, null);

    //        ，         
    channel.queueBind(queueName, exchangeName, routingKey);

    //5.           
    Consumer consumer = new DefaultConsumer(channel) {
      @Override
      public void handleDelivery(String consumerTag, Envelope envelope,
                    AMQP.BasicProperties properties, byte[] body)
          throws IOException {
        String message = new String(body, "UTF-8");
        System.out.println(" [x] Received '" + message + "'");
      }
    };
    //6.    Channel        
    channel.basicConsume(queueName, true, consumer);

  }
}

Send message : this is topc msg

[x] Received 'this is topc msg'
[x] Received 'this is topc msg'

Fanout 모드
루트 키 를 처리 하지 않 고 간단하게 대기 열 을 교환기 에 연결 해서 교환기 에 보 내 는 메 시 지 는 이 교환기 와 연 결 된 모든 대기 열 에 전 송 됩 니 다.
팬 아웃 교환기 가 메 시 지 를 전달 하 는 것 이 가장 빠르다.

import com.rabbitmq.client.*;
import java.io.IOException;

public class FanoutConsumer {
  public static void main(String[] args) throws Exception {
    //1.      ConnectionFactory      
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    factory.setVirtualHost("/");
    factory.setUsername("guest");
    factory.setPassword("guest");
    factory.setAutomaticRecoveryEnabled(true);
    factory.setNetworkRecoveryInterval(3000);

    //2.            
    Connection connection = factory.newConnection();

    //3.    Connection     Channel
    Channel channel = connection.createChannel();

    //4.   
    String exchangeName = "test_fanout_exchange";
    String queueName = "test_fanout_queue";
    String routingKey = "item.#";
    channel.exchangeDeclare(exchangeName, "fanout", true, false, null);
    channel.queueDeclare(queueName, false, false, false, null);

    //        ，         
    channel.queueBind(queueName, exchangeName, routingKey);

    //5.           
    Consumer consumer = new DefaultConsumer(channel) {
      @Override
      public void handleDelivery(String consumerTag, Envelope envelope,
                    AMQP.BasicProperties properties, byte[] body)
          throws IOException {
        String message = new String(body, "UTF-8");
        System.out.println(" [x] Received '" + message + "'");
      }
    };

    //6.    Channel        
    channel.basicConsume(queueName, true, consumer);
  }
}

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
public class FanoutProducer {

  public static void main(String[] args) throws Exception {
    //1.      ConnectionFactory      
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    factory.setVirtualHost("/");
    factory.setUsername("guest");
    factory.setPassword("guest");

    //2.            
    Connection connection = factory.newConnection();

    //3.    Connection     Channel
    Channel channel = connection.createChannel();

    //4.   
    String exchangeName = "test_fanout_exchange";
    String routingKey1 = "item.update";
    String routingKey2 = "";
    String routingKey3 = "ookjkjjkhjhk";//  routingkey

    //5.   
    String msg = "this is fanout msg";
    channel.basicPublish(exchangeName, routingKey1, null, msg.getBytes());
    channel.basicPublish(exchangeName, routingKey2, null, msg.getBytes());
    channel.basicPublish(exchangeName, routingKey3, null, msg.getBytes());
    System.out.println("Send message : " + msg);

    //6.     
    channel.close();
    connection.close();
  }
}

Send message : this is fanout msg

[x] Received 'this is fanout msg'
[x] Received 'this is fanout msg'
[x] Received 'this is fanout msg'

이상 이 바로 본 고의 모든 내용 입 니 다.여러분 의 학습 에 도움 이 되 고 저 희 를 많이 응원 해 주 셨 으 면 좋 겠 습 니 다.