SpringCloud 生產者和消費者

下圖顯示了生產者和消費者的一般關系：

圖30.1。生產者和消費者

生產者是將消息發(fā)送到通道的任何組件。可以將該通道綁定到具有該代理的Binder實現的外部消息代理。調用bindProducer()方法時，第一個參數是代理內目標的名稱，第二個參數是生產者向其發(fā)送消息的本地通道實例，第三個參數包含屬性（例如分區(qū)鍵表達式） ），以在為該通道創(chuàng)建的適配器中使用。

使用者是從通道接收消息的任何組件。與生產者一樣，消費者的渠道可以綁定到外部消息代理。調用bindConsumer()方法時，第一個參數是目標名稱，第二個參數提供邏輯消費者組的名稱。由給定目標的使用者綁定表示的每個組都接收生產者發(fā)送到該目標的每個消息的副本（也就是說，它遵循常規(guī)的發(fā)布-訂閱語義）。如果有多個使用相同組名綁定的使用者實例，那么消息將在這些使用者實例之間進行負載平衡，以便由生產者發(fā)送的每條消息僅在每個組內的單個使用者實例中被使用（也就是說，它遵循常規(guī)排隊語義）。