java udp协议请求demo

package com.local.hr.udp;

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.SocketException;

import java.util.Collections;

import java.util.HashSet;

import java.util.List;

import java.util.Set;

import com.local.hr.util.EdHrCode;

import com.local.hr.util.ReturnEntity;

import com.local.socket.osm.OseamControl;

public class UdpClientSocket extends Thread{
private byte[] buffer = new byte[1024];  
private String serverHost;
private int serverPort = 9881;

    private DatagramSocket ds = null;  

    private Set<ReturnEntity> data = Collections.synchronizedSet(new HashSet<ReturnEntity>());//保证线程安全

    private EdHrCode code = new EdHrCode();

    private boolean read =true;

    

    /** 

     * 构造函数，创建UDP客户端 

     */  

    public UdpClientSocket(String serverHost) throws Exception {  

    this.serverHost = serverHost;

        ds = new DatagramSocket(); // 邦定本地端口作为客户端  

    }  

      

    /** 

     * 测试客户端发包和接收回应信息的方法 

     */  

    public static void main(String[] args) throws Exception {  

        UdpClientSocket client = new UdpClientSocket("192.168.1.255"); 

        System.out.println("线程状态 :"+client.getState());

        client.start();

        InetAddress address = InetAddress.getLocalHost();

        String ip = address.getHostAddress();

        System.out.println("");

        client.send(getData("aa3b00ffffffffffff000003015a485238303030373832414730393100000000000000000000000000000000000032414730393100000000000000000000d155"));  

        // 关闭  

        boolean bool= true;

        System.out.println("线程状态 :"+client.getState());

        for (int i = 0; i < 5; i++) {

        if (client.getData().size()>0) {

        try {  

        client.setRead(false);

        client.getDs().close();//停掉udp客户端

        bool=false;

                } catch (Exception ex) {  

                    ex.printStackTrace();  

                } 

        System.out.println("线程状态 :"+client.getState());

        break;
}
Thread.sleep(1000);//时间到了也要停掉
}

        if (bool) {

    try {  

    client.setRead(false); 

    client.getDs().close();//停掉udp客户端

    bool=false;

            } catch (Exception ex) {  

                ex.printStackTrace();  

            } 
}

        for (ReturnEntity en : client.getData()) {

        List<String> list = en.getData();
if (list!=null&&list.size()>0) {
for (int i = 0; i < list.size(); i++) {
System.out.println(list.get(i));
}
}
}

    }  

    

    private static byte[] getData(String s) {

    return OseamControl.hexStr2ByteArray(s);
}

    

    @Override

    public void run() {

    while(this.isRead()) {
try {
this.receive();
} catch (Exception e) {
if (e instanceof SocketException) {
break;
}
try {
this.sleep(200);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
}
}

    }

  

 

      

    /** 

     * 向指定的服务端发送数据信息 

     */  

    public final void send(

            final byte[] bytes) throws IOException {  

        DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress.getByName(serverHost), serverPort);  

        ds.send(dp);  

    }  

  

    /** 

     * 接收从指定的服务端发回的数据 

     */  

    public void receive()  

            throws Exception {  

        DatagramPacket dp = new DatagramPacket(buffer, buffer.length);  

        ds.receive(dp);       

        byte[] data = new byte[dp.getLength()];  

        System.arraycopy(dp.getData(), 0, data, 0, dp.getLength());       

        String s= OseamControl.bytesToHexString(data);

        ReturnEntity entity =code.caseControlCode("5a", s);

        if (entity.getStatus()==ReturnEntity.DATA_STATUS_NORMAL) {

        this.data.add(entity);
}

    }

public String getServerHost() {
return serverHost;
}

public void setServerHost(String serverHost) {
this.serverHost = serverHost;
}

public Set<ReturnEntity> getData() {
return data;
}

public DatagramSocket getDs() {
return ds;
}

public boolean isRead() {
return read;
}

public void setRead(boolean read) {
this.read = read;
}

    

}