当需要轮询器并且它具有属性max-消息-每轮询时，具有入站-通道-适配器属性"max-rows"的意义是什么？

Question

int-jdbc：入站-通道-适配器需要int： poller才能工作，两者都分别具有max-row和max-消息-每-轮询。

a） 为什么入站通道适配器需要轮询器。为什么不能内置默认轮询器？

b） 如果每次轮询的最大行数和最大消息数具有不同的值怎么办？

c） 为什么轮询器（o.s.i.e.SourcePollingChannelAdapter）在轮询和处理一组消息时保持轮询（或尝试轮询）？

<int-jdbc:inbound-channel-adapter 
    query="${poller.deliveryLocator.dnd.get}"
    max-rows="${poller.deliveryLocator.dnd.maxRow}"
    row-mapper="deliveryLocatorPollerRowMapper" data-source="dataSource" 
    channel="deliveryLocatorChannel">
    <int:poller fixed-rate="500" time-unit="MILLISECONDS" max-messages-per-poll="${poller.deliveryLocator.dnd.maxRow}">
        <int:transactional />
    </int:poller>

</int-jdbc:inbound-channel-adapter>

对于问题"c"，我确实为org.springframework设置了调试级别记录器，并通过在行映射器上设置断点来阻止程序。

我注意到poller一直在轮询DB（这些调试语句正在重复），但是，它没有选择任何记录，因为入站通道适配器被阻塞。

2019-06-10 15:16:29 [task-scheduler-1] DEBUG 
o.s.orm.jpa.JpaTransactionManager - Creating new transaction with name 
2019-06-10 15:16:29 [task-scheduler-1] DEBUG o.s.orm.jpa.JpaTransactionManager - Opened new EntityManager [SessionImpl(1259297282<open>)] for JPA transaction
2019-06-10 15:16:29 [task-scheduler-1] DEBUG o.s.orm.jpa.JpaTransactionManager - Exposing JPA transaction as JDBC [org.springframework.orm.jpa.vendor.HibernateJpaDialect$HibernateConnectionHandle@621f9b19]
2019-06-10 15:16:29 [task-scheduler-1] DEBUG o.s.jdbc.core.JdbcTemplate - Executing prepared SQL query
2019-06-10 15:16:29 [task-scheduler-1] DEBUG o.s.jdbc.core.JdbcTemplate - Executing prepared SQL statement
2019-06-10 15:16:29 [task-scheduler-1] DEBUG o.s.i.e.SourcePollingChannelAdapter - Received no Message during the poll, returning 'false'
2019-06-10 15:16:29 [task-scheduler-1] DEBUG o.s.orm.jpa.JpaTransactionManager - Initiating transaction commit
2019-06-10 15:16:29 [task-scheduler-1] DEBUG o.s.orm.jpa.JpaTransactionManager - Committing JPA transaction on EntityManager [SessionImpl(1259297282<open>)]
2019-06-10 15:16:29 [task-scheduler-1] DEBUG o.s.orm.jpa.JpaTransactionManager - Closing JPA EntityManager [SessionImpl(1259297282<open>)] after transaction

Answer 1

a） 您可以定义默认轮询器（请参阅文档）。

b）最大行是限制每次轮询时读取的行数的一种方法（消息有效负载是行或映射对象的集合）；max-消息-每次轮询是在轮询间隔之间轮询数据库的次数。

c） 只有当你把工作交给另一个线程时，它才会这样做。如果在轮询器线程上处理结果，则在当前轮询完成之前，不会发生下一次轮询。

我不知道你说的“…被封锁”是什么意思。