popup多个imapAdapter

我在spring是新手，我不喜欢代码重复。 我写了一个工作正常的ImapAdapter：

@Component public class GeneralImapAdapter { private Logger logger = LoggerFactory.getLogger(getClass()); @Autowired private EmailReceiverService emailReceiverService; @Bean @InboundChannelAdapter(value = "emailChannel", poller = @Poller(fixedDelay = "10000", taskExecutor = "asyncTaskExecutor")) public MessageSource<javax.mail.Message> mailMessageSource(MailReceiver imapMailReceiver) { return new MailReceivingMessageSource(imapMailReceiver); } @Bean @Value("imaps://<login>:<pass>@<url>:993/inbox") public MailReceiver imapMailReceiver(String imapUrl) { ImapMailReceiver imapMailReceiver = new ImapMailReceiver(imapUrl); imapMailReceiver.setShouldMarkMessagesAsRead(true); imapMailReceiver.setShouldDeleteMessages(false); // other setters here return imapMailReceiver; } @ServiceActivator(inputChannel = "emailChannel", poller = @Poller(fixedDelay = "10000", taskExecutor = "asyncTaskExecutor")) public void emailMessageSource(javax.mail.Message message) { emailReceiverService.receive(message); } } 

但是我想要这样的20个适配器，唯一的区别是imapUrl 。

如何做到这一点没有代码重复？

Answer 1

使用多个应用程序上下文，configuration属性。

这个例子是一个例子。 它使用XML来进行configuration，但是Javaconfiguration也适用相同的技术。

如果你需要他们喂养一个共同的emailReceiverService ; 使各个适配器上下文子上下文; 请参阅示例自述文件以获取有关如何执行此操作的指示信息。

编辑：

下面是一个例子，服务（和通道）在共享父上下文中

 @Configuration @EnableIntegration public class MultiImapAdapter { public static void main(String[] args) throws Exception { AnnotationConfigApplicationContext parent = new AnnotationConfigApplicationContext(MultiImapAdapter.class); parent.setId("parent"); String[] urls = { "imap://foo", "imap://bar" }; List<ConfigurableApplicationContext> children = new ArrayList<ConfigurableApplicationContext>(); int n = 0; for (String url : urls) { AnnotationConfigApplicationContext child = new AnnotationConfigApplicationContext(); child.setId("child" + ++n); children.add(child); child.setParent(parent); child.register(GeneralImapAdapter.class); StandardEnvironment env = new StandardEnvironment(); Properties props = new Properties(); // populate properties for this adapter props.setProperty("imap.url", url); PropertiesPropertySource pps = new PropertiesPropertySource("imapprops", props); env.getPropertySources().addLast(pps); child.setEnvironment(env); child.refresh(); } System.out.println("Hit enter to terminate"); System.in.read(); for (ConfigurableApplicationContext child : children) { child.close(); } parent.close(); } @Bean public MessageChannel emailChannel() { return new DirectChannel(); } @Bean public EmailReceiverService emailReceiverService() { return new EmailReceiverService(); } } 

和

 @Configuration @EnableIntegration public class GeneralImapAdapter { @Bean public static PropertySourcesPlaceholderConfigurer pspc() { return new PropertySourcesPlaceholderConfigurer(); } @Bean @InboundChannelAdapter(value = "emailChannel", poller = @Poller(fixedDelay = "10000") ) public MessageSource<javax.mail.Message> mailMessageSource(MailReceiver imapMailReceiver) { return new MailReceivingMessageSource(imapMailReceiver); } @Bean @Value("${imap.url}") public MailReceiver imapMailReceiver(String imapUrl) { // ImapMailReceiver imapMailReceiver = new ImapMailReceiver(imapUrl); // imapMailReceiver.setShouldMarkMessagesAsRead(true); // imapMailReceiver.setShouldDeleteMessages(false); // // other setters here // return imapMailReceiver; MailReceiver receiver = mock(MailReceiver.class); Message message = mock(Message.class); when(message.toString()).thenReturn("Message from " + imapUrl); Message[] messages = new Message[] {message}; try { when(receiver.receive()).thenReturn(messages); } catch (MessagingException e) { e.printStackTrace(); } return receiver; } } 

和

 @MessageEndpoint public class EmailReceiverService { @ServiceActivator(inputChannel="emailChannel") public void handleMessage(javax.mail.Message message) { System.out.println(message); } } 

希望有所帮助。

请注意，您不需要服务激活器上的轮询器 – 使用DirectChannel ，该服务将在轮询器执行器线程上调用 – 不需要另一个asynchronous切换。