这是由spring amqp框架简化而来的一个自定义框架,去除了很多平时用不到的东西,同时也根据自己的需要,在特定的地方做了一些修改。
核心类是下面的4个:
CacheConnectionFactory 这个工厂,缓存了连接和信道
UdConsumerContainer 消费者池
BlockingQueueConsumer 消费者
RabbitMQHelper 帮助类(提供了各种声明方法)
接下来先说CacheConnectionFactory 类:
这是由spring amqp框架简化而来的一个自定义框架,去除了很多平时用不到的东西,同时也根据自己的需要,在特定的地方做了一些修改。
核心类是下面的4个:
CacheConnectionFactory 这个工厂,缓存了连接和信道
UdConsumerContainer 消费者池
BlockingQueueConsumer 消费者
RabbitMQHelper 帮助类(提供了各种声明方法)
接下来先说CacheConnectionFactory 类: