Hi Trustin,<br><br>some more information about my setup:<br><br>I have about 3000 NE (Client), which connect to the server. The connections are persistent, i.e the connections are never meant to be closed. you may keep the connections open forever. and send a message from the client every 20 seconds. <br>
<br>As soon as the client&#39;s connection is accepted (i.e TCP handshake is finished), the client will start sending the messages from its queue, on an average the queue size would be 5 messages. so you may want to replicate this behavior as well. <br>
<br>E.g:<br>1. Client connects to the server.<br>2. Client sends Message M1, waits for the server to acknowledge the message (timeout is 5 secs).<br>3. if the server fails to acknowledge the message within 5 seconds, then the client re-sends the same message. Else sends the next message.<br>
4. The acknowledgment from server to client is at application level, you may replicate by echoing the same message.<br><br>I am running Sun Solaris 10, with Sun&#39;s hotspot JVM 1.5.<br><br>Please let me know if you need more information on my setup.<br>
<br>Thanks,<br><br>Virat<br><br clear="all">I will either find a way or make one.<br>
<br><br><div class="gmail_quote">On Thu, Jun 18, 2009 at 6:04 PM, &quot;ÀÌÈñ½Â (Trustin Lee)&quot; <span dir="ltr">&lt;<a href="mailto:trustin@gmail.com">trustin@gmail.com</a>&gt;</span> wrote:<br><blockquote class="gmail_quote" style="border-left: 1px solid rgb(204, 204, 204); margin: 0pt 0pt 0pt 0.8ex; padding-left: 1ex;">
Do I need to keep handshaking making a new connection every time for 20<br>
minutes, or just keep the connection open and keep sending messages?<br>
<div><div></div><div class="h5"><br>
On 2009-06-18 ¿ÀÈÄ 8:45, Virat Gohil wrote:<br>
&gt;<br>
&gt; Hi All,<br>
&gt;<br>
&gt; I am getting the following exception after about 20 minutes of running time<br>
&gt; using my server:<br>
&gt;<br>
&gt; &nbsp;EXCEPTION: javax.net.ssl.SS<br>
&gt; LException: illegal change cipher spec msg, state = 6<br>
&gt; javax.net.ssl.SSLException: illegal change cipher spec msg, state = 6<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at com.sun.net.ssl.internal.ssl.Alerts.getSSLException(Unknown<br>
&gt; Source)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at com.sun.net.ssl.internal.ssl.SSLEngineImpl.fatal(Unknown Source)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at com.sun.net.ssl.internal.ssl.SSLEngineImpl.fatal(Unknown Source)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at com.sun.net.ssl.internal.ssl.SSLEngineImpl.readRecord(Unknown<br>
&gt; Source)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at com.sun.net.ssl.internal.ssl.SSLEngineImpl.readNetRecord(Unknown<br>
&gt; Source)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at com.sun.net.ssl.internal.ssl.SSLEngineImpl.unwrap(Unknown Source)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at javax.net.ssl.SSLEngine.unwrap(Unknown Source)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:699)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.handler.ssl.SslHandler.decode(SslHandler.java:445)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:244)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:184)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:87)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:344)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:331)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:303)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:255)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:176)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at<br>
&gt; org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.java:49)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown<br>
&gt; Source)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown<br>
&gt; Source)<br>
&gt; &nbsp; &nbsp; &nbsp; &nbsp; at java.lang.Thread.run(Unknown Source)<br>
&gt;<br>
&gt; I am attaching an example server along with this email, the clients may send<br>
&gt; any random string with ascii char (0x04) as delimiter.<br>
&gt;<br>
&gt; <a href="http://n2.nabble.com/file/n3104250/NioServer.tar.bz2" target="_blank">http://n2.nabble.com/file/n3104250/NioServer.tar.bz2</a> NioServer.tar.bz2<br>
&gt;<br>
&gt; Kindly suggest a solution or cause to this issue.<br>
&gt;<br>
&gt; Thanks,<br>
&gt;<br>
&gt; Virat<br>
<br>
<br>
--<br>
</div></div>&mdash; Trustin Lee, <a href="http://gleamynode.net/" target="_blank">http://gleamynode.net/</a><br>
<br>
<br>_______________________________________________<br>
netty-users mailing list<br>
<a href="mailto:netty-users@lists.jboss.org">netty-users@lists.jboss.org</a><br>
<a href="https://lists.jboss.org/mailman/listinfo/netty-users" target="_blank">https://lists.jboss.org/mailman/listinfo/netty-users</a><br>
<br></blockquote></div><br>