网上有很多消息队列的中间件,如redis,kafka,rabbitmq,这些都很强大
但用起来,每个的用法都不一样,有没有一种办法,我只需要实现一种方法,就能随意使用哪个中间件都可以呢....private String topic;
/**
* 消息内容
*/
private String message;
}
2.生产者接口设计,用于各种消息队列的实现...生产者这个有点折腾,主要是我希望自动创建队列,但实现用的时候,要先手动创建,所以我自己想了个办法,再发消息时,判断有没有创建queue,没有的话,先创建:
/**
* rabbitmq 消息队列
*...applicationContext.getBeanFactory();
beanFactory.registerBeanDefinition(name, beanDefinition);
}
}
至此,通用的消息队列...(redis,kafka,rabbitmq)已完成,把redis,kafka,rabbitmq,的实现打包成不同的jar包,想用哪一个就用哪一个。