Java server using spring-integration-ip

Question

The server use java,and communicate with C++ clients via TCP. WHen the user leaves computer over 5 minutes,the client will send a byte array to the server.The java server is written by spring-integration-ip.I confused if I should set using-nio="true" ?Is there any problem about concurrency?HOW I trasform the byte array using custom protocol?I'm new to TCP and spring-integration,thanks for your helps!

I hava encounter a problem when I write my app follow the sample.The server deserialize the byte stream and then echo the service,but the client can't receive the serialized byte stream after the echo service return.

spring-tcp.xml:

<int-ip:tcp-connection-factory 
     id="serverConnectionFactory"
     type="server" port="5678" 
     using-nio="true" 
     serializer="connectionSerializeDeserialize"
     deserializer="connectionSerializeDeserialize" />

<bean id="connectionSerializeDeserialize" 
      class="com.snail.tcp.CustomSerializerDeserializer" />

<int-ip:tcp-inbound-gateway id="gatewayCrLf"
    connection-factory="serverConnectionFactory" request-channel="toSA"
    error-channel="errorChannel" />

<int:channel id="toSA" />

<int:service-activator input-channel="toSA"
    ref="echoService" method="test" />
<bean id="echoService" class="com.snail.tcp.EchoService" />

(de)serialize method:

private static final int LENGTH = 2;
private static final int FLAG = 2;


@Override
public String deserialize(InputStream is) throws IOException {
    logger.debug("begin deserialize");
    int length = Integer.valueOf(parseString(is, LENGTH));
    int flag = Integer.valueOf(parseString(is, FLAG));
    String content = parseString(is, length);
    return content;
}

@Override
public void serialize(String s, OutputStream os) throws IOException {
    logger.debug("begin serialize:" + s);
    byte[] content = s.getBytes();
    os.write(content);
    os.flush();
}

echo service:

 public String test(String input) {
    logger.debug("echo service:" + input);
    //some service...
    return "echo:" + input;
}

main method:

 public static void main(String[] args) {
    Socket socket = null;
    Writer out = null;
    BufferedReader in=null;
    try {
        socket = new Socket("127.0.0.1", 5678);
        socket.setSoTimeout(10000);
        out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        out.write("1001HELLOWORLD");
        out.flush();

        in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        StringBuffer str = new StringBuffer();
        int c;
        while ((c = in.read()) != -1) {
            str.append((char) c);
        }
        System.out.println(str.toString());
    } catch (UnknownHostException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    } finally {
        try {
            out.close();
            in.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

the console log:

[DEBUG] com.snail.tcp.CustomSerializerDeserializer-deserialize(): begin deserialize

[DEBUG] com.snail.tcp.EchoService-test(): echo service:HELLOWORLD

[DEBUG] com.snail.tcp.CustomSerializerDeserializer-serialize(): begin serialize:echo:HELLOWORLD

but the client can't receive the deserialized message 'HELLOWORLD',instead a SocketTimeoutException: Read timed out... I want to know where i did wrong,thx a lot

You are asking lots of different questions here and not providing much detail. I would suggest you break this down into separate questions and in each, provide some details on what you have tried so far, what you want to do, and exactly what is goign wrong. — SimonC
– SimonC, Commented Oct 31, 2013 at 2:22

Gary Russell · Accepted Answer · 2013-10-31 02:48:52Z

3

The framework takes care of concurrency; you generally only need NIO if you are supporting a large number of clients; for a small number of clients, NIO is generally not needed.

You can either use a custom (de)serializer or put a transformer downstream of the inbound endpoint.

I suggest you read the Documentation, look at the samples and come back with more specific questions if you still have any.

answered Oct 31, 2013 at 2:48

Gary Russell

176k14 gold badges168 silver badges194 bronze badges

Sign up to request clarification or add additional context in comments.

5 Comments

Leo Xu Over a year ago

Thanks for your advice.Would you please figure out the problem above.

Gary Russell Over a year ago

Probably means the serializer is not terminating the message in the way the client expects; do you see a logger.debug("Message sent " + message); log?. It should appear after your serializer DEBUG message. Your inbound message has structure but your outbound just sends the raw data. Doesn't the client expect some structure? You may have to run Wireshark or similar to look at exactly what is being sent.

Leo Xu Over a year ago

I debug my server.When it execute os.write(content) in serialize() method ,it raise a java.nio.channels.ClosedChannelException.I only want to return a simple string such as "SUCCESS" to the client instead of a structure.Can i realize this in the serialize() method or other place?

Gary Russell Over a year ago

You can send whatever you want (or your client needs); it just looked odd to me. If you are getting a ChannelClosedException, the channel is, er, closed. Probably by the client. If you turn on DEBUG logging all the connection open/close activity will be logged.

Leo Xu Over a year ago

I have solved the problem.I only change out.flush() to out.close(),and the client can receive the message!I think it seems to be the server didn't know the end of the message,so it results in a time out. Thank you for the same

Collectives™ on Stack Overflow

Java server using spring-integration-ip

1 Answer 1

5 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

5 Comments

Your Answer

Sign up or log in

Post as a guest

Related