future.cancel不能关闭线程_结合多线程技术，实现客户端和服务端任意通讯的“聊天室”功能。...

一、实操名称：结合多线程技术，实现客户端和服务端任意通讯的“聊天室”功能。
二、项目信息
2.1作者：任鑫
2.2项目时长：3小时
2.3项目环境：JDK版本--1.8，操作系统--Windows7，eclipse
2.4项目涉及知识点：多线程、IO流、基于TCP协议的Socket编程
2.5项目的搭建
2.5.1--项目简介：实现聊天室群聊的功能：基于TCP协议的Socket编程。
服务器端包含：CloseUtil类（关闭流工具类）：负责关闭流。MyChannel类（通道线程类）：主要负责调用转发信息的方法。Server类（服务器类）：负责创建对象，监听客户端连接，实现多次聊天。
客户端包含：CloseUtil类（关闭流工具类）：负责关闭流。Send类（发送数据的线程类）：主要负责调用发送信息的方法。Receive（接收数据的线程类）：主要负责调用接收服务器端的数据的方法。Client类（客户端类）：负责创建对象并启动线程。
2.5.2--服务器端
1、CloseUtil类（关闭流工具类）package cn.sxt.chat.server;import java.io.Closeable;
import java.io.IOException;
/*** 关闭流工具类* @author littlelock**/
public class CloseUtil {public static void closeAll(Closeable... able){//可变参数，Closeable是可以关闭的数据的源或目的地。for (Closeable c : able) {if (c!=null) {try {c.close();} catch (IOException e) {//关闭此流并释放与之相关联的任何系统资源。 e.printStackTrace();}}}}
}
2、MyChannel类（通道线程类）package cn.sxt.chat.server;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.List;/*** 通道线程类* @author littlelock* 包含：1、输入流；2、输出流；3、接收数据；4、发送数据；5、转发信息的方法；6、重写run方法实现转发信息。* 主要负责调用转发信息的方法。* 群聊分析：服务器端收到客户端的数据将其转发到每一个客户端来实现群聊。*      向其他的客户端转发的时候不能转发给自己。*      每一个客户端都是一条通道。*      所以当创建线程类对象的时候，每创建一个线程类对象就说明一个客户端进来了。*      可以将其添加到集合（Server类中创建的list）当中，然后去遍历集合，去向集合当中的每一个客户端进行转发。*    */
public class MyChannel implements Runnable{private DataInputStream dis;//获取输入流接收数据private DataOutputStream dos;//获取输出流private boolean flag = true;public MyChannel(Socket client){try {dis = new DataInputStream(client.getInputStream());dos = new DataOutputStream(client.getOutputStream());} catch (IOException e) {flag = false;CloseUtil.closeAll(dis,dos,client);}}//接收数据的方法private String receive(){String str = "";try {str = dis.readUTF();} catch (IOException e) {flag = false;CloseUtil.closeAll(dis);//如果一个线程出现错误了，其他的线程还需要继续执行，只要是线程出错，我们就将这个线程移除Server.list.remove(this);}return str;}//发送数据的方法private void send(String str){if(str!=null&&str.length()!=0)try {dos.writeUTF(str);dos.flush();} catch (IOException e) {flag = false;CloseUtil.closeAll(dos);Server.list.remove(this);}}//转发的方法private void sendOther(){String str = this.receive();List<MyChannel> list = Server.list;for(MyChannel other:list){if(other == this){continue;//不发给自己}other.send(str);//发送出去}}@Overridepublic void run() {while(flag){sendOther();}}
}
3、Server类（服务器类）package cn.sxt.chat.server;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
/*** 服务器端* @author littlelock*分析：单次聊天执行一次后，服务器端和客户端均停止运行，但是聊天室应该可以发送很多次数据，而且不发送数据也可以接收数据。*      单次聊天出现的问题就是：如果不发送数据，那就收不到数据。*    解决方案：1、多次聊天可以使用循环来解决；2、先发后收的问题可以使用线程来解决，一个接收数据的线程，一个发送数据的线程。**/
public class Server {//创建集合对象，存储每一个连接进来的客户端public static List<MyChannel> list = new ArrayList<MyChannel>();public static void main(String[] args) throws IOException {System.out.println("----------------服务器端已开启---------------------");//(1)创建ServerSocket对象ServerSocket server=new ServerSocket(9999);//(2)监听客户端是否有客户端连接while(true){//实现多次聊天Socket socket=server.accept();MyChannel channel = new MyChannel(socket);//创建线程类的对象list.add(channel);//添加到集合中Thread t = new Thread(channel);t.start();}}
}
2.5.3--客户端1、CloseUtil类（关闭流工具类）package cn.sxt.chat.client;import java.io.Closeable;
import java.io.IOException;
/*** 关闭流工具类* @author littlelock**/
public class CloseUtil {public static void closeAll(Closeable... able){//可变参数，Closeable是可以关闭的数据的源或目的地。for (Closeable c : able) {if (c!=null) {try {c.close();//关闭此流并释放与之相关联的任何系统资源。 } catch (IOException e) {e.printStackTrace();}}}}
}
2、Send类（发送数据的线程类）package cn.sxt.chat.client;import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
/*** 发送数据的线程类* @author littlelock* 主要负责调用发送信息的方法*/
public class Send implements Runnable{private BufferedReader br;//从键盘获取数据private DataOutputStream dos;//发送数据的数据流private boolean flag = true;//标识线程执行成功与否public Send(){br=new BufferedReader(new InputStreamReader(System.in));} public Send(Socket client){this();//调用本类的无参构造方法try {dos=new DataOutputStream(client.getOutputStream());} catch (IOException e) {flag = false;CloseUtil.closeAll(dos,client);}}//从键盘获取数据的方法private String getMessage(){String str = "";try {str = br.readLine();} catch (IOException e) {flag = false;CloseUtil.closeAll(br);}return str;}//发送数据的方法private void send(String str){try {dos.writeUTF(str);dos.flush();} catch (IOException e) {flag = false;CloseUtil.closeAll(dos);}}@Overridepublic void run() {while(flag){this.send(getMessage());//调用发送信息的方法}}
}
3、Receive（接收数据的线程类）package cn.sxt.chat.client;import java.io.DataInputStream;
import java.io.IOException;
import java.net.Socket;
/*** 接收数据的线程类* @author littlelock* 主要负责调用接收服务器端数据的方法。*/
public class Receive implements Runnable {private DataInputStream dis;//用于接收数据的数据流private boolean flag = true;//用于标识线程执行成功与否public Receive(Socket client){try {dis=new DataInputStream(client.getInputStream());} catch (IOException e) {flag = false;CloseUtil.closeAll(dis,client);}}//接收服务器端的数据private String getMessage(){String str = "";try {str = dis.readUTF();} catch (IOException e) {flag = false;CloseUtil.closeAll(dis);}return str;}@Overridepublic void run() {while(flag){System.out.println(this.getMessage());}}
}
4、Client类（客户端类）package cn.sxt.chat.client;import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
/*** 客户端* @author littlelock*分析：客户端使用多线程（一个发送数据的线程类Send，一个发送数据的线程类Receive），实现了客户端和服务端的循环操作。*      解决了先发后收的问题。*/
public class Client {public static void main(String[] args) throws IOException {//创建Socket对象Socket client=new Socket("localhost",9999);Send send = new Send(client);//创建发送数据的线程类对象Receive receive = new Receive(client);//创建接收数据的线程类对象//创建Thread类对象并启动线程new Thread(send).start();new Thread(receive).start();}
}