输出流共享到集合中，服务端遍历集合来广播输出流给客户端，来达到聊天室的功能.
课后作业：使用Mapk来实现@xxx 时，发送私聊内容给对方
Client
package chat;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
/**
* 聊天室客户端
* @author Administrator
*
*/
publicclassClient {
/*
* java.net.Socket
* 封装了TCP协议，使用它就可以基于TCP协议进行网络通讯
* Socket是运行在客户端的
*/
private Socket socket;
/**
* 构造方法，用来初始化客户端
* 实例化Socket的时候需要传入两个参数：
* 1.服务端地址：通过IP地址可以找到服务端的计算机.
* 2.服务端端口：通过端口可以找到服务端计算机上的服务端应用程序
* 实例化Socket的过程就是连接的过程，若远端计算机没有响应会抛出异常.
*/
public Client() throws Exception{
System.out.println("正在连接服务端...");
socket =new Socket("localhost", 8088);
System.out.println("已与服务端建立连接!");
}
/**
* 启动客户端
*/
publicvoid start(){
try {
Scanner scan =new Scanner(System.in);
/*
* 先要求用户输入一个昵称
*/
String nickName =null;
while(true){
System.out.println("请输入昵称：");
nickName = scan.nextLine();
if(nickName.length() >0){
break;
}
System.out.println("输入有误！");
}
System.out.println("欢迎你,"+ nickName +"!开始聊天吧!");
/*
* Socket提供的方法：
* OutputStream getOutputStream()
* 获取一个字节输出流，通过该流写出的数据会被发送至远端计算机.
*/
OutputStream out = socket.getOutputStream();
OutputStreamWriter osw =new OutputStreamWriter(out, "UTF-8"); //转换流，指定字符集
PrintWriter pw =new PrintWriter(osw, true); //自动行刷新
/*
* 先将昵称发送给服务器
*/
pw.println(nickName);
/*
* 启动读取服务端发送过来消息的线程
*/
ServerHandler handler =new ServerHandler();
Thread t =new Thread(handler);
t.start();
/*
* 将字符串发送至服务端
*/
// System.out.println("输入内容：");
while(true){
pw.println(scan.nextLine());
}
} catch (Exception e) {
e.printStackTrace();
}
}
publicstaticvoid main(String[] args) {
try {
Client client =new Client();
client.start();
} catch (Exception e) {
e.printStackTrace();
System.out.println("客户端启动失败!");
}
}
/**
* 该线程用来读取服务端发送过来的消息并输出到客户端控制台
* @author Administrator
*
*/
classServerHandlerimplements Runnable{
publicvoid run(){
try {
InputStream is = socket.getInputStream();
InputStreamReader isr =new InputStreamReader(is, "UTF-8");
BufferedReader br =new BufferedReader(isr);
String message =null;
while((message = br.readLine()) !=null){
System.out.println(message);
}
} catch (Exception e) {
}
}
}
}
Server
package chat;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
/**
* 聊天室服务端
* @author Administrator
*
*/
publicclassServer {
/*
* 运行在服务端的ServerSocket主要负责：
* 1.向系统申请服务端口
* 客户端就是通过这个端口与之连接
* 2.监听申请的服务端口，当一个客户端通过该端口尝试连接时，
* ServerSocket会在服务端创建一个Socket与客户端建立连接.
*/
private ServerSocket server;
/*
* 保存所有客户端输出流的集合
*/
private List<< span="">PrintWriter> allOut;
/**
* 用来初始化服务端
*/
public Server() throws Exception {
/*
* 初始化的同时申请服务端口
*/
server =new ServerSocket(8088);
allOut =new ArrayList<< span="">PrintWriter>();
}
/**
* 将给定的输出流存入共享集合
* @param out
*/
privatesynchronizedvoid addOut(PrintWriter out){
allOut.add(out);
}
/**
* 将给定的输出流从共享集合中删除
* @param out
*/
privatesynchronizedvoid removeOut(PrintWriter out){
allOut.remove(out);
}
/**
* 将给定消息发送给所有客户端
* @param message
*/
privatesynchronizedvoid sendMessage(String message){
for(PrintWriter out : allOut){
out.println(message);
}
}
/**
* 服务端开始工作的方法
*/
publicvoid start() {
try {
/*
* ServrSocket的accept方法是一个阻塞方法，作用是监听服务端口，
* 直到一个客户端连接并创建一个Socket,使用该Socket即可与刚连接的客户端进行交互.
*/
while(true){
System.out.println("等待客户端连接...");
Socket socket = server.accept();
System.out.println("一个客户端连接了!");
/*
* 启动一个线程，来完成与该客户端的交互
*/
ClientHandler handler =new ClientHandler(socket);
Thread t =new Thread(handler);
t.start();
}
} catch (Exception e) {
e.printStackTrace();
}
}
publicstaticvoid main(String[] args) {
try {
Server server =new Server();
server.start();
} catch (Exception e) {
e.printStackTrace();
System.out.println("服务端启动失败!");
}
}
/*
* 该线程负责处理一个客户端的交互
*/
classClientHandlerimplements Runnable{
/*
* 该线程处理的客户端的Socket
*/
private Socket socket;
/*
* 客户端该用户的昵称
*/
privateString nickName;
//客户端的地址信息
privateString host;
public ClientHandler(Socket socket){
this.socket = socket;
/*
* 通过Socket可以获取远端计算机的地址信息.
*/
InetAddress address = socket.getInetAddress();
//获取IP地址
host = address.getHostAddress();
}
publicvoid run(){
PrintWriter pw =null;
try {
/*
* Socket提供的方法
* InputStream getInputStream()
* 该方法可以获取一个输入流，从该流读取的数据就是从远端计算机发送过来的
*/
InputStream in = socket.getInputStream();
InputStreamReader isr =new InputStreamReader(in, "UTF-8");
BufferedReader br =new BufferedReader(isr);
/*
* 首先读取一行字符串为昵称
*/
nickName = br.readLine();
sendMessage(nickName +"上线了");
/*
* 通过Socket创建输出流用于将消息发送给客户端
*/
OutputStream os = socket.getOutputStream();
OutputStreamWriter osw =new OutputStreamWriter(os, "UTF-8");
pw =new PrintWriter(osw, true);
/*
* 将该客户端的输出流存入到共享集合中
*/
addOut(pw);
String message =null;
/*
* br.readLine() 在读取客户端发送过来的消息时，由于客户端断线，而其操作系统的不同，这里读取后的结果不同：
* 当windows的客户端断开时：br.readLine会抛出一场
* 当linux的客户端断开时：br.readLine会返回null
*/
while((message = br.readLine()) !=null){ //readLine() 读到文件末尾会返回null
// System.out.println(host + "说：" + message);
// pw.println(host + "说：" + message); 将客户端发送过来的消息返回给客户端，客户端去读Socket
//广播消息
sendMessage(nickName +"说："+ message);
}
}catch (Exception e) {
e.printStackTrace();
} finally{
/*
* 处理当前客户端断开后的逻辑
*/
//将该客户端的输出流从共享集合中删除
removeOut(pw);
sendMessage(nickName +"下线了！");
try {
socket.close(); //Socket断开连接时，会自动关闭流
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}
