Udp实现消息的发送和接收、以及图片的上传

//Udp实现消息的发送和接收

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
import java.util.Scanner;

public class UdpUtils implements Runnable {

//定义Socket数据包服务
private DatagramSocket socket;

public UdpUtils(int port) {
try {
//创建socket数据包服务
            socket = new DatagramSocket();
        } catch (SocketException e) {
            e.printStackTrace();
        }
    }

//发送
public void send(String content, String ip, int port) {
//获取接收端 的IP 和 端口号
        InetSocketAddress address = new InetSocketAddress(ip, port); 
//创建数据包  并将 消息内容 、地址 传入
        DatagramPacket dp = new DatagramPacket(content.getBytes(),
                content.getBytes().length,address);
try {
//发送数据包
            socket.send(dp);
try {
                Thread.sleep(1);    //防止Udp传输时，包错误。
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

//接收
    @Override
public void run() {
byte[] buf = new byte[1024];
//创建数据包 将 发送过来的 消息内容 取出
        DatagramPacket dp = new DatagramPacket(buf, buf.length);
while (true) {
try {
//接收数据包
                socket.receive(dp);
//    System.out.println(new String(dp.getData(), 0, dp.getLength()));
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

//Test 测试
class TestUdpUtils{
public static void main(String[] args) {
        UdpUtils utils = new UdpUtils(10010);
        Thread thread = new Thread(utils);
        thread.start();
        Scanner input = new Scanner(System.in);
while(true){
            String msg = input.next();
if(msg.equals("exit")){
                input.close();
                System.exit(0);
            }
            utils.send("Send:" + msg, "127.0.0.1", 10010);
        }
    }
}

 

//Udp实现图片的上传

 

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;

public class UdpMapUtils implements Runnable {

private DatagramSocket socket;
private File file;
private String ip;
private int port;

public UdpMapUtils(File file, String ip, int port) {
this.file = file;
this.ip = ip;
this.port = port;
try {
            socket = new DatagramSocket(port);
        } catch (SocketException e) {
            e.printStackTrace();
        }
    }

public void send(File file) {

        InetSocketAddress address = new InetSocketAddress(ip, port);
//    System.out.println(address);
        BufferedInputStream bis = null;
try {
            bis = new BufferedInputStream(new FileInputStream(file));
byte[] buf = new byte[1024];
while (bis.read(buf) != -1) {
                DatagramPacket dp = new DatagramPacket(buf, buf.length, address);
                socket.send(dp);
                Thread.sleep(2);
            }
byte[] b = "over".getBytes();
            DatagramPacket dp = new DatagramPacket(b, b.length,address);
            socket.send(dp);
        } catch (Exception e) {
            e.printStackTrace();
        } 
finally{
try {
                bis.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            socket.close();
        }
    }

    @Override
public void run() {

        BufferedOutputStream bos = null;

try {
            bos = new BufferedOutputStream(new FileOutputStream(file));
byte[] buf = new byte[1024];
while (true) {
                DatagramPacket dp = new DatagramPacket(buf, buf.length);
                socket.receive(dp);
if(new String(buf,0,dp.getLength()).equals("over"))
break;
                bos.write(buf);
                bos.flush();
            }
        } catch (Exception e) {
            e.printStackTrace();
        } 
finally {
try {
                bos.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            socket.close();
        }
    }
}