网上有很多消息队列的中间件,如redis,kafka,rabbitmq,这些都很强大
但用起来,每个的用法都不一样,有没有一种办法,我只需要实现一种方法,就能随意使用哪个中间件都可以呢....boolean support(String producerType) {
return Objects.equals(producerType,"redis");
}
}
kafka...");
}
}
rabbitmq生产者这个有点折腾,主要是我希望自动创建队列,但实现用的时候,要先手动创建,所以我自己想了个办法,再发消息时,判断有没有创建queue,没有的话,先创建:
/**...(redis,kafka,rabbitmq)已完成,把redis,kafka,rabbitmq,的实现打包成不同的jar包,想用哪一个就用哪一个。...生产者做得有点长,消费者的设计开新章吧!