java客户端与服务端建立连接 线程 ServerSocket

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;

/*
* 聊天客户端
*/
public class Client {
/*
* java.net.Scoket 套接字
* 封装了TCP通讯，使用它可以通过网络连接到服务端并进行数据交换（通讯）
*/
private Socket socket;
/*
* 构造方法
* 用于初始化客户端
*/
public Client() throws Exception{
try {
/*
* 实例化Scoket的过程就是与远端计算机建立连接的过程
* 实际上建立连接是客户端应用程序与服务端应用程序建立的连接
* 那么这里实例化Scoket需要传入两个参数
* 1：服务器端计算机的IP地址（用于在网络中找到服务器端电脑）
* 2：端口号（通过端口号可以找到运行在服务器中的服务端应用程序）
*/
System.out.println("正在连接服务器。。。");
socket = new Socket("localhost",8080);
System.out.println("已建立连接！");
} catch (Exception e) {
throw e;
}
}
/*
* 客户端的启动方法
*/
public void start(){
try {
/*
* Socket 提供方法：
* OutputStream getOutputStream
* 该方法可以获取一个字节输出流，通过该流写出的数据都会发送给远端计算机
* 对于客户而言，远端就是服务端
*/

Scanner scan = new Scanner(System.in);
//客户端输出
OutputStream out = socket.getOutputStream();
//转换指定字符集
OutputStreamWriter osw = new OutputStreamWriter(out,"UTF-8");
//缓冲 字符输出流
PrintWriter pw = new PrintWriter(osw,true);

//启动读取服务端发送过来消息的线程
ServerHandler handler = new ServerHandler();
Thread t = new Thread(handler);
t.start();

System.out.println("开始聊天");
String message = null;
while(true){
message = scan.nextLine();
pw.println(message);
//              //读取服务端发送回来的内容
//              message = br.readLine() ;
//              System.out.println(message);
}

} catch (Exception e) {
e.printStackTrace();
}
}
/*
* 该线程专门用来接收服务端发送过来的消息并输出到控制台
*/
private class ServerHandler implements Runnable{
public void run(){
try {
//客户端输入
InputStream in  = socket.getInputStream();
//字符
InputStreamReader isr = new InputStreamReader(in,"utf-8");
//字符
BufferedReader br = new BufferedReader(isr);
String message = null;
while((message = br.readLine())!= null){
System.out.println(message);
}

} catch (Exception e) {
e.printStackTrace();
}
}
}

public static void main(String[] args) {
try {
Client client = new Client();
client.start();

} catch (Exception e) {
e.printStackTrace();
}
}
}

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.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

/*
* 服务器端
*
*/
public class Server {
/*
* java.net.ServerSocket; 运行在服务端的ServerScoket主要职责：
* 1：向OS申请服务端口（客户端就是同过这个端口与服务端建立连接的）
* 2：监听服务端口并建立与客户端的连接
*/
private ServerSocket server;
//存放所有客户端的输出流，用于广播消息
private List<PrintWriter> allOut;
/*
* 服务端构造方法，用来初始化服务端
*/
public Server() throws Exception {
try {
/*
* 初始化ServerSocket的同时向系统申请服务器端口， 若该端口已经被其他程序占用则会抛出异常
*/
server = new ServerSocket(8080);
allOut = new ArrayList<PrintWriter>();

} catch (Exception e) {
// 将来在这里可以记录日志
// 异常若不应当在这里处理，继续抛出
throw e;
}

}

/*
* 服务端开始工作的方法
*/
public void start() {

try {
/*
* ServerSocket提供方法： Socket accept()
* 该方法是一个阻塞方法，作用是监听服务端口，等待客户端的连接一旦一个客户端请求连接
* 那么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();
}

}

private class ClientHandler implements Runnable {
/*
* 当前线程就是通过这个Socket与指定客户端交互的
*
*/

private Socket socket;

//当前客户端的地址信息
private String host;

public ClientHandler(Socket socket) {
this.socket = socket;
//获取该客户端地址信息（远端计算机地址信息）
InetAddress address = socket.getInetAddress();
host = address.getHostAddress();
}

public void run() {
PrintWriter pw = null;
try {
/*
* Socket 提供方法： InputStream getInputStream()
* 通过这个流读取到的数据就是远端发送过来的数据
*/
// 服务端输入
// 字节
InputStream in = socket.getInputStream();
// 字符
InputStreamReader isr = new InputStreamReader(in, "utf-8");
// 字符
BufferedReader br = new BufferedReader(isr);

// 服务端输出
OutputStream out = socket.getOutputStream();
// 转换指定字符集
OutputStreamWriter osw = new OutputStreamWriter(out, "UTF-8");
// 缓冲 字符输出流
pw = new PrintWriter(osw, true);

//将该客户端的输出流存入共享集合
synchronized(allOut){//锁集合 保证多个线程不能同时调用
allOut.add(pw);
}
//广播当前客户端上线
sendMessage(host+"上线了");

String message = null;
while ((message = br.readLine()) != null) {
Thread t = Thread.currentThread();
System.out.println("客户" +t.getName()+":"+ message);
//                  // 发送回给客户端
//                  pw.println("客户端说：" + message);

//遍历集合，发送给所有客户端
sendMessage(host+":"+message);

}

} catch (Exception e) {
//e.printStackTrace();
}finally{

//处理客户端断开连接后的操作

//将该客户端的输出流从共享集合中删除
synchronized(allOut){
allOut.remove(pw);

}
sendMessage(host+"下线了");

try{
/*
* 网络通讯完毕后关闭socket
*/
socket.close();
}catch(Exception e){
}

}

}
/*
* 将消息广播给所有客户端
*/
private void sendMessage(String message){
synchronized(allOut){
for(PrintWriter o : allOut){
o.println(message);
}
}
}
}

public static void main(String[] args) {
try {
Server server = new Server();
server.start();

} catch (Exception e) {
e.printStackTrace();
}
}

}