Wie wird ein Socket-Client mit Federintegration eingerichtet?

Question

Ich verwende spring 4 Annotation-basierte Konfiguration, und möchte einen einfachen Telnet/Socket-Client einrichten.

Dies ist, was ich bisher:

@MessageEndpoint 
public class MySocket { 
    @Bean 
    public TcpConnectionFactoryFactoryBean clientFactory() { 
     TcpConnectionFactoryFactoryBean fact = new TcpConnectionFactoryFactoryBean(); 
     fact.setType("client"); 
     fact.setHost(host); 
     fact.setPort(port); 
     fact.setUsingNio(true); 
     fact.setSingleUse(true); 
     fact.setSoTimeout(timeout); 
     return fact; 
    } 

    @Bean 
    public MessageChannel clientChannel() { 
     return new DirectChannel(); 
    } 

    @Bean 
    @ServiceActivator(inputChannel = "clientChannel") 
    public TcpOutboundGateway outGateway(TcpNioClientConnectionFactory factory, 
      @Qualifier("clientChannel") MessageChannel clientChannel) throws Exception { 
     TcpOutboundGateway gate = new TcpOutboundGateway(); 
     gate.setConnectionFactory(factory); 
     gate.setReplyChannel(clientChannel); 
     return gate; 
    } 
} 

@Component 
public class MyMessageService { 
    @Autowired 
    @Qualifier("clientChannel") 
    private MessageChannel clientChannel; 

    public void run() { 
    Message<String> msg = MessageBuilder.withPayload("test").build(); 
    Message<?> rsp = new MessagingTemplate(clientChannel).sendAndReceive(msg); 
    } 
} 

Ergebnis: org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers

Was soll ich hier fehlt die Nachricht über die Buchse zu senden und die Antwort erhalten?

Answer 1

Sie die @MessageEndpoint Annotation nicht benötigen, aber man braucht einen Verbraucher auf dem Kanal ...

@ServiceActivator(inputChannel = "clientChannel") 
@Bean 
public TcpOutboundGateway outGateway(AbstractClientConnectionFactory scf) { 
    ... 
} 

Das Gateway benötigt einen Verweis auf die Verbindungsfactory. Da Sie eine Factory-Bean verwenden, ist es am einfachsten, sie der Factory-Methode der Bean als Parameter hinzuzufügen.