親愛的Spring社群！

最近我們釋出了 Spring Integration Java DSL: 逐行教程，其中廣泛使用了 Java 8 Lambda。我們收到一些反饋，認為這是 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 會稍微冗長一些，因為您需要為函式式介面的內聯匿名實現提供樣板程式碼。然而，我們相信支援 DSL 對於那些還無法遷移到 Java 8 的使用者來說很重要。DSL 的許多優勢（流暢的 API、編譯時驗證等）對所有使用者都是可用的。

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

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

一如既往，我們期待您的評論和反饋（StackOverflow (spring-integration 標籤)、Spring JIRA、GitHub），我們非常歡迎貢獻！

感謝您的時間和耐心閱讀本文！