Hi !<div><br></div><div>I've been using Netty to implement a very simple text-based protocol for a log service, where messages are UTF-8 strings like this:</div><div><br></div><div style="margin-left: 40px;"><font face="'courier new', monospace"><LOG_FILE_PATH>:<JSON_ENCODED_MESSAGE_DATA>\n</font></div>
<div><br></div><div>For instance</div><div><br></div><div style="margin-left: 40px;"><font face="'courier new', monospace">hello/world.log:"Hello, World"\n</font></div><div><br></div><div>would append "Hello, World" to the hello/world.log file.</div>
<div><br></div><div>The problem I have is that it seems that some messages get interwoven, basically just as if the server considered two messages as being part of the same one, and intermixing both. My problem is then: how do I ensure that each message is reliably sent, and that the server does not "interweaves" received messages.</div>
<div><br></div><div>The server is implemented using a ChannelPipelineCoverage("one") SimpleChannelUpstreamHandler. The message aggregation happens in messageReceived, which works like this:</div><div><br></div>
<div style="margin-left: 40px;">
<span style="font-family: courier new,monospace;">if message contains "\n"</span></div><div style="margin-left: 40px; font-family: courier new,monospace;"> write(buffer)</div><div style="margin-left: 40px; font-family: courier new,monospace;">
else</div><div style="margin-left: 40px; font-family: courier new,monospace;"> buffer append (message)</div><div style="margin-left: 40px; font-family: courier new,monospace;">end<br><br></div><div>with a pipeline setup like this<br>
<br><span style="font-family: courier new,monospace;"> p.addLast("decoder", new StringDecoder(CharsetUtil.UTF_8));</span><br><br></div><div>and the client is implemented with the following decoders<br><br>
<span style="font-family: courier new,monospace;"> e.getChannel().getPipeline().addLast("frameDecoder", new DelimiterBasedFrameDecoder(65535, Delimiters.lineDelimiter()(0), Delimiters.lineDelimiter()(1)))</span><br style="font-family: courier new,monospace;">
<span style="font-family: courier new,monospace;"> e.getChannel().getPipeline().addLast("encoder", new StringEncoder(CharsetUtil.UTF_8));</span><br><br>I suppose the problem might be related to the "frameDecoder", which, to be frank, I don't remember why I used it. So what would be the best setup for a high-performance (10+K messages/second) client/server for this simple text protocol ? I could use 0MQ for that, but Netty being pure Java, it's easier to deploy.<br>
<br>Thanks,<br><br> -- Sébastien<br><br></div><div><br>
</div><div><br></div><div><br></div><div><br></div><div><br></div>