지역 사회 배우다 도구 라이브러리 여가
찾다
한국어
집 > Java > java지도 시간 > SpringBoot는 RabbitMq를 어떻게 통합하나요?

SpringBoot는 RabbitMq를 어떻게 통합하나요?

WBOY
풀어 주다： 2023-05-25 10:00:38
앞으로
811명이 탐색했습니다.

SpringBoot는 실제로 RabbitMq를 통합합니다

spring-boot-starter-amqp

AMQP(Advanced Message Queuing Protocol)는 메시지 미들웨어를 위한 플랫폼 중립적 유선 프로토콜입니다. Spring AMQP 프로젝트는 AMQP 기반 메시징 솔루션 개발에 핵심 Spring 개념을 적용합니다. Spring Boot는 spring-boot-starter-amqp "Starter"를 포함하여 RabbitMQ를 통해 AMQP 작업에 대한 몇 가지 편의를 제공합니다.

RabbitMQ를 springboot와 통합하는 것은 매우 간단합니다. 아주 약간의 구성만으로 사용한다면 springboot는 spring-boot-starter-amqp 프로젝트에서 메시지에 대한 다양한 지원을 제공합니다.

종속성 추가

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
로그인 후 복사

RabbitMQ는 AMQP 프로토콜을 기반으로 하는 가볍고 안정적이며 확장 가능하고 휴대 가능한 메시지 브로커입니다. Spring은 AMQP 프로토콜을 통해 통신하기 위해 RabbitMQ를 사용합니다.

속성 구성

RabbitMQ 구성은 외부 구성 속성 spring.rabbitmq.*에 의해 제어됩니다. 예를 들어 다음 섹션에서 다음 application.properties를 선언할 수 있습니다. 

spring.rabbitmq.host = localhost
 spring.rabbitmq.port = 5672
 spring.rabbitmq.username = guest
 spring.rabbitmq.password
로그인 후 복사

빠르게 시작하기

1. 대기열 구성 

package com.example.rabbitmqdemo.config;


import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * RabbitMQ 配置类
 *
 * @author itguang
 * @create
@Configuration
public class RabbitConfig

    @Bean
    public Queue queue(){
        return new Queue("hello");
    }
}
로그인 후 복사

2 Sender

rabbitTemplate은 springboot에서 제공하는 기본 구현입니다. 

package com.example.rabbitmqdemo.rabbitmq;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.util.Date;

