四、UDP传输应用

发送端：

需求：通过udp传输方式，将一段文字数据发送出去。定义一个udp发送端。

思路：

1，建立updsocket服务。

2，提供数据，并将数据封装到数据包中。

3，通过socket服务的发送功能，将数据包发出去。

4，关闭资源。

class UdpSend {  

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

        // 1，创建udp服务。通过DatagramSocket对象。  

        DatagramSocket ds = new DatagramSocket(8888);  

        // 2，确定数据，并封装成数据包。DatagramPacket(byte[] buf, int length, InetAddress  

        // address, int port)  

        byte[] buf = "udp ge men lai le ".getBytes();  

        DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.1.254"), 10000);  

        // 3，通过socket服务，将已有的数据包发送出去。通过send方法。  

        ds.send(dp);  

        // 4，关闭资源。  

        ds.close();  

    }  

}  

接收端：

需求：

定义一个应用程序，用于接收udp协议传输的数据并处理的。

定义udp的接收端。

思路：

1，定义udpsocket服务。通常会监听一个端口。其实就是给这个接收网络应用程序定义数字标识。方便于明确哪些数据过来该应用程序可以处理。

2，定义一个数据包，因为要存储接收到的字节数据。

因为数据包对象中有更多功能可以提取字节数据中的不同数据信息。

3，通过socket服务的receive方法将收到的数据存入已定义好的数据包中。

4，通过数据包对象的特有功能。将这些不同的数据取出。打印在控制台上。

5，关闭资源。

class UdpRece {  

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

        // 1,创建udp socket，建立端点。  

        DatagramSocket ds = new DatagramSocket(10000);  

        while (true) {  

            // 2,定义数据包。用于存储数据。  

            byte[] buf = new byte[1024];  

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

            // 3，通过服务的receive方法将收到数据存入数据包中。  

            ds.receive(dp);// 阻塞式方法。  

  

            // 4，通过数据包的方法获取其中的数据。  

            String ip = dp.getAddress().getHostAddress();  

            String data = new String(dp.getData(), 0, dp.getLength());  

            int port = dp.getPort();  

            System.out.println(ip + "::" + data + "::" + port);  

        }  

        // 5，关闭资源  

        // ds.close();  

    }  

}  

五、利用线程技术使多个客户端同时并发访问服务端

//客户端：利用线程技术  

class PicThread implements Runnable {  

    private Socket s;  

  

    PicThread(Socket s) {  

        this.s = s;  

    }  

  

    public void run() {  

        int count = 1;  

        String ip = s.getInetAddress().getHostAddress();  

        try {  

            System.out.println(ip + "....connected");  

            InputStream in = s.getInputStream();  

            File dir = new File("d:\\pic");  

            File file = new File(dir, ip + "(" + (count) + ")" + ".jpg");  

            while (file.exists())  

                file = new File(dir, ip + "(" + (count++) + ")" + ".jpg");  

            FileOutputStream fos = new FileOutputStream(file);  

            byte[] buf = new byte[1024];  

            int len = 0;  

            while ((len = in.read(buf)) != -1) {  

                fos.write(buf, 0, len);  

            }  

            OutputStream out = s.getOutputStream();  

            out.write("上传成功".getBytes());  

            fos.close();  

            s.close();  

        } catch (Exception e) {  

            throw new RuntimeException(ip + "上传失败");  

        }  

    }  

}  

  

// 服务端  

class PicServer {  

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

        ServerSocket ss = new ServerSocket(10007);  

        while (true) {  

            Socket s = ss.accept();  

            new Thread(new PicThread(s)).start();  

  

        }  

        // 不必关闭，等待下一个客户端的访问  

        // ss.close();  

    }  

}  

大家苦一点，学好就行了！！！