public class SpringRmq { public static void main(String[] args) throws Exception { /** * Message类封装了body(消息BODY)和properties(消息属性) * 其中MessageProperties类中定义了例如messageId、timestamp、contentType等属性。 * 这此属性可以扩展到用户通过setHeader(String key, Object value)方法来自定义“headers”。 */ Message m = null; /** * Exchange接口代表一个AMQP的Exchange,决定消息生产者发送消息 */ AbstractExchange ae = null; /** * Queue类是消息消费者接收消息中重要的一个组成部分。通过与Exchange判定来肯定消费者所接收的消息。 */ Queue q = null; /** * Bingding类通过多种构造参数来判定Exchange,Queue,routingkey; */ Binding b = null; /** * AmqpTemplate是用来发送消息的模板类 */ AmqpTemplate a = null; /** * 用户配置Queue、Exchange、Binding的代理类。代理类会自动声明或创建这些配置信息。下面这个类用于异步接收消息的处理类 */ AmqpAdmin aa = null; RabbitAdmin ra = null; /** * 消息转换器类 */ MessageConverter mc = null; /** * 监听消息容器类 */ SimpleMessageListenerContainer ss = null; } }