[网络协议]Tcp即时通信

TCP即时通信（重点，端口转发）

客户端

package com.huang.socket_tcp;
?
import java.io.*;
import java.net.Socket;
import java.util.Scanner;
?
?
public class ClientDome1 {
 ? ?public static void main(String[] args)  {
 ? ? ? ?try {
 ? ? ? ? ? ?System.out.println("===============客户端启动=====================");
?
 ? ? ? ? ? ?//1.创建socket通信管道，请求与服务器的连接
 ? ? ? ? ? ?//参数一：服务器的IP地址
 ? ? ? ? ? ?//参数二：服务器端口
 ? ? ? ? ? ?Socket ?socket=new Socket("127.0.0.1",9999);
?
 ? ? ? ? ? ?//创建一个独立的线程专门负责这个客户端的读消息（服务端随时转发消息过来）
 ? ? ? ? ? ?new ClientReaderThread(socket).start();
?
?
 ? ? ? ? ? ?//2.从socket通信管道中得到一个字节输出流 负责发送数据
 ? ? ? ? ? ?OutputStream os =socket.getOutputStream();
?
 ? ? ? ? ? ?//3.把低级的字节流包装成打印流
 ? ? ? ? ? ?PrintStream ps=new PrintStream(os);
?
 ? ? ? ? ? ? //4.发送消息
 ? ? ? ? ? ?Scanner sc=new Scanner(System.in);
 ? ? ? ? ? ?String msg;
 ? ? ? ? ? ?while (true){
 ? ? ? ? ? ? ? ?System.out.println("请说");
 ? ? ? ? ? ? ? ?if ((msg=sc.nextLine())!=null){
 ? ? ? ? ? ? ? ? ? ?ps.println(msg);
 ? ? ? ? ? ? ? ? ? ?ps.flush();
 ? ? ? ? ? ? ?  }else if("exit".equals(msg)){
 ? ? ? ? ? ? ? ? ? ?socket.close();
 ? ? ? ? ? ? ?  }
 ? ? ? ? ?  }
?
 ? ? ? ? ? ?//关闭资源
 ? ? ? ? ? ?//socket.close();
 ? ? ?  } catch (Exception e) {
 ? ? ? ? ? ?e.printStackTrace();
 ? ? ?  }
?
 ?  }
}
?
class ClientReaderThread extends Thread{
 ? ?private Socket socket;
?
 ? ?public ClientReaderThread(Socket socket){
 ? ? ? ?this.socket=socket;
 ?  }
?
 ? ?@Override
 ? ?public void run() {
 ? ? ? ?try {
 ? ? ? ? ? ?//从Socket通信管道中得到一个字节输入流
 ? ? ? ? ? ?InputStream is=socket.getInputStream();
 ? ? ? ? ? ?//4.把字节输入流包装成缓冲字符输入流进行消息的读取
 ? ? ? ? ? ?/**
 ? ? ? ? ? ? * 字符输入流是无法直接包装字节输入流
 ? ? ? ? ? ? * 采用转换流将字节输入流转换成字符输入流
 ? ? ? ? ? ? */
 ? ? ? ? ? ?BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(is));
 ? ? ? ? ? ?//5.按行读取消息
 ? ? ? ? ? ?String readLine;
 ? ? ? ? ? ?while ((readLine=bufferedReader.readLine())!=null){
 ? ? ? ? ? ? ? ?System.out.println("收到消息"+":"+readLine);
 ? ? ? ? ?  }
 ? ? ?  } catch (Exception e) {
 ? ? ? ? ? ?System.out.println("服务端把你踢出去了");
 ? ? ?  }
 ?  }
}

服务端

package com.huang.socket_tcp;
?
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
?
/**
 *目标：实现服务端可以同时处理多个客户端的消息
 */
public class ServerDome1 {
 ? ?//定义一个静态的list集合存储当前全部的在线的socket管道
 ? ? public static List<Socket> allOnlineSocket =new ArrayList<>();
?
 ? ?public static void main(String[] args) throws Exception{
?
 ? ? ? ? ? ?System.out.println("===============服务端启动=====================");
 ? ? ? ? ? ?//1.注册端口
 ? ? ? ? ? ?ServerSocket serverSocket = new ServerSocket(9999);
?
 ? ? ? ? ? ?//定义一个死循环有主线程负责不断的接受客户端的Socket管道连接
 ? ? ? ? ? ?while (true) {
 ? ? ? ? ? ? ? ?//2.每接收到一个客户端的Socket管道，交给一个独立的子线程负责读取消息
 ? ? ? ? ? ? ? ?//在这里等待客户端的socket管道连接。
 ? ? ? ? ? ? ? ?Socket socket = serverSocket.accept();
 ? ? ? ? ? ? ? ?System.out.println(socket.getRemoteSocketAddress() + "上线了");
?
 ? ? ? ? ? ? ? ?allOnlineSocket.add(socket);
 ? ? ? ? ? ? ? ?//创建一个独立的线程单独处理socket管道
 ? ? ? ? ? ? ? ?new ServerReaderThread(socket).start();
 ? ? ? ? ?  }
 ?  }
}
?
class ServerReaderThread extends Thread{
?
 ? ?private Socket socket;
?
 ? ?public ServerReaderThread(Socket socket){
 ? ? ? ?this.socket=socket;
 ?  }
?
 ? ?@Override
 ? ?public void run() {
 ? ? ? ?try {
 ? ? ? ? ? ?//从Socket通信管道中得到一个字节输入流
 ? ? ? ? ? ?InputStream is=socket.getInputStream();
 ? ? ? ? ? ?//4.把字节输入流包装成缓冲字符输入流进行消息的读取
 ? ? ? ? ? ?/**
 ? ? ? ? ? ? * 字符输入流是无法直接包装字节输入流
 ? ? ? ? ? ? * 采用转换流将字节输入流转换成字符输入流
 ? ? ? ? ? ? */
 ? ? ? ? ? ?BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(is));
 ? ? ? ? ? ?//5.按行读取消息
 ? ? ? ? ? ?String readLine;
 ? ? ? ? ? ?while ((readLine=bufferedReader.readLine())!=null){
 ? ? ? ? ? ? ? ?System.out.println(socket.getRemoteSocketAddress()+":"+readLine);
 ? ? ? ? ? ? ? ?//把消息进行端口转发给全部客户端socket管道；
 ? ? ? ? ? ? ? ?sendMsgToAll(readLine);
 ? ? ? ? ?  }
 ? ? ?  } catch (Exception e) {
 ? ? ? ? ? ?System.out.println(socket.getRemoteSocketAddress()+"下线了");
 ? ? ? ? ? ?ServerDome1.allOnlineSocket.remove(socket);
 ? ? ?  }
 ?  }
?
 ? ?private void sendMsgToAll(String readLine) throws Exception {
 ? ? ? ?for (Socket socket : ServerDome1.allOnlineSocket) {
 ? ? ? ? ? ?PrintStream ps=new PrintStream(socket.getOutputStream());
 ? ? ? ? ? ?ps.println(readLine);
 ? ? ? ? ? ?ps.flush();
 ? ? ?  }
 ?  }
}