public class Message {private final MessageProperties messageProperties;private final byte[] body;public Message(byte[] body, MessageProperties messageProperties) {this.body = body;this.messageProperties = messageProperties;}public byte[] getBody() {return this.body;}public MessageProperties getMessageProperties() {return this.messageProperties;}
}

public interface Exchange {String getName();String getExchangeType();boolean isDurable();boolean isAutoDelete();Map<String, Object> getArguments();}

public abstract class ExchangeTypes {public static final String DIRECT = "direct";public static final String TOPIC = "topic";public static final String FANOUT = "fanout";public static final String HEADERS = "headers";public static final String SYSTEM = "system";/*** The constant to represent {@code x-delayed-message} exchange mode.* @deprecated since 1.6.4, it's not a user-available exchange type,* the delayed {@code boolean} is used for that.*/@Deprecatedpublic static final String DELAYED = "x-delayed-message";
}

public class Queue  {private final String name;private volatile boolean durable;private volatile boolean exclusive;private volatile boolean autoDelete;private volatile Map<String, Object> arguments;/*** 队列是持久的，非排他的和非自动删除的。** @param name 队列名*/public Queue(String name) {this(name, true, false, false);}// Getters and Setters omitted for brevity

}

public class Binding extends AbstractDeclarable {public enum DestinationType {QUEUE, EXCHANGE;}

Binding b = BindingBuilder.bind(someQueue).to(someTopicExchange).with("foo.*");

<rabbit:connection-factoryid="connectionFactory" channel-cache-size="50"/>

        template.setMandatory(true);template.setReturnCallback(new ReturnCallback() {@Overridepublic void returnedMessage(Message message, int replyCode, String replyText, String exchange,String routingKey) {// 当消息没有被送回到的时候,会回调这个方法.// 其中基本的信息都已经有了.
            }});

template.setConfirmCallback(new ConfirmCallback() {@Overridepublic void confirm(CorrelationData correlationData, boolean ack, String cause) {System.out.println("确认消息");}});

void send(Message message) throws AmqpException;void send(String routingKey, Message message) throws AmqpException;void send(String exchange, String routingKey, Message message) throws AmqpException;

Message message = MessageBuilder.withBody("foo".getBytes()).setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN).setMessageId("123").setHeader("bar", "baz").build();

Message message = MessageBuilder.withBody("foo".getBytes()).setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN).setMessageId("123").setHeader("bar", "baz").build();

    <rabbit:annotation-driven/>

@Component
public class MyService {@RabbitListener(bindings = @QueueBinding(value = @Queue(value = "myQueue", durable = "true"),exchange = @Exchange(value = "auto.exch", ignoreDeclarationExceptions = "true"),key = "orderRoutingKey"))public void processOrder(String data) {...}@RabbitListener(bindings = @QueueBinding(value = @Queue,exchange = @Exchange(value = "auto.exch"),key = "invoiceRoutingKey"))public void processInvoice(String data) {...}}

   @RabbitListener(queues = "myQueue")public void processOrder(String data) {...}

原始的org.springframework.amqp.core.Message。
接收消息的com.rabbitmq.client.Channel

@RabbitListener(queues = "myQueue")
public void processOrder(Message<Order> order) { ...
}

public interface Message<T> {T getPayload();MessageHeaders getHeaders();
}