彈簧積分隊列通道容量錯誤

Question

我在彈簧整合方面玩的更多，我對它非常感興趣，但對我的意見有一個奇怪的行爲，我找不到答案。

我使用隊列通道的簡單應用：

<int:channel id="ticketChannel" datatype="ch.elca.prototype.model.Ticket"> 
    <int:queue capacity="1"/> 
</int:channel> 

我也試着交會，排隊同樣的效果：

<int:channel id="ticketChannel" datatype="ch.elca.prototype.model.Ticket"> 
    <int:rendezvous-queue/> 
</int:channel> 

隨着我的理解，現在應該只可能在該頻道中一次移動一條消息。也許2，如果你認爲你有一個額外的容量。我不知道如何閱讀它。但是我可以在沒有消耗的情況下將四次發送到該頻道，這對我來說有點奇怪，然後我不瞭解容量。

如下圖：

主要用途： 在這裏，我流10票，並呼籲openTicket每個：

public static void main(final String[] args) throws InterruptedException { 
    try (ConfigurableApplicationContext context = SpringApplication.run(SassSimulatorApplication2.class, args)) { 
     final TicketGenerator generator = context.getBean(TicketGenerator.class); 
     final ProblemReporter reporter = context.getBean(ProblemReporter.class); 
     generator.createTickets().limit(10).forEach(reporter::openTicket); 
     context.close(); 
    } 
} 

ProblemReporter：

public class ProblemReporter { 
    private volatile QueueChannel channel; 

    public synchronized void openTicket(final Ticket ticket){ 
     final Message<Ticket> build = TicketMessageBuilder.buildMessage(ticket); 
     boolean send = channel.send(build); 

     System.out.println("send: " + send); 
     System.out.println("getQueueSize: " + channel.getQueueSize()); 
     System.out.println("getSendCount: " + channel.getSendCount()); 
     System.out.println("getReceiveCount: " + channel.getReceiveCount()); 
     System.out.println("getSendErrorCount: " + channel.getSendErrorCount()); 
     System.out.println("getRemainingCapacity: " + channel.getRemainingCapacity()); 
    } 

    @Value("#{ticketChannel}") 
    public void setChannel(final QueueChannel channel) { 
     this.channel = channel; 
    } 
} 

啓動時應用I得到以下：

send: true 
getQueueSize: 0 
getSendCount: 0 
getReceiveCount: 0 
getSendErrorCount: 0 
getRemainingCapacity: 1 

send: true 
getQueueSize: 0 
getSendCount: 0 
getReceiveCount: 0 
getSendErrorCount: 0 
getRemainingCapacity: 1 

send: true 
getQueueSize: 1 
getSendCount: 0 
getReceiveCount: 0 
getSendErrorCount: 0 
getRemainingCapacity: 0 

send: true 
getQueueSize: 1 
getSendCount: 0 
getReceiveCount: 0 
getSendErrorCount: 0 
getRemainingCapacity: 0 

我正在使用Spring-Boot 1.3.3，Sprint-Integration 4.2.5.RELEASE。我還使用Spring-Integration 4.1.9嘗試了Spring-Boot 1.2.8。

是預期的行爲？

在此先感謝。

Answer 1

看起來像你的channel.send(build, 30000);完成對local變量，而不是共享bean。 我的測試情況是這樣的：

QueueChannel channel = new QueueChannel(3); 

IntStream.range(0, 4) 
     .forEach(i -> { 
      boolean send = channel.send(new GenericMessage<>("test-" + i), 100); 
      System.out.println("send: " + send); 
      System.out.println("getQueueSize: " + channel.getQueueSize()); 
      System.out.println("getRemainingCapacity: " + channel.getRemainingCapacity()); 
     }); 

，其結果是：

send: true 
getQueueSize: 1 
getRemainingCapacity: 2 
send: true 
getQueueSize: 2 
getRemainingCapacity: 1 
send: true 
getQueueSize: 3 
getRemainingCapacity: 0 
send: false 
getQueueSize: 3 
getRemainingCapacity: 0 

注：sendCount（以及類似的）只能通過@EnableIntegrationMBeanExport或@EnableIntegrationManagement啓用。 請參閱參考手冊中的Management。

此外，您還可以在框架中找到關於此問題的一些測試案例，例如， QueueChannelTests。