org.qbroker.net

Class UDPSocket

java.lang.Object

org.qbroker.net.UDPSocket

public class UDPSocket
extends java.lang.Object

UDPSocket connects an UDP socket for sending and/or receiving Datagram packets. Due to its connectionless feature, you can use the same socket to send and receive packets as long as the outgoing packets having the destination IP address and the prot. Please do not use it to transfer the data more than 8K, since there is no implementation on handling data longer than the buffer size.

Please also be careful on the differences of implementations and Java versions. On Java 1.4, the send() method has implemented ICMP ping if connect() is used. Therefore, you will get PortUnreachableException if you try to send packets to a connected destination where there is no one listening to it. On Java 1.3, there is no such correlation by calling connect(). To establish a connectionless UDPSocket, you can pass hostname as null and set up the socket as a server socket. This will bypass connect() in the initialization. Set address and port to each outgoing packets for sending.

Be careful also on the timeout. If it is set to zero, the block on receive is forever. This may end up dead lock.

This is NOT MT-Safe.

Author:

yannanlu@yahoo.com

Constructor Summary

Constructors

Constructor and Description
UDPSocket(java.lang.String hostname, int port)
UDPSocket(java.lang.String serverName, int serverPort, int bufferSize)
UDPSocket(java.lang.String serverName, int serverPort, java.lang.String hostname, int port, int bufferSize, int timeout)

Method Summary

Modifier and Type	Method and Description
void	close()
java.net.InetAddress	getLocalAddress()
int	getLocalPort()
java.net.DatagramSocket	getSocket()
int	getTimeout()
boolean	isConnected()
static void	main(java.lang.String[] args)
java.lang.String	receive()
void	receive(java.net.DatagramPacket p)
void	receive(XQueue xq) get a used packet from XQ first and send the received packet to XQ if the used packet is null, create a new packet for use
int	reconnect()
void	send(byte[] buffer, int offset, int length)
void	send(java.net.DatagramPacket p)
void	send(java.lang.String text)
void	send(XQueue xq)
void	setSleepTime(int ms)
void	setTimeout(int timeout)
void	setWaitTime(int ms)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UDPSocket

public UDPSocket(java.lang.String hostname,
                 int port)

UDPSocket

public UDPSocket(java.lang.String serverName,
                 int serverPort,
                 int bufferSize)

UDPSocket

public UDPSocket(java.lang.String serverName,
                 int serverPort,
                 java.lang.String hostname,
                 int port,
                 int bufferSize,
                 int timeout)

Method Detail

reconnect

public int reconnect()

close

public void close()

isConnected

public boolean isConnected()

getLocalAddress

public java.net.InetAddress getLocalAddress()

getLocalPort

public int getLocalPort()

getTimeout

public int getTimeout()

getSocket

public java.net.DatagramSocket getSocket()

setTimeout

public void setTimeout(int timeout)

setSleepTime

public void setSleepTime(int ms)

setWaitTime

public void setWaitTime(int ms)

send

public void send(java.net.DatagramPacket p)
          throws java.io.IOException

Throws:

java.io.IOException

send

public void send(byte[] buffer,
                 int offset,
                 int length)
          throws java.io.IOException

Throws:

java.io.IOException

send

public void send(java.lang.String text)
          throws java.io.IOException

Throws:

java.io.IOException

send

public void send(XQueue xq)
          throws java.io.IOException

Throws:

java.io.IOException

receive

public void receive(java.net.DatagramPacket p)
             throws java.io.IOException

Throws:

java.io.IOException

receive

public void receive(XQueue xq)
             throws java.io.IOException

get a used packet from XQ first and send the received packet to XQ if the used packet is null, create a new packet for use

Throws:

java.io.IOException

receive

public java.lang.String receive()
                         throws java.io.IOException

Throws:

java.io.IOException

main

public static void main(java.lang.String[] args)