客户端：
public class Client {
/*
* java.net.Socket
* 套接字，封装了TCP协议，使用它可以与远端计算机通讯
*/
private Socket socket;
/*
* 定义构造方法，用来初始化客户端
*/
/*
* 实例化Socket时需要传入两个参数：
* 1：服务端计算机的地址信息（IP地址）
* 2：服务端计算机上运行的服务端应用程序申请的服务端口
*
*
* 通过IP可以找到服务端的计算机，通过端口可以连接到运行在服务端计算机上的服务端应用程序
*
* 实例化Socket的过程就是连接服务端的过程，若服务端无响应，实例化过程会抛出异常
*
* 端口号是一个整数，2字节内的整数0-65536
* 但3000以内的端口号不要使用，因为紧密的绑定着系统程序，和世界上流行的应用程序。
* 10000以上也很少被使用
*/
public Client() throws Exception{
try {
Scanner scanner=new Scanner(System.in);
String str=scanner.nextLine();
socket=new Socket(str,8088);//"176.195.107.86"
System.out.println(str);
System.out.println("连接上服务端！");
} catch (Exception e) {
//记录日志
throw e;
}
}
public void start(){
try{
//用来获取用户输入
Scanner scanner=new Scanner(System.in);
/**
* Socket提供方法：
* OutputStream getOutputStream()
* 通过获取的输出流写出的数据就可以通过
* 网络发送给远端计算机，对于客户端而言远端就是服务器。
*/
OutputStream out=socket.getOutputStream();
//String message="你好服务端";
//byte[] data=message.getBytes("UTF-8");
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;
long time=System.currentTimeMillis()-500;
while(true){
message=scanner.nextLine();
if(System.currentTimeMillis()-time>=500){
pw.println(message);
time=System.currentTimeMillis();
}else{
System.out.println("你说话过快！");
time=System.currentTimeMillis();
}
}
//pw.close();
}catch(Exception e){
e.printStackTrace();
}
}
public static void main(String[] args) {//程序入口方法，没有逻辑代码
Client client;
try {
client = new Client();
client.start();
} catch (Exception e) {
e.printStackTrace();
System.out.println("服务端启动失败");
}
}
/**
* 该线程专门用来循环读取服务端发送过来的消息并输出
* 到客户端的控制台上
* @author live
*
*/
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){
}
}
}
}
服务端：
public class Server {
/**
* 运行在服务端的ServerSocket主要负责两个工作：
* 1：向系统申请服务端口，客户端就是通过这个端口与服务端应用程序建立连接的。
* 2：监听服务端口，一旦客户端通过该端口尝试连接时，ServerSocket就会实
* 例化一个Socket与该客户端通讯。
*/
private ServerSocket server;
//存放所有客户端的输出流，用于广播消息
private List<PrintWriter> allOut;
public Server() throws Exception{
try{
/**
* 实例化SeverSocket时需要指定服务端口，客户端就是通过这个端口与服务端建立连接的。
*
* 该端口不能与系统其他程序申请的端口冲突，否则会抛出异常。
* address already in use
*/
server=new ServerSocket(8088);
allOut=new ArrayList<PrintWriter>();
}catch(Exception e){
throw e;
}
}
public void start(){
try{
/*
* ServerSocket提供方法：
* Socket accept()
* 该方法是一个阻塞方法，调用后会一致等待客户端的连接，一旦一个客户端
* 通过ServerSocket申请的端口建立连接，那么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();
}
}
public static void main(String[] args) {
try{
Server server=new Server();
server.start();
}catch(Exception e){
e.printStackTrace();
System.out.println("服务端启动失败");
}
}
/*
* 该线程任务是用于处理与指定客户端的交互工作。
*/
private class ClientHandler implements Runnable{
//当前线程通过这个Socket与指定客户端交互
private Socket socket;
//该客户端的地址信息
private String host;
public ClientHandler(Socket socket){
this.socket=socket;
//通过Socket获取远端计算机地址信息
InetAddress address=socket.getInetAddress();
//获取IP地址的字符串形式
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);
/*
* 通过Socket获取输出流，用于将消息发送给客户端
*/
OutputStream out=socket.getOutputStream();
OutputStreamWriter osw=new OutputStreamWriter(out,"UTF-8");
pw=new PrintWriter(osw,true);
//将该客户端的输出流存入共享集合
synchronized (allOut) {//给allOut加锁，保证线程安全
allOut.add(pw);
}
String message=null;
/*
* 使用br.readline读取客户端发送过来的一行字符串时，该方法处于阻塞状态
* 直到客户端真实发送过来一行，这里才会返回
*
* 但是当客户端断开连接时，br.readline会根据客户端不同操作系统有不同的反馈
* 当Windows的客户端断开，br.readline方法会抛出异常
* 当Linux的客户端断开，br.readline方法会返回null.
*/
while((message=br.readLine())!=null){
//System.out.println(host+"说："+message);
/*//将读到的内容再回复给客户端（临时测试用）
pw.println("回复："+message);
*/
/*
* 将消息转发给所有客户端
*/
synchronized (allOut) {
for(PrintWriter o:allOut){
o.println(host+"说："+message+"\n连接人数："+allOut.size());
}
}
}
}catch(Exception e){
} finally {
/*
* 当客户端断线，要将输出流从共享集合中删除
* 需要同步
*
* 处理客户端断开连接的操作
*/
synchronized (allOut) {
allOut.remove(pw);
}
try{
socket.close();
}catch(IOException e){
e.printStackTrace();
}
}
}
}
}