udptestb.java~1~

java udp 协议 文件传输

package udpdemob;
import java.net.*;
import java.io.*;

public class UDPTestB extends Thread {
    DatagramSocket sockReceive = null;
    DatagramPacket dpRecive = null;
    byte[] bsRe = new byte[4096];
    String str = "";
    public void run() {
        try {
            sockReceive = new DatagramSocket(10002);
            dpRecive = new DatagramPacket(
                    bsRe, bsRe.length);
            sockReceive.receive(dpRecive);
            str = new String(bsRe);
            System.out.println("recieve data in client B:" + str);
        } catch (Exception ex) {
            System.out.println("ex in recieve B:" +
                               ex.getMessage());
        } finally {
            try {
                sockReceive.close();
            } catch (Exception ex) {
            }
        }
    }

    public static void main(String[] args) {
        Thread th = new UDPTestB();
        DatagramSocket sockSend = null;
        DatagramPacket dpSend = null;
        th.start();
        byte[] bs = null;
        try {
            bs = "i am tester.".getBytes();
            sockSend = new DatagramSocket();
            dpSend = new DatagramPacket(bs, bs.length);
            dpSend.setAddress(
                    InetAddress.getByName("localhost"));
            dpSend.setPort(10001);
            sockSend.send(dpSend);
        } catch (Exception ex) {
            System.out.println("ex in client B:" +
                               ex.getMessage());
        } finally {
            try {
                sockSend.close();
            } catch (Exception ex) {}
        }
    }
}