/**
 * 消息发送者
 *
 * @author itguang
 * @create

@Component
public class HelloSender


    @Autowired
    private AmqpTemplate amqpTemplate;


    public void send(){
        String context = "hello----"+LocalDateTime.now();
        System.out.println("send:"+context);
        //往名称为 hello 的queue中发送消息
        this.amqpTemplate.convertAndSend("hello",context);
    }

}
로그인 후 복사
테스트

package com.example.rabbitmqdemo.rabbitmq;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 消息接受者
 *
 * @author itguang
 * @create

@Component
@RabbitListener(queues = "hello") //监听 名称为 hello 的queue
public class HelloReceiver

    //消息处理器
    @RabbitHandler
    public void process(String message){
        System.out.println("Receiver:"+message);

    }


}
로그인 후 복사

콘솔 출력 결과 보기

package com.example.rabbitmqdemo;

import com.example.rabbitmqdemo.rabbitmq.HelloSender;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitmqdemoApplicationTests

    @Autowired
    HelloSender helloSender;

    @Test
    public void contextLoads() {
        helloSender.send();

    }
}
로그인 후 복사

일대다 전송: 하나의 발신자 및 여러 수신자

수신측에서는 Receiver1과 Receiver2 두 개를 등록했으며, 위 코드를 약간 수정했습니다. 송신측 조인 매개변수 수, 수신측은 수신된 매개변수를 인쇄합니다. 다음은 테스트 코드입니다. 두 수신측의 실행 효과를 관찰하기 위해 100개의 메시지를 보냅니다

hello2라는 대기열을 추가

  • send:hello----2018-04-21T11:29:47.739
Receiver:hello----2018-04-21T11:29:47.739
    로그인 후 복사
큐 hello2 메시지로 보내기, 카운트 매개변수 허용

  • package com.example.rabbitmqdemo.config;


import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * RabbitMQ 配置类
 *
 * @author itguang
 * @create
@Configuration
public class RabbitConfig



    @Bean
    public Queue queue(){
        return new Queue("hello");
    }

    @Bean
    public Queue queue2(){
        return new Queue("hello2");
    }



}
    로그인 후 복사
두 개의 hello2 수신자

  • package com.example.rabbitmqdemo.rabbitmq;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.util.Date;

/**
 * 消息发送者
 *
 * @author itguang
 * @create

@Component
public class HelloSender


    @Autowired
    private AmqpTemplate amqpTemplate;


    public void send(){
        String context = "hello----"+LocalDateTime.now();
        System.out.println("send:"+context);
        this.amqpTemplate.convertAndSend("hello",context);
    }

    //给hello2发送消息,并接受一个计数参数
    public void send2(int i){
        String context = i+"";
        System.out.println(context+"--send:");
        this.amqpTemplate.convertAndSend("hello2",context);
    }
}
    로그인 후 복사
    @Component
@RabbitListener(queues = "hello2")
public class HelloReceiver1


    @RabbitHandler
    public void process(String message){

        System.out.println("Receiver1:"+message);
    }


}
    로그인 후 복사
    Test
@Component
@RabbitListener(queues = "hello2")
public class HelloReceiver2

    @RabbitHandler
    public void process(String message){
        System.out.println("Receiver2:"+message);
    }
}
로그인 후 복사
콘솔 출력 보기:

@Test
    public void manyReceiver(){
        for (int i=0;i<100;i++){
            helloSender.send2(i);
        }

    }
로그인 후 복사

볼 수 있는 내용: 메시지가 63으로 전송되면, 수신자가 메시지를 받았습니다.

결론:


한 명의 발신자, N명의 수신자, 테스트 후 메시지는 N개의 수신자에게 균등하게 전송됩니다.

다대다: 여러 발신자가 여러 수신자에게

다음과 같이 두 개의 발신자를 주입하고 이를 루프에 넣을 수 있습니다.

0--send:
1--send:
2--send:
3--send:
4--send:

...(省略)

58--send:
59--send:
60--send:
61--send:
62--send:
63--send:
Receiver2:1
Receiver1:0
64--send:
65--send:
Receiver1:2
Receiver2:3
66--send:
Receiver1:4
Receiver2:5
...(省略)
로그인 후 복사

단위 테스트를 실행하고 콘솔 출력을 확인합니다.

@Test
    public void many2many(){
      for (int i=0;i<100;i++){
          helloSender.send2(i);
          helloSender2.send2(i);

      }
    }
로그인 후 복사

결론: 일대다와 마찬가지로 수신자는 여전히 To 메시지를 균등하게 수신합니다.

객체 보내기

먼저 엔터티 클래스 객체 User를 생성합니다. 이 객체는 직렬화 가능 인터페이스를 구현해야 합니다.

0--send:
0--send:
1--send:
1--send:
2--send:
2--send:
3--send:
3--send:

...(省略)

22--send:
22--send:
23--send:
23--send:
24--send:
24--send:
Receiver2:0
25--send:
25--send:
Receiver2:1
26--send:
Receiver2:2
26--send:
Receiver2:3
27--send:
Receiver1:0
27--send:
Receiver2:4
Receiver1:1
28--send:
Receiver2:5
Receiver1:2
28--send:
Receiver2:6
Receiver1:3
29--send:
Receiver2:7
Receiver1:4
29--send:
Receiver2:8
Receiver1:5
30--send:
Receiver2:9
Receiver1:6
30--send:
31--send:
31--send:
32--send:
32--send:
로그인 후 복사

그런 다음 구성 파일에

package com.example.rabbitmqdemo.pojo;

import java.io.Serializable;

/**
 * @author itguang
 * @create
public class User implements Serializable


    private String username;
    private String password;

    public User(String username, String password) {
        this.username = username;
        this.password = password;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    @Override
    public String toString() {
        return "User{" +
                "username='" + username + '\'' +
                ", password='" + password + '\'' +
                '}';
    }
}
로그인 후 복사

라는 대기열을 생성합니다. 다음은 사용자 객체 송신자 ObjectSender 및 수신자 ObjectReceiver: object_queue

@Bean
    public Queue queue3(){
        return new Queue("object_queue");
    }
로그인 후 복사
@Component
public class ObjectSender

    @Autowired
    AmqpTemplate amqpTemplate;

    public void sendUser(User user){

        System.out.println("Send object:"+user.toString());
        this.amqpTemplate.convertAndSend("object_queue",user);

    }
}
로그인 후 복사
단위 테스트를 실행하고 콘솔 출력 결과 보기: 

@Component
@RabbitListener(queues = "object_queue")
public class ObjectReceiver

    @RabbitHandler
    public void objectReceiver(User user){

        System.out.println("Receiver object:"+user.toString());

    }
}
로그인 후 복사
Topic Exchange

topic은 RabbitMQ에서 가장 유연한 방법이며 다양한 객체 기반으로 자유롭게 바인딩될 수 있습니다. Routing_key Queue

먼저 주제 규칙을 구성하세요. 여기에서는 

Send object:User{username='李增光', password='666666'}
Receiver object:User{username='李增光', password='666666'}
로그인 후 복사
메시지 발신자를 테스트하는 데 사용됩니다. 둘 다 topicExchange를 사용하고 서로 다른 Routing_key

package com.example.rabbitmqdemo.config;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author itguang
 * @create
@Configuration
public class TopicRabbitConfig


    final static String message = "topic.message";
    final static String messages = "topic.messages";


    //创建两个 Queue
    @Bean
    public Queue queueMessage(){
        return new Queue(TopicRabbitConfig.message);
    }

    @Bean
    public Queue queueMessages(){
        return new Queue(TopicRabbitConfig.messages);
    }

    //配置 TopicExchange,指定名称为 topicExchange
    @Bean
    public TopicExchange exchange(){
        return new TopicExchange("topicExchange");
    }

    //给队列绑定 exchange 和 routing_key

    @Bean
    public Binding bindingExchangeMessage(Queue queueMessage, TopicExchange exchange){
        return BindingBuilder.bind(queueMessage).to(exchange).with("topic.message");
    }

    @Bean
    public Binding bingingExchangeMessages(Queue queueMessages,TopicExchange exchange){
        return BindingBuilder.bind(queueMessages).to(exchange).with("topic.#");
    }


}
로그인 후 복사
두 개의 메시지 수신자가 각각 서로 다른 대기열을 지정합니다.

보내는 send1은 topic.# 및 topic.message와 일치합니다. 두 수신자 모두 메시지를 받을 수 있으며, send2만 보내면 topic.#은 Receiver2만 듣는 모든 메시지와 일치할 수 있습니다

Fanout Exchange

Fanout은 브로드캐스트 모드이거나 우리에게 익숙한 구독 모드는 Fanout 스위치에 메시지를 보내고 이 스위치에 바인딩된 모든 대기열은 이 메시지를 받습니다.

팬아웃 관련 구성:

package com.example.rabbitmqdemo.topic;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author itguang
 * @create
@Component
public class TopicSender

    @Autowired
    AmqpTemplate amqpTemplate;

    public void send1(){
        String context = "hi, i am message 1";
        System.out.println("Sender : " + context);
        amqpTemplate.convertAndSend("topicExchange","topic.message",context);
    }

    public void send2() {
        String context = "hi, i am messages 2";
        System.out.println("Sender : " + context);
        amqpTemplate.convertAndSend("topicExchange", "topic.messages", context);
    }
}
로그인 후 복사
메시지 보낸 사람:

这里使用了A、B、C三个队列绑定到Fanout交换机上面，发送端的routing_key写任何字符都会被忽略

package com.example.rabbitmqdemo.fanout;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author itguang
 * @create
@Component
public class FanoutSender


    @Autowired
    AmqpTemplate amqpTemplate;


    public void send(){

        String context = "hi, fanout msg ";
        System.out.println("Sender : " + context);
        //这里使用了A、B、C三个队列绑定到Fanout交换机上面，发送端的routing_key写任何字符都会被忽略：
        amqpTemplate.convertAndSend("fanoutExchange","", context);

    }

}
로그인 후 복사

三个消息接受者:

@Component
@RabbitListener(queues = "fanout.A")
public class FanoutReceiverA


    @RabbitHandler
    public void process(String message){

        System.out.println("Receiver form fanout.A: "+message);

    }

}

@Component
@RabbitListener(queues = "fanout.B")
public class FanoutReceiverB


    @RabbitHandler
    public void process(String message){

        System.out.println("Receiver form fanout.B: "+message);

    }

}

@Component
@RabbitListener(queues = "fanout.C")
public class FanoutReceiverC


    @RabbitHandler
    public void process(String message){

        System.out.println("Receiver form fanout.C: "+message);

    }

}
로그인 후 복사

运行单元测试,查看结果:

Sender : hi, fanout msg 

Receiver form fanout.C: hi, fanout msg 
Receiver form fanout.A: hi, fanout msg 
Receiver form fanout.B: hi, fanout msg
로그인 후 복사

结果说明，绑定到fanout交换机上面的队列都收到了消息.

위 내용은 SpringBoot는 RabbitMq를 어떻게 통합하나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨：
springboot rabbitmq
원천：yisu.com
이전 기사：mybatis+druid를 사용하여 springboot에서 동적 데이터 소스를 구성하는 방법 다음 기사：Java 다중 스레드 동기화 도구 클래스 CountDownLatch를 사용하는 방법
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
저자별 최신 기사
최신 이슈
POST 요청은 Postman을 사용할 때 잘 작동하지만 React axios 및 Spring Boot 백엔드를 사용할 때는 작동하지 않습니다. 반응 콘솔에서 "리소스를 로드할 수 없습니다: 서버 응답 상태는 500()"이라는 오류 메시지가 나타납니다. SpringBoot 백엔드에서 &q...
에서 2024-04-05 13:07:01
0
1
396
SQL Server: WHERE 절과 함께 CASE WHEN 표현식 사용 SQLServer가 포함된 새 SpringBoot 프로젝트가 있고 이전 프로젝트의 리포지토리 메서드에 대한 MySQL 기본 쿼리를 SQLServer 기본 쿼리로 ...
에서 2024-04-03 14:46:55
0
1
351
Spring Boot + React + MySQL 애플리케이션의 아키텍처 계층은 무엇입니까? 애플리케이션에 대한 문서를 작성하려고 하는데 아키텍처를 설명하는 방법이 혼란스럽습니다. 제가 수행한 연구에 따르면 프레젠테이션 레이어는 React 애플리케이션이고...
에서 2024-04-03 10:07:06
0
1
410
관련 주제
더>
인기 추천
인기 튜토리얼
더>
관련 튜토리얼
인기 추천
최신 강좌
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