Comment répondre à une demande avec TcpInboundGateway?

Je voudrais développer un serveur TCP avec Spring Integration mais j'ai quelques difficultés ... Mon serveur devrait écouter sur un port pour les GPS qui s'identifient d'abord avec leur IMEI et qui ont besoin d'un accusé de réception du serveur pour aller plus loin et envoyer les données de position au même serveur TCP.Comment répondre à une demande avec TcpInboundGateway?

J'ai réussi à obtenir l'IMEI mais l'accusé de réception n'atteint pas l'appareil ... Je ne suis même pas sûr si je l'envoie de la bonne façon. J'ai lu la documentation et d'autres messages et j'ai découvert que je devais utiliser TcpInboundGateway au lieu de l'adaptateur de canal parce que c'est la même session. Mais dois-je utiliser TcpOutboundGateway pour renvoyer la réponse à l'appareil?

Voici mon code:

@EnableIntegration 
@IntegrationComponentScan 
@Configuration 
public class TcpServerConfiguration { 

    private static final Logger logger = LogManager.getLogger(TcpServerConfiguration.class); 

    @Autowired 
    TcpServerProperties properties; 

    @Bean 
    public AbstractServerConnectionFactory serverFactory() { 
     TcpNetServerConnectionFactory tcpServerFactory = new TcpNetServerConnectionFactory(properties.getPort()); 
     tcpServerFactory.setDeserializer(new ByteArrayRawSerializer()); 
     return tcpServerFactory; 
    } 

    @Bean 
    public MessageChannel inputChannel() { 
     DirectChannel channel = new DirectChannel(); 
     return channel; 
    } 

    @Bean 
    public MessageChannel outputChannel() { 
     DirectChannel channel = new DirectChannel(); 
     return channel; 
    } 

    @Bean 
    public TcpInboundGateway tcpInGate(AbstractServerConnectionFactory connectionFactory) { 
     TcpInboundGateway inGateway = new TcpInboundGateway(); 
     inGateway.setConnectionFactory(connectionFactory); 
     inGateway.setRequestChannel(inputChannel()); 
     inGateway.setReplyChannel(outputChannel()); 
     return inGateway; 
    } 

}

Le gestionnaire classe de message:

@MessageEndpoint 
public class MessageHandler { 

    private static final Logger logger = LogManager.getLogger(MessageHandler.class); 

    @Transformer(inputChannel = "inputChannel", outputChannel = "outputChannel") 
    public byte[] consume(byte[] bytes) { 
     String message = new String(bytes); 
     String byteString = ""; 
     for (byte b : bytes) { 
      byteString += Byte.toString(b) + ", "; 
     } 
     logger.info("Bytes : " + byteString); 
     logger.info("Message : " + message); 
     return new byte[]{ 01 }; 
    } 

}

Ici, j'envoie toujours le Ack (01) pour tester s'il est envoyé avec succès ce qui est pas le cas.

J'ai ajouté logging.level.org.springframework.integration=DEBUG et voici ce que je suis:

