親愛的 Spring 社群！

最近我們釋出了 Spring Integration Java DSL：逐行教程，其中大量使用了 Java 8 Lambdas。 我們收到了一些反饋，認為這是對 DSL 的一個很好的介紹，但是那些無法遷移到 Java 8 或者還不熟悉 Lambdas，但希望利用它的優勢的使用者也需要類似的教程

因此，為了幫助那些希望從 XML 配置遷移到 Java & 註解配置的 Spring Integration 使用者，我們提供了這個 逐行教程，以證明即使沒有 Lambdas，我們也能從 Spring Integration Java DSL 的使用中獲得很多好處。 雖然大多數人會同意 lambda 語法提供了更簡潔的定義。

我們在這裡分析了相同的 Cafe Demo 示例，但使用 Java 8 之前的配置變體。 許多選項是相同的，因此我們只需複製/貼上他們的描述以獲得完整的畫面。 由於此 Spring Integration Java DSL 配置與 Java 8 lambda 風格完全不同，因此對於所有使用者來說，瞭解如何透過 Spring Integration Java DSL 提供的各種選項來實現相同的結果將非常有用。

我們應用程式的原始碼放在一個類中，該類是一個 Boot 應用程式； 重要的行用數字註釋，對應於後面的註釋

@SpringBootApplication                                                   // 1
@IntegrationComponentScan                                                // 2
public class Application {

  public static void main(String[] args) throws Exception {
  	ConfigurableApplicationContext ctx =
			SpringApplication.run(Application.class, args);              // 3

  	Cafe cafe = ctx.getBean(Cafe.class);                                 // 4
  	for (int i = 1; i <= 100; i++) {                                     // 5
  	  Order order = new Order(i);
  	  order.addItem(DrinkType.LATTE, 2, false);
  	  order.addItem(DrinkType.MOCHA, 3, true);
  	  cafe.placeOrder(order);
  	}

  	System.out.println("Hit 'Enter' to terminate");                      // 6
  	System.in.read();
  	ctx.close();
  }

  @MessagingGateway                                                      // 7
  public interface Cafe {

  	@Gateway(requestChannel = "orders.input")                            // 8
  	void placeOrder(Order order);                                        // 9

  }

  private final AtomicInteger hotDrinkCounter = new AtomicInteger();

  private final AtomicInteger coldDrinkCounter = new AtomicInteger();    // 10

  @Autowired
  private CafeAggregator cafeAggregator;                                 // 11

  @Bean(name = PollerMetadata.DEFAULT_POLLER)
  public PollerMetadata poller() {                                       // 12
  	return Pollers.fixedDelay(1000).get();
  }

  @Bean
  @SuppressWarnings("unchecked")
  public IntegrationFlow orders() {                                      // 13
  	return IntegrationFlows.from("orders.input")                         // 14
	  .split("payload.items", (Consumer) null)                           // 15
	  .channel(MessageChannels.executor(Executors.newCachedThreadPool()))// 16
	  .route("payload.iced",                                             // 17
	    new Consumer<RouterSpec<ExpressionEvaluatingRouter>>() {         // 18

	      @Override
	      public void accept(RouterSpec<ExpressionEvaluatingRouter> spec) {
	      	spec.channelMapping("true", "iced")
                .channelMapping("false", "hot");                         // 19
  	      }

  	    })
  	  .get();                                                            // 20
  }

  @Bean
  public IntegrationFlow icedFlow() {                                    // 21
  	return IntegrationFlows.from(MessageChannels.queue("iced", 10))      // 22
	  .handle(new GenericHandler<OrderItem>() {                          // 23

	  	@Override
	  	public Object handle(OrderItem payload, Map<String, Object> headers) {
	  	  Uninterruptibles.sleepUninterruptibly(1, TimeUnit.SECONDS);
	  	  System.out.println(Thread.currentThread().getName()
	  	    + " prepared cold drink #" + coldDrinkCounter.incrementAndGet()
	  	    + " for order #" + payload.getOrderNumber() + ": " + payload);
	  	  return payload;                                                // 24
  	  	}

  	  })
  	  .channel("output")                                                 // 25
  	  .get();
  }

  @Bean
  public IntegrationFlow hotFlow() {                                     // 26
  	return IntegrationFlows.from(MessageChannels.queue("hot", 10))
	  .handle(new GenericHandler<OrderItem>() {

	  	@Override
	  	public Object handle(OrderItem payload, Map<String, Object> headers) {
	  	  Uninterruptibles.sleepUninterruptibly(5, TimeUnit.SECONDS);    // 27
	  	  System.out.println(Thread.currentThread().getName()
	  	    + " prepared hot drink #" + hotDrinkCounter.incrementAndGet()
	  	    + " for order #" + payload.getOrderNumber() + ": " + payload);
	  	  return payload;
  	  	}

  	  })
  	  .channel("output")
  	  .get();
  }

  @Bean
  public IntegrationFlow resultFlow() {                                  // 28
    return IntegrationFlows.from("output")                               // 29
      .transform(new GenericTransformer<OrderItem, Drink>() {            // 30

        @Override
        public Drink transform(OrderItem orderItem) {
          return new Drink(orderItem.getOrderNumber(),
            orderItem.getDrinkType(),
            orderItem.isIced(),
            orderItem.getShots());                                       // 31
        }

      })
      .aggregate(new Consumer<AggregatorSpec>() {                        // 32

        @Override
        public void accept(AggregatorSpec aggregatorSpec) {
          aggregatorSpec.processor(cafeAggregator, null);                // 33
        }

      }, null)
      .handle(CharacterStreamWritingMessageHandler.stdout())             // 34
    .get();
  }


  @Component
  public static class CafeAggregator {                                   // 35

  	@Aggregator                                                          // 36
  	public Delivery output(List<Drink> drinks) {
  	  return new Delivery(drinks);
  	}

  	@CorrelationStrategy                                                 // 37
  	public Integer correlation(Drink drink) {
  	  return drink.getOrderNumber();
  	}

  }

}

逐行檢查程式碼...

好吧，我們已經完成了基於 Spring Integration Java DSL 描述 Cafe Demo 示例，當 Java Lambda 支援不可用時。 將它與XML 示例 進行比較，並檢視 Lambda 支援教程以獲取有關 Spring Integration 的更多資訊。

正如你所看到的，在沒有 lambda 的情況下使用 DSL 會稍微冗長一些，因為你需要為函式式介面的內聯匿名實現提供樣板程式碼。 但是，我們認為支援那些還無法遷移到 Java 8 的使用者使用 DSL 非常重要。 許多 DSL 優勢（流暢的 API，編譯時驗證等）對所有使用者都可用。

lambda 的使用延續了 Spring Framework 減少或消除樣板程式碼的傳統，因此我們鼓勵使用者嘗試 Java 8 和 lambda，並鼓勵他們的組織考慮允許在 Spring Integration 應用程式中使用 Java 8。

此外，請參閱 參考手冊 以獲取更多資訊。

與往常一樣，我們期待你的評論和反饋（StackOverflow (spring-integration 標籤), Spring JIRA, GitHub) 並且我們非常歡迎 貢獻!

感謝你花時間和耐心閱讀本文！