TCP传输

Socket和ServerSocket

建立客户端和服务器端（两个独立的应用程序）

建立连接后，通过Socket中的IO流进行数据的传输

关闭Socket

TCP和UDP原理差不多，只是涉及的对象不一样

TCP客户端

public static void TCPDemo() throws UnknownHostException, IOException {
		
		/*
		 * TCP传输，客户端建立
		 * 1.建立TCP客户端socket服务，使用SOCKET对象（建议一创建就明确目的地，要连接的主机）
		 * 2.如果连接建立成功，就说明数据传输通道已建立
		 * 该通道就是SOCKET流，是底层建立好的，因为是流，所以有输入输出，其输入输出流对象，在SOCKET获取
		 * 通过getInputStream()和getOutputStream()来获取两个字节流
		 * 3.使用输出流，将数据写出(网络)
		 * 4.关闭
		 */
		
		//建立客户端SOCKET服务
		Socket socket = new Socket("127.0.0.1",6534);//地址和端口号
		
		//获取SOCKET流中的输出流
		OutputStream os = socket.getOutputStream();
		
		//使用输出流将指定的数据写出
			os.write("tcp客户端发送信息".getBytes());
			
			socket.close();	
	}

public static void TEPserveDeno() throws IOException {
		//服务端接收客户端发来的数据，并打印在控制台
		/*
		 * 建立TCP服务端
		 * 1.建立TCP服务端Socket服务，通过ServerSocket对象
		 * 2.服务端必须对外提供端口，否则客户端无法连接
		 * 3.获取连接过来的客户端对象（重点）
		 * （比如拨打10086人工，一个客户，一个服务人员，客户的数据，客户自己最清楚）
		 * 4.通过客户端对象获取Socket流兑取客户端发来的数据并打印
		 * 5.关闭资源：关闭客户端，关闭服务端
		 */
		//常见服务端对象
		ServerSocket ss = new ServerSocket(6534);
		
		//获取连接过来的客户端对象
		Socket so = ss.accept();//此方法用来获取客户端对象
		String ip = so.getInetAddress().getHostAddress();
		//通过Socket对象获取输入流，读取客户端发来的数据
		InputStream in = so.getInputStream();
		
		byte[] buf = new byte[1024];
		int len = in.read(buf);
		String str = new String(buf,0,len);
		System.out.println("ip : "+ip+"server : "+str);
		
		so.close();//服务端一般是不关闭的
	}

注意：TCP和UDP不一样的是，必须先开启服务端，服务端不打开，客户端就无法访问，而UDP随意

服务端和客户端交互

客户端发送数据过去，服务端返回信息，表示收到

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;

public class Main {
	public static void main(String[] args) throws IOException{
		TCPDemo();
		TCPserveDeno();
	}

	public static void TCPserveDeno() throws IOException {
	
		ServerSocket ss = new ServerSocket(6534);
		
		Socket so = ss.accept();//阻塞式的
		String ip = so.getInetAddress().getHostAddress();
	
		InputStream in = so.getInputStream();
		
		byte[] buf = new byte[1024];
		int len = in.read(buf);
		String str = new String(buf,0,len);
		System.out.println("ip : "+ip+"server : "+str);
		
		//使用客户端Socket对象输出流返回数据
		OutputStream out = so.getOutputStream();
		out.write("收到信息".getBytes());
		
		so.close();
	}

	public static void TCPDemo() throws UnknownHostException, IOException {
		
		Socket socket = new Socket("127.0.0.1",6534);
		
		OutputStream os = socket.getOutputStream();
		
		os.write("tcp客户端发送信息".getBytes());
		
		//读取服务端返回的数据，使用Socket读取流
		InputStream in = socket.getInputStream();
		byte[] buf = new byte[1024];
		int len = in.read(buf);
		String text = new String(buf,0,len);
		System.out.println(text);
		socket.close();	
	}
}

JAVA学习第六十一课 — TCP协议