Oh, my bad, I've sent you TCP sample.
Here is the UDP one.
WBR,
Alexey.
On Aug 12, 2010, at 20:49 , SATHISH SANTHANAM wrote:
> Hello,
>
> I am trying to get a UDP server working with grizzly. The server
> needs to send the response asynchronously - meaning, the UDP message
> is read in the filter's handleRead(). But, the response will be sent
> by a different thread later.
>
> When we send the response, we want to set the source address to the
> same port where the UDP server is receiving requests (so that the
> client will see the response coming from the same destination where
> it sent the request).
>
> My question is - When a thread is ready to send the response, what
> is the correct way to send it? Should it call
>
> transport.connect(remote, local)
> connection.getStreamWriter()
> writer.writeByteArray()
>
> When I do the above, I see some issues - some incoming messages to
> the server are getting lost. I am wondering whether this is due to
> the fact that I am binding another socket to the same local port (as
> part of transport.connect above), but, I am using that socket only
> for write purpose, no read is done on it.
> If I use the same connection object which is available in
> handleRead(), then, things seem to work fine. But, I would like to
> avoid it if possible, because, I don't want to keep a map of all the
> connections for which response is pending.
>
> If the above is not the correct way, can you suggest the correct way
> to handle the above scenario? Thank you.
>
> Sathish
>
> My code is something like this:
>
> transport = UDPTransportFactory.createTransport();
> transport.getFilterChain().add(new UDPFilter());
> transport.bind(host, port);
> transport.start();
>
> class UDPFilter extends FilterAdapter {
> public NextAction handleRead(final FilterChainContext ctx, final
> NextAction nextAction) {
> //read the message from the connection
> InetSocketAddress address = (InetSocketAddress) ctx.getAddress();
> Buffer messageBuffer = (Buffer) ctx.getMessage();
> final byte[] data = new byte[messageBuffer.remaining()];
> messageBuffer.get(data);
> new Thread(new MyRunnable(data, address)).start();
> return nextAction;
> }
>
> class MyRunnable implements Runnable {
> public void run() {
> //prepare the response and send it to the client
> //what is the correct way to do this? - Should I use the same
> transport, same/new connection?
> transport.connect(remote, local) //local address is same as the
> where we bound the server to
> connection.getStreamWriter()
> writer.writeByteArray()
> connection.close()
> }
>
> Thank you.
>
> Sathish
>
>
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>