2017-10-02 14:16:44.245 INFO 6340 --- [main] b.thingsplay.Fmb920TcpServerApplication : Started Fmb920TcpServerApplication in 3.885 seconds (JVM running for 5.38) 
2017-10-02 14:16:44.250 INFO 6340 --- [pool-1-thread-1] .s.i.i.t.c.TcpNetServerConnectionFactory : serverFactory, port=7015 Listening 
2017-10-02 14:17:50.161 DEBUG 6340 --- [pool-1-thread-1] .s.i.i.t.c.TcpNetServerConnectionFactory : Accepted connection from 1.1.1.1 
2017-10-02 14:17:50.200 DEBUG 6340 --- [pool-1-thread-1] o.s.i.i.tcp.connection.TcpNetConnection : New connection ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912 
2017-10-02 14:17:50.201 DEBUG 6340 --- [pool-1-thread-1] .s.i.i.t.c.TcpNetServerConnectionFactory : serverFactory: Added new connection: ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912 
2017-10-02 14:17:50.204 DEBUG 6340 --- [pool-1-thread-2] o.s.i.i.tcp.connection.TcpNetConnection : ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912 Reading... 
2017-10-02 14:17:50.207 DEBUG 6340 --- [pool-1-thread-2] o.s.i.i.t.s.ByteArrayRawSerializer  : Available to read:17 
2017-10-02 14:18:20.576 DEBUG 6340 --- [pool-1-thread-2] o.s.i.i.tcp.connection.TcpNetConnection : Message received GenericMessage [payload=byte[17], headers={ip_tcp_remotePort=62138, ip_connectionId=ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912, ip_localInetAddress=/0.0.0.0, ip_address=1.1.1.1, id=229435ad-6284-8136-40d4-4fdfe3ef462e, ip_hostname=ptr-x-x-x-x.dyn.mobistar.be, timestamp=1506946700575}] 
2017-10-02 14:18:20.585 INFO 6340 --- [pool-1-thread-2] o.s.i.endpoint.EventDrivenConsumer  : Adding {bridge:null} as a subscriber to the 'outputChannel' channel 
2017-10-02 14:18:20.587 INFO 6340 --- [pool-1-thread-2] o.s.integration.channel.DirectChannel : Channel 'application.outputChannel' has 1 subscriber(s). 
2017-10-02 14:18:20.589 INFO 6340 --- [pool-1-thread-2] o.s.i.endpoint.EventDrivenConsumer  : started [email protected]3d44a 
2017-10-02 14:18:20.595 DEBUG 6340 --- [pool-1-thread-2] o.s.integration.channel.DirectChannel : preSend on channel 'inputChannel', message: GenericMessage [payload=byte[17], headers={replyChannel=org.springframewor[email protected]1a0438a2, errorChannel=org.springframewor[email protected]1a0438a2, ip_tcp_remotePort=62138, ip_connectionId=ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912, ip_localInetAddress=/0.0.0.0, ip_address=1.1.1.1, id=2cc3d793-dc24-705d-1438-d4b3e089d11b, ip_hostname=ptr-x-x-x-x.dyn.mobistar.be, timestamp=1506946700594}] 
2017-10-02 14:18:20.598 DEBUG 6340 --- [pool-1-thread-2] o.s.i.t.MessageTransformingHandler  : messageHandler.consume.transformer.handler received message: GenericMessage [payload=byte[17], headers={replyChannel=org.springframewor[email protected]1a0438a2, errorChannel=org.springframewor[email protected]1a0438a2, ip_tcp_remotePort=62138, ip_connectionId=ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912, ip_localInetAddress=/0.0.0.0, ip_address=1.1.1.1, id=2cc3d793-dc24-705d-1438-d4b3e089d11b, ip_hostname=ptr-x-x-x-x.dyn.mobistar.be, timestamp=1506946700594}] 
2017-10-02 14:18:20.608 INFO 6340 --- [pool-1-thread-2] be.thingsplay.tcp.MessageHandler   : Bytes : 0, 15, 51, 53, 50, 48, 57, 52, 48, 56, 51, 50, 54, 54, 52, 55, 53, 
2017-10-02 14:18:20.611 INFO 6340 --- [pool-1-thread-2] be.thingsplay.tcp.MessageHandler   : Message : 352094083266475 
2017-10-02 14:18:20.618 DEBUG 6340 --- [pool-1-thread-2] o.s.integration.channel.DirectChannel : preSend on channel 'outputChannel', message: GenericMessage [payload=byte[1], headers={replyChannel=org.springframewor[email protected]1a0438a2, errorChannel=org.springframewor[email protected]1a0438a2, ip_tcp_remotePort=62138, ip_connectionId=ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912, ip_localInetAddress=/0.0.0.0, ip_address=1.1.1.1, id=0e5b6c37-ff73-5c46-4c37-0df48d3ba607, ip_hostname=ptr-x-x-x-x.dyn.mobistar.be, timestamp=1506946700614}] 
2017-10-02 14:18:20.620 DEBUG 6340 --- [pool-1-thread-2] o.s.integration.handler.BridgeHandler : [email protected] received message: GenericMessage [payload=byte[1], headers={replyChannel=org.springframewor[email protected]1a0438a2, errorChannel=org.springframewor[email protected]1a0438a2, ip_tcp_remotePort=62138, ip_connectionId=ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912, ip_localInetAddress=/0.0.0.0, ip_address=1.1.1.1, id=0e5b6c37-ff73-5c46-4c37-0df48d3ba607, ip_hostname=ptr-x-x-x-x.dyn.mobistar.be, timestamp=1506946700614}] 
2017-10-02 14:18:20.623 DEBUG 6340 --- [pool-1-thread-2] o.s.integration.channel.DirectChannel : postSend (sent=true) on channel 'outputChannel', message: GenericMessage [payload=byte[1], headers={replyChannel=org.springframewor[email protected]1a0438a2, errorChannel=org.springframewor[email protected]1a0438a2, ip_tcp_remotePort=62138, ip_connectionId=ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912, ip_localInetAddress=/0.0.0.0, ip_address=1.1.1.1, id=0e5b6c37-ff73-5c46-4c37-0df48d3ba607, ip_hostname=ptr-x-x-x-x.dyn.mobistar.be, timestamp=1506946700614}] 
2017-10-02 14:18:20.625 DEBUG 6340 --- [pool-1-thread-2] o.s.integration.channel.DirectChannel : postSend (sent=true) on channel 'inputChannel', message: GenericMessage [payload=byte[17], headers={replyChannel=org.springframewor[email protected]1a0438a2, errorChannel=org.springframewor[email protected]1a0438a2, ip_tcp_remotePort=62138, ip_connectionId=ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912, ip_localInetAddress=/0.0.0.0, ip_address=1.1.1.1, id=2cc3d793-dc24-705d-1438-d4b3e089d11b, ip_hostname=ptr-x-x-x-x.dyn.mobistar.be, timestamp=1506946700594}] 
2017-10-02 14:18:20.628 DEBUG 6340 --- [pool-1-thread-2] o.s.i.i.tcp.connection.TcpNetConnection : ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912 Message sent GenericMessage [payload=byte[1], headers={ip_tcp_remotePort=62138, ip_connectionId=ptr-x-x-x-x.dyn.mobistar.be:62138:7015:a7151dbf-63c1-4ff5-b158-5707797b8912, ip_localInetAddress=/0.0.0.0, ip_address=1.1.1.1, id=af87b495-fceb-dbdc-c768-a8a81391af75, ip_hostname=ptr-x-x-x-x.dyn.mobistar.be, timestamp=1506946700628}] 
2017-10-02 14:18:20.631 DEBUG 6340 --- [pool-1-thread-2] o.s.i.i.t.s.ByteArrayRawSerializer  : Available to read:0

J'espère que quelqu'un pourra me aider!

Source

2017-10-02 Phoste

Vous utilisez TcpInboundGateway correctement. Même si vous n'avez pas besoin de l'option setReplyChannel(). Dans la plupart des cas, il suffit de compter sur les replyChannel dans les en-têtes et le retour de jsut de la méthode @Transformer atteindra la «session» appropriée pour répondre.

Je pense que vous utilisez incorrect deserializer. Voir ByteArrayRawSerializer JavaDocs:

* A byte array (de)serializer that does nothing with the payload; sends it raw. 
* Message termination for assembly purposes is signaled by the client closing the 
* connection. The serializer does not, itself, close the connection after 
* writing the bytes. 
* <p> 
* Because the socket must be closed to indicate message end, this (de)serializer 
* can only be used by uni-directional (non-collaborating) channel adapters, and 
* not by gateways.

Ainsi, depuis votre client ne ferme pas la connexion pour la session de fin, vous ne recevez pas la réponse là-bas. Plus sur ce sérialiseur n'est pas pour les passerelles.

Tenir compte pour sélectionner le bon (de) sérialiseur avec terminaison appropriée pour vous: https://docs.spring.io/spring-integration/docs/4.3.12.RELEASE/reference/html/ip.html#connection-factories

Source

2017-10-02 14:29:48

Merci, c'est bien le problème. Mais que puis-je utiliser comme sérialiseur lorsqu'il n'y a pas de valeur de fin? De la doc j'ai la demande ressemble à ceci: 'Par exemple IMEI 356307042441013 serait envoyé comme 000f333536333037303432343431303133 Les deux premiers octets indiquent la longueur IMEI. Dans ce cas, 000F signifie que imei a une longueur de 15 octets. – Phoste

Je ne sais pas. Vous devez négocier avec votre client pour convenir du protocole approprié pour les messages. –

Comment répondre à une demande avec TcpInboundGateway?

Répondre

Questions connexes