UDP程序测试代码,Java代码库,德仔网

代码语言
代码分类
【Java】 UDP程序测试
作者: / 发布于2011/1/14/ 417
<div><span style="color: #0000ff">package</span><span style="color: #000000"> com.tz.simple.udp;

</span><span style="color: #0000ff">import</span><span style="color: #000000"> java.io.IOException;
</span><span style="color: #0000ff">import</span><span style="color: #000000"> java.net.DatagramPacket;
</span><span style="color: #0000ff">import</span><span style="color: #000000"> java.net.DatagramSocket;
</span><span style="color: #0000ff">import</span><span style="color: #000000"> java.net.InetAddress;
</span><span style="color: #0000ff">import</span><span style="color: #000000"> java.util.Date;
</span><span style="color: #0000ff">import</span><span style="color: #000000"> java.util.concurrent.ExecutorService;
</span><span style="color: #0000ff">import</span><span style="color: #000000"> java.util.concurrent.Executors;

</span><span style="color: #0000ff">import</span><span style="color: #000000"> com.tz.uitl.Common;

</span><span style="color: #008000">/**</span><span style="color: #008000">
* UDP程序测试<BR>
* 时间服务器，采用线程池处理<BR>
* 
* </span><span style="color: #808080">@author</span><span style="color: #008000"> LJZ
* 
</span><span style="color: #008000">*/</span><span style="color: #000000">
</span><span style="color: #0000ff">public</span><span style="color: #000000"> </span><span style="color: #0000ff">class</span><span style="color: #000000"> UDPTimeServer </span><span style="color: #0000ff">extends</span><span style="color: #000000"> Thread {
 </span><span style="color: #0000ff">final</span><span style="color: #000000"> </span><span style="color: #0000ff">private</span><span style="color: #000000"> </span><span style="color: #0000ff">static</span><span style="color: #000000"> </span><span style="color: #0000ff">int</span><span style="color: #000000"> DAYTIME_PORT </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #000000">7897</span><span style="color: #000000">;

 </span><span style="color: #0000ff">private</span><span style="color: #000000"> DatagramSocket serverSocket </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #0000ff">null</span><span style="color: #000000">;

 </span><span style="color: #0000ff">private</span><span style="color: #000000"> </span><span style="color: #0000ff">final</span><span style="color: #000000"> </span><span style="color: #0000ff">int</span><span style="color: #000000"> THREAD_POOL </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #000000">10</span><span style="color: #000000">;

 </span><span style="color: #0000ff">private</span><span style="color: #000000"> ExecutorService threadPool </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #0000ff">null</span><span style="color: #000000">;

 </span><span style="color: #0000ff">public</span><span style="color: #000000"> UDPTimeServer() </span><span style="color: #0000ff">throws</span><span style="color: #000000"> IOException {
 serverSocket </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #0000ff">new</span><span style="color: #000000"> DatagramSocket(DAYTIME_PORT);
 threadPool </span><span style="color: #000000">=</span><span style="color: #000000"> Executors.newFixedThreadPool(THREAD_POOL);
 System.out.println(</span><span style="color: #000000">"</span><span style="color: #000000">时间服务器启动成功,监听端口 [</span><span style="color: #000000">"</span><span style="color: #000000"> </span><span style="color: #000000">+</span><span style="color: #000000"> DAYTIME_PORT </span><span style="color: #000000">+</span><span style="color: #000000"> </span><span style="color: #000000">"</span><span style="color: #000000">] 线程池 [</span><span style="color: #000000">"</span><span style="color: #000000">
 </span><span style="color: #000000">+</span><span style="color: #000000"> THREAD_POOL </span><span style="color: #000000">+</span><span style="color: #000000"> </span><span style="color: #000000">"</span><span style="color: #000000">].</span><span style="color: #000000">"</span><span style="color: #000000">);
 }

 </span><span style="color: #0000ff">public</span><span style="color: #000000"> </span><span style="color: #0000ff">void</span><span style="color: #000000"> run() {
 </span><span style="color: #0000ff">while</span><span style="color: #000000"> (</span><span style="color: #0000ff">true</span><span style="color: #000000">) {
 </span><span style="color: #0000ff">try</span><span style="color: #000000"> {
 </span><span style="color: #0000ff">byte</span><span style="color: #000000"> buffer[] </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #0000ff">new</span><span style="color: #000000"> </span><span style="color: #0000ff">byte</span><span style="color: #000000">[</span><span style="color: #000000">256</span><span style="color: #000000">];
 DatagramPacket packet </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #0000ff">new</span><span style="color: #000000"> DatagramPacket(buffer,
 buffer.length);
 serverSocket.receive(packet);
 System.out.println(</span><span style="color: #000000">"</span><span style="color: #000000">收到客户端 [</span><span style="color: #000000">"</span><span style="color: #000000"> </span><span style="color: #000000">+</span><span style="color: #000000"> packet.getSocketAddress()
 </span><span style="color: #000000">+</span><span style="color: #000000"> </span><span style="color: #000000">"</span><span style="color: #000000"> ] 请求.</span><span style="color: #000000">"</span><span style="color: #000000">);
 threadPool.execute(</span><span style="color: #0000ff">new</span><span style="color: #000000"> HandlerThread(packet));
 } </span><span style="color: #0000ff">catch</span><span style="color: #000000"> (Exception e) {

 }
 }
 }

 </span><span style="color: #008000">/**</span><span style="color: #008000">
 * 客户端数据处理线程
 * 
 * </span><span style="color: #808080">@author</span><span style="color: #008000"> LJZ
 * 
 </span><span style="color: #008000">*/</span><span style="color: #000000">
 </span><span style="color: #0000ff">private</span><span style="color: #000000"> </span><span style="color: #0000ff">class</span><span style="color: #000000"> HandlerThread </span><span style="color: #0000ff">extends</span><span style="color: #000000"> Thread {
 </span><span style="color: #0000ff">private</span><span style="color: #000000"> DatagramPacket packet </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #0000ff">null</span><span style="color: #000000">;

 </span><span style="color: #0000ff">public</span><span style="color: #000000"> HandlerThread(DatagramPacket p) {
 packet </span><span style="color: #000000">=</span><span style="color: #000000"> p;
 }

 </span><span style="color: #0000ff">public</span><span style="color: #000000"> </span><span style="color: #0000ff">void</span><span style="color: #000000"> run() {
 </span><span style="color: #0000ff">try</span><span style="color: #000000"> {
 String date </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #0000ff">new</span><span style="color: #000000"> Date().toString();
 </span><span style="color: #0000ff">byte</span><span style="color: #000000">[] buffer </span><span style="color: #000000">=</span><span style="color: #000000"> date.getBytes();

 InetAddress address </span><span style="color: #000000">=</span><span style="color: #000000"> packet.getAddress();
 </span><span style="color: #0000ff">int</span><span style="color: #000000"> port </span><span style="color: #000000">=</span><span style="color: #000000"> packet.getPort();
 packet </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #0000ff">new</span><span style="color: #000000"> DatagramPacket(buffer, buffer.length, address,
 port);
 serverSocket.send(packet);

 System.out.println(</span><span style="color: #000000">"</span><span style="color: #000000">线程 [</span><span style="color: #000000">"</span><span style="color: #000000"> </span><span style="color: #000000">+</span><span style="color: #000000"> getName() </span><span style="color: #000000">+</span><span style="color: #000000"> </span><span style="color: #000000">"</span><span style="color: #000000">] 向客户端 [</span><span style="color: #000000">"</span><span style="color: #000000">
 </span><span style="color: #000000">+</span><span style="color: #000000"> packet.getSocketAddress() </span><span style="color: #000000">+</span><span style="color: #000000"> </span><span style="color: #000000">"</span><span style="color: #000000"> ] 发送数据 [</span><span style="color: #000000">"</span><span style="color: #000000">
 </span><span style="color: #000000">+</span><span style="color: #000000"> Common.byte2string(buffer, </span><span style="color: #0000ff">false</span><span style="color: #000000">) </span><span style="color: #000000">+</span><span style="color: #000000"> </span><span style="color: #000000">"</span><span style="color: #000000">].</span><span style="color: #000000">"</span><span style="color: #000000">);
 } </span><span style="color: #0000ff">catch</span><span style="color: #000000"> (Exception e) {

 } </span><span style="color: #0000ff">finally</span><span style="color: #000000"> {
 packet </span><span style="color: #000000">=</span><span style="color: #000000"> </span><span style="color: #0000ff">null</span><span style="color: #000000">;
 }
 }
 }

 </span><span style="color: #0000ff">public</span><span style="color: #000000"> </span><span style="color: #0000ff">static</span><span style="color: #000000"> </span><span style="color: #0000ff">void</span><span style="color: #000000"> main(String args[]) </span><span style="color: #0000ff">throws</span><span style="color: #000000"> IOException {
 </span><span style="color: #0000ff">new</span><span style="color: #000000"> UDPTimeServer().start();
 }
}
</span>
</div>
试试其它关键字
同语言下
可能有用的
贡献的其它代码Label