springboot 메시지 미들웨어 사용
SpringBoot 를 사용 하여 rabbitmq 를 통합 하여 전송 과 수신 을 실현 합 니 다.
내용.
1.의존 도입
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
2.application.properties
#rabbitmq
spring.application.name=springboot-mq
spring.rabbitmq.host=192.168.17.129
spring.rabbitmq.port=5672
spring.rabbitmq.username=mytest
spring.rabbitmq.password=mytest
3.rabbitmap 설정 클래스
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitMQConfig {
@Bean
public Queue mqQueue(){
return new Queue("mqboot");
}
}
4.발송 클래스<큰 칼럼 zyzx(53)-springboot 사용 메시지 미들웨어/h5>
@Component
public class Sender {
@Autowired
private AmqpTemplate rabbitTemplate;
public void send(){
String content = "send: hello"+new Date();
System.out.println("Sender:"+content)
this.rabbitTemplate.convertAndSend("mqboot",content);
}
}
분류 하 다
@Component
@RabbitListener(queues = "mqboot")
public class Receiver {
@RabbitHandler
public void process(String data){
System.out.println("Receiver:"+data);
}
}
6.테스트springBoot 시작
연결 성공:
@RunWith(SpringRunner.class)
@SpringBootTest
public class ApplicationTests {
@Autowired
private TeacherRepository teacherRepository;
/*@Autowired
private JavaMailSender javaMailSender;*/
@Autowired
private Sender sender;
@Test
public void contextLoads() {
//mq
sender.send();
}
}
이상 이 바로 본 고의 모든 내용 입 니 다.여러분 의 학습 에 도움 이 되 고 저 희 를 많이 응원 해 주 셨 으 면 좋 겠 습 니 다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
thymeleaf로 HTML 페이지를 동적으로 만듭니다 (spring + gradle)지난번에는 에서 화면에 HTML을 표시했습니다. 이번에는 화면을 동적으로 움직여보고 싶기 때문에 입력한 문자를 화면에 표시시키고 싶습니다. 초보자의 비망록이므로 이상한 점 등 있으면 지적 받을 수 있으면 기쁩니다! ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.