Java网络编程中的TCP/UDP详解

package com.lanou.test;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class TCPServer {
	public static void main(String[] args) {
		//JAVA的TCP编程中，BIO模型使用一个工具实现TCP编程，这个工具叫做Socket，服务端叫ServerSocket,
		try {
			ServerSocket ss = new ServerSocket(65535);//这个端口号 写死 固定的
			//这个是客户端发送上来的链接，服务器使用这个链接做数据处理
			Socket s = ss.accept();
			//分别是两个指针对当前联机的输入输出流
			OutputStream os = s.getOutputStream();
			InputStream is = s.getInputStream();			
			//改变输入输出流的状态（套一个其它流）
			PrintWriter pw = new PrintWriter(os);
			Scanner scanner = new Scanner(System.in);
			BufferedReader br = new BufferedReader(new InputStreamReader(is));
			while(true) {
				String str= scanner.nextLine();	//nextline  阻塞式代码
				pw.println(str);
				pw.flush();
				if(str.equals("")) {
					break;
				}
				str = br.readLine();
				System.out.println("我是服务器，我收到客户端消息" + str);
				if(str.equals("")) {
					break;
				}	
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

package com.lanou.test;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
public class TCPClient {
	public static void main(String[] args) {
		//客户端，直接使用Sockert工具
		try {
			Socket s = new Socket("127.0.0.1", 65535);
			// host  链接到那个主机上 String的参数       port端口 
			InputStream is = s.getInputStream();
			OutputStream os = s.getOutputStream();
			BufferedReader br = new BufferedReader(new InputStreamReader(is));
			PrintWriter pw = new PrintWriter(os);
			Scanner scanner = new Scanner(System.in);
			String str;
			while(!(str = br.readLine()).equals("")) {	
				System.out.println("客户端收到"+str);
				str = scanner.nextLine();
				pw.println(str);
				pw.flush();
				if(str.equals("")) {
					break;
				}
			}
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

package com.lanou.udp;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
public class UDP {
	public static void main(String[] args) {
		//UDP是面向报文的，所以数据传输过程中，是不需要建立链接的，只要有对应的报文，就可以指挥网卡去发送这个数据包
		//但是对于服务器来说，UDP虽然没有建立链接，却需要在对应的端口上进行监听，否则是有问题的
		//DatagramSocket,这个类型是JAVA对于UDP实现的一个网络套接字，当我们需要使用UDP传输内容的时候，只需要创建一个
		//DatagramSocket,对象就可以了，不用指定这个对象是否是服务（区别TCP的ServerSocket）	
		try {
			DatagramSocket socket = new DatagramSocket(10086);
			byte[] b = new byte[1024];
			DatagramPacket p =new DatagramPacket(b, b.length);
			while(true) {
				socket.receive(p);
				b = p.getData();//拿出数据 拆开包裹
				System.out.println(new String(b));	
				System.out.println(p.getAddress() + "说 ： " + new String(b));
				p.setData("你开心就好".getBytes());
				socket.send(p);
			}		
		} catch (SocketException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

package com.lanou.udp;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.net.SocketException;
public class UDPClient {
	public static void main(String[] args) {
		try {
			DatagramSocket socket = new DatagramSocket();
			String str = "我是客户端  ";
			DatagramPacket p = new DatagramPacket(str.getBytes(), str.getBytes().length);
			p.setSocketAddress(new InetSocketAddress("127.0.0.1", 10086));
			socket.send(p);
			socket.receive(p);
			System.out.println(new String(p.getData()));
		} catch (SocketException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}		
	}
}