RabbitMQ 사용 총화(코드)
1396 단어 RabbitMQ
SpringCloud 프로젝트 에 서 는 모듈 A 호출 모듈 B 의 방법 으로 메시지 큐 RabbitMQ 를 사용 합 니 다.
모듈 A 에 설정 을 추가 해 야 합 니 다:
/**
* rabbitmq
* Springboot Rabbitmq
* @author Administrator
*
*/
@Configuration
public class RabbitmqConfig {
@Bean
public TopicExchange topicExchange() {
return new TopicExchange(UserCenterMq.MQ_EXCHANGE_USER);
}
}
대응 인터페이스:
/**
* rabbitmq exchange routing key
*
* @author Administrator
*
*/
public interface UserCenterMq {
/**
* exchange
*/
String MQ_EXCHANGE_USER = "user.topic.exchange";
/**
* routing key
*/
String ROUTING_KEY_ROLE_DELETE = "role.delete";
}
발표 메시지:
amqpTemplate.convertAndSend(UserCenterMq.MQ_EXCHANGE_USER, UserCenterMq.ROUTING_KEY_ROLE_DELETE, id);
모듈 B 의 설정:
/**
* ，
*
* @author Administrator
*
*/
@Slf4j
@Component
@RabbitListener(queues = RabbitmqConfig.ROLE_DELETE_QUEUE)
public class RoleDeleteConsumer {
@Autowired
private RoleMenuDao roleMenuDao;
/**
*
*
*
* @param roleId
*/
@RabbitHandler
public void roleDeleteHandler(String roleId) {
log.info(" ,roleId:{}", roleId);
try {
roleMenuDao.delete(roleId, null);
} catch (Exception e) {
log.error(" ", e);
}
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Golang "일등 시민"- 함수 (function)2. 성명 함수: 일반 함수는 반드시 먼저 성명해야 호출할 수 있다 다섯째, 함수 변수 - 함수를 값으로 변수에 저장 익명 함수 성명, 호출 익명 함수 리셋 함수 실현 익명 함수 구현 조작 봉인 함수 자체가 값으로 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
