一.通过Socket实现TCP编程
1.1 TCP编程
TCP协议是面向连接，可靠的，有序的，以字节流的方式发送数据。基于TCP协议实现网络通信的类有客户端的Socket类和服务器端的ServerSocket类。
1.2 服务器端套路
1.创建ServerSocket对象，绑定监听端口。
2.通过accept（）方法监听客户端请求。
3.连接建立后，通过输入流读取客户端发送的请求信息。
4.通过输出流向客户端发送响应信息。
5.关闭响应的资源。
1.3 客户端套路
1.创建Socket对象，指明需要连接的服务器的地址和端口号。
2.连接建立后，通过输出流向服务器发送请求信息。
3.通过输入流获取服务器响应的信息。
4.关闭相应资源。
1.4 多线程实现服务器与多客户端之间通信步骤
1.服务器端创建ServerSocket，循环调用accept（）等待客户端连接。
2. 客户端创建一个socket并请求和服务器端连接。
3.服务器端接受客户端请求，创建socket与该客户建立专线连接。
4.建立连接的两个socket在一个单独的线程上对话。
5.服务器端继续等待新的连接。
1.5 创建处理线程类ServerThread
这里选择实现runnable接口而不是继承Thread是因为一个类只能继承一个父类，当我需要继承其他类的时，父类就就不好处理了。
package com.linuxidc; 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; public class ServerThread implements Runnable{ Socket socket = null;//和本线程相关的Socket public ServerThread(Socket socket) { this.socket = socket; } @Override public void run() { InputStream is = null; InputStreamReader isr = null; BufferedReader br = null; OutputStream os = null; PrintWriter pw = null; try { //与客户端建立通信，获取输入流，读取取客户端提供的信息 is = socket.getInputStream(); isr = new InputStreamReader(is,"GBK"); br = new BufferedReader(isr); String data = null; while((data=br.readLine()) != null){//循环读取客户端的信息 System.out.println("我是服务器，客户端提交信息为："+data); } socket.shutdownInput();//关闭输入流 //获取输出流，响应客户端的请求 os = socket.getOutputStream(); pw = new PrintWriter(os); pw.write("服务器端响应成功！"); pw.flush(); } catch (IOException e) { e.printStackTrace(); }finally { //关闭资源即相关socket try { if(pw!=null) pw.close(); if(os!=null) os.close(); if(br!=null) br.close(); if(isr!=null) isr.close(); if(is!=null) is.close(); if(socket!=null) socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }
1.6 创建服务器端类
使用while以达到可以循环侦听不同客户端的连接请求。因为这是一个死循环，所以不用关闭也没有机会去关闭serverSocket。设置count值，用于记录服务器端被连接过的次数并显示客户端所在ip值。如果线程处理类是继承Thread类，那么创建新线程代码可以改为ServerThread serverThread = new ServerThread(socket);serverThread.start();
package com.linuxidc; import java.io.IOException; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; public class Server { public static void main(String[] args) { try { //创建一个服务器端的Socket，即ServerSocket,绑定需要监听的端口 ServerSocket serverSocket = new ServerSocket(8888); Socket socket = null; //记录连接过服务器的客户端数量 int count = 0; System.out.println("***服务器即将启动，等待客户端的连接***"); while(true){//循环侦听新的客户端的连接 //调用accept（）方法侦听，等待客户端的连接以获取Socket实例 socket = serverSocket.accept(); //创建新线程 Thread thread = new Thread(new ServerThread(socket)); thread.start(); count++; System.out.println("服务器端被连接过的次数："+count); InetAddress address = socket.getInetAddress(); System.out.println("当前客户端的IP为："+address.getHostAddress()); } //serverSocket.close();一直循环监听，不用关闭连接 } catch (IOException e) { e.printStackTrace(); } } }
1.7 创建客户端类