udp socket demo

/**
 * Message.java
 * 负责信息的发送和接收
 */
package qq.bean;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;


/**
 * @author wuliqiang
 * 用无连接的udp 发送
 */
public class Message {
    
    private static int port;
    
    
    // 成员变量的初始化

    public Message(String strport) {
        port = Integer.parseInt(strport);
    }
    
    
    public String RecvFromRemote()
    {
        DatagramSocket socket = null;
        String strbuf = null;
        
        try {
            socket = new DatagramSocket(port);
        } catch (SocketException e) {
            System.out.println("create socket error!");
            e.printStackTrace();
        }
        
        //set up packet

        byte data[] =new byte[1024];
        DatagramPacket recvPacket = new DatagramPacket(data, data.length);
        try {
            socket.receive(recvPacket);
        } catch (IOException e) {
            System.out.println("receive error!");
            e.printStackTrace();
        }
        
        strbuf= new String(recvPacket.getData(), 0, recvPacket.getData().length);
        
        
        return strbuf.trim();
    }
    
    public void  SentdToRemote(String Ip, String strSend)
    {
        DatagramSocket socket = null;
        InetAddress inetAddr =null;
        try {
            inetAddr = InetAddress.getByName(Ip);
        } catch (UnknownHostException e1) {
            System.err.println("error create inetAddr");
            e1.printStackTrace();
        }
        try {
            socket = new DatagramSocket();
        } catch (SocketException e) {
            System.err.println("create socke error");
            e.printStackTrace();
        }
        
        //set the package

        byte data[] = strSend.getBytes();
        DatagramPacket sendPacket = new DatagramPacket(data, data.length, inetAddr, port );
        try {
            socket.send(sendPacket);
        } catch (IOException e) {
            System.err.println("socket send error!");
            e.printStackTrace();
        }
        
    }

}