UDP和TCP

public class UdpSend {
	public static void main(String[] args) throws Exception {
		// 创建UDP服务 通过DatagramSocket对象
		DatagramSocket ds = new DatagramSocket();
		// 确定数据并封装成数据包
		byte[] data = "你好".getBytes();
		DatagramPacket dp = new DatagramPacket(data, data.length,
				InetAddress.getByName("10.13.241.240"), 10000);
		// 发送数据
		ds.send(dp);
		// 关闭服务
		ds.close();
	}
}

接收端

public class UdpRece {
	public static void main(String[] args) throws Exception {
		// 1、创建udpsocket建立端点
		DatagramSocket ds = new DatagramSocket(10000);
		// 2、定义数据包，用于存储数据
		while (true) {
			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);
		}
//		ds.close();//如果要一直接收数据，服务不要关
	}
}

TCP传输

Tcp分客户端和服务端 客户端对应Socket 服务端对应ServerSocket 
建立客户端和服务器端
建立连接后，通过Socket中的IO流进行数据的传输
关闭socket
同样，客户端与服务器端是两个独立的应用程序。

public class TcpClient {
	public static void main(String[] args) throws UnknownHostException, IOException {
		Socket socket=new Socket("10.13.241.240", 10000);
		//为了发送数据，应该获取cocket流中的输出流
		OutputStream out=socket.getOutputStream();
		out.write("nihao".getBytes());
		//为了接受数据，应该获取cocket流中的输入流
		InputStream in=socket.getInputStream();
		byte [] buf=new byte[1024];
		int len=in.read(buf);
		System.out.println(new String (buf,0,len));
		socket.close();
	}
}

服务端

public class TcpServer {
	public static void main(String[] args) throws UnknownHostException, IOException {
		// 建立服务端的scoket服务，并监听一个端口
		ServerSocket server = new ServerSocket(10000);
		//通过accept方法获取连接过来的客户端对象
		Socket socket = server.accept();
		String ip=socket.getInetAddress().getHostAddress();
		System.out.println(ip+"....connect");
		//获取客户端发过来的数据，那么要使用对象的读取流来读取数据
		InputStream is=socket.getInputStream();
		byte buf[]=new byte[1024];
		int len=is.read(buf);
		System.out.println(new String(buf,0,len));
		//通过输出流想客户端发送数据
		OutputStream out=socket.getOutputStream();
		out.write("niyehao".getBytes());
		socket.close();
		server.close();
	}
}

通过客户端上传文件到服务器

public class UploadClient {
	public static void main(String[] args) throws UnknownHostException, IOException {
		Socket s = new Socket("10.13.252.9", 10003);
		//定义读取文件对象。
		BufferedInputStream bis=new BufferedInputStream(new FileInputStream("C:\\testjava\\222.mp3"));
		//定义目的，将数据写入到socket输出流。发给服务端。
		BufferedOutputStream bos=new BufferedOutputStream(s.getOutputStream());
		
		int len=0;
		while((len=bis.read())!=-1){
			bos.write(len);
		}
		s.shutdownOutput();//关闭客户端的输出流。相当于给流中加入一个结束标记-1.
		//定义一个socket读取流，读取服务端返回的信息。
		BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));

		String str = bufIn.readLine();
		System.out.println(str);
		bis.close();
		s.close();
	}
}

服务端代码

public class UploadServer {

	public static void main(String[] args) throws IOException {
		ServerSocket ss = new ServerSocket(10003);
		Socket s = ss.accept();
		String ip = s.getInetAddress().getHostAddress();
		System.out.println(ip+"....connected");
		//读取socket读取流中的数据。
		InputStream in=s.getInputStream();
		//目的socket输出流。写入到socket输出流
		BufferedOutputStream bos=new BufferedOutputStream(new FileOutputStream("C:\\testjava\\server.mp3"));
		
		int len=0;
		while((len=in.read())!=-1){
			bos.write(len);
		}
		PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
		pw.println("上传成功");
		bos.close();
		s.close();
		ss.close();
	}
}