代码拉取完成，页面将自动刷新
引入rabbitmq，简化配置。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-rabbitmq-starter</artifactId>
<version>1.0.0</version>
</dependency>
public interface RabbitConsume<T> {
void onSuccess(T t);
void onFail(T t);
boolean support(Class t);
}
spring:
rabbitmq:
host: localhost
port: 5672
username: xxx
password: xxx
rabbitmq:
# 交换机
exchanges:
# 自定义-延迟
- name: delay.exchange
type: CUSTOM
custom-type: x-delayed-message
arguments:
x-delayed-type: direct
# 队列
queues:
# 延迟队列
- name: delay.queue
routing-key: delay.key
exchange-name: delay.exchange
public class DemoService {
@Autowired
RabbitProvider rabbitProvider;
public void test() {
rabbitProvider.send("delay.exchange","delay.key", RabbitData.builder().uuid("8888888").message(new Demo)).build(), 3000);
··· 代码
}
2.监听
public class MyRabbitConsume implements RabbitConsume<Demo> {
@Override
public void onSuccess(Demo o) {
log.debug("默认处理消息成功=============================>{}" , JSONObject.toJSONString(o));
}
@Override
public void onFail(Demo o) {
log.debug("默认处理消息失败=============================>{}" , JSONObject.toJSONString(o));
}
@Override
public boolean support(Class clazz) {
return Demo.class.isAssignableFrom(clazz);
}
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。