Java基于Socket實(shí)現(xiàn)多人聊天室

更新時(shí)間：2022年09月02日 11:44:58 作者：becatjd

這篇文章主要為大家詳細(xì)介紹了Java基于Socket實(shí)現(xiàn)多人聊天室，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

本文實(shí)例為大家分享了Java基于Socket實(shí)現(xiàn)簡(jiǎn)易版多人聊天室的具體代碼，供大家參考，具體內(nèi)容如下

一、聊天室需求

1、一個(gè)服務(wù)端，多個(gè)客戶(hù)端；
2、實(shí)現(xiàn)客戶(hù)端和服務(wù)端的交互；
3、客戶(hù)端發(fā)送信息，服務(wù)端收到信息，再轉(zhuǎn)發(fā)給其他客戶(hù)端；
4、上下線時(shí)顯示哪個(gè)客戶(hù)端上下線并且顯示在線客戶(hù)端數(shù)量；

二、代碼分析

1. 建立連接

客戶(hù)端類(lèi)，創(chuàng)建發(fā)送端Socket對(duì)象，用自己的IP地址和端口號(hào)，與服務(wù)端建立連接。

class Client:

//用于與服務(wù)端通信的Socket
private Socket socket;

public Client() throws Exception {
?? ?/*
?? ? * 初始化Socket的同時(shí)要制定服務(wù)端的IP地址和端口號(hào)
?? ? * ip地址用于我們?cè)诰W(wǎng)絡(luò)上找到服務(wù)端的所在計(jì)算在
?? ? * 端口號(hào)用于找到服務(wù)器上的服務(wù)端應(yīng)用程序。
?? ? *?
?? ? * 實(shí)例化Socket的過(guò)程就是連接服務(wù)端的過(guò)程若
?? ? * 服務(wù)端無(wú)響應(yīng)，這里得構(gòu)造方法得拋出異常。
?? ? *?
?? ? */
?? ?try {
?? ??? ?System.out.println("正在連接服務(wù)器......");
?? ??? ?//localhost 127.0.0.1
?? ??? ?socket = new Socket("LAPTOP-TCK59O6Q",8888);
?? ??? ?System.out.println("與服務(wù)端連接完畢");
?? ?} catch (Exception e) {
?? ??? ?System.out.println("初始化失敗");
?? ??? ?throw e;
?? ?}
}?

服務(wù)端類(lèi)，使用構(gòu)造方法初始化服務(wù)端，創(chuàng)建接收端的Socket對(duì)象

class Server:

private ServerSocket server;

//構(gòu)造方法初始化服務(wù)端
public Server() throws IOException {
?? ?//實(shí)例化serverSocket的同時(shí)，指定服務(wù)端的端口號(hào)；
?? ?try {
?? ??? ?server = new ServerSocket(8888);
?? ??? ?allOut = new ArrayList<PrintWriter>();
?? ?} catch (Exception e) {
?? ??? ?System.out.println("服務(wù)端初始化失敗");
?? ??? ?throw e;
?? ?}
}

2. 客戶(hù)端發(fā)送信息

在客戶(hù)端的類(lèi)中寫(xiě)一個(gè)start()方法，start()是客戶(hù)端發(fā)送信息給服務(wù)端的方法
獲取輸出流對(duì)象，把鍵盤(pán)錄入的信息發(fā)送到服務(wù)端。

class Client:

public void start() throws Exception {
?? ?/*
?? ? * 客戶(hù)端開(kāi)始工作的方法
?? ? */
?? ?try {
?? ??? ?//啟動(dòng)用于讀取服務(wù)端發(fā)送消息的線程
?? ??? ?ServerHandler handler = new ServerHandler();
?? ??? ?//ServerHandler是自己寫(xiě)的類(lèi)，實(shí)現(xiàn)Runnable接口,有多線程功能
?? ??? ?Thread t = new Thread(handler);
?? ??? ?t.start();
?? ??? ?
?? ??? ?//將數(shù)據(jù)發(fā)送到服務(wù)端
?? ??? ?OutputStream out = socket.getOutputStream();//獲取輸出流對(duì)象
?? ??? ?OutputStreamWriter osw = new OutputStreamWriter(out,"utf-8");//轉(zhuǎn)化成utf-8格式
?? ??? ?PrintWriter pw = new PrintWriter(osw,true);
?? ??? ?Scanner scan = new Scanner(System.in);
?? ??? ?while(true) {
?? ??? ??? ?String message = scan.nextLine();//得到鍵盤(pán)錄入的信息
?? ??? ??? ?pw.println(message);//把信息輸出到服務(wù)端
?? ??? ?}
?? ??? ?
?? ?} catch (Exception e) {
?? ??? ?System.out.println("客戶(hù)端運(yùn)行失敗");
?? ??? ?throw e;
?? ?}?
?? ?
}

服務(wù)端工作的start()方法，accept()方法與客戶(hù)端連接上

class Server:

//服務(wù)端工作的方法
public void start() throws IOException {
?? ?/*
?? ? * ServerSocket提供了一個(gè)accept的方法，該方法是一個(gè)阻塞方法，
?? ? * 用于監(jiān)聽(tīng)其打開(kāi)的8888端口；當(dāng)一個(gè)客戶(hù)端通過(guò)該端口與服務(wù)端連接時(shí)，
?? ? * accept方法就會(huì)解除阻塞，然后創(chuàng)建一個(gè)socket實(shí)例并返回，
?? ? * socket的作用就是與剛剛連接上的客戶(hù)端進(jìn)行通信。
?? ? */
?? ?while(true) {
?? ??? ?System.out.println("等待客戶(hù)端連接...");
?? ??? ?Socket socket = server.accept();
?? ??? ?System.out.println("一個(gè)客戶(hù)端連接了！");
?? ??? ?//啟動(dòng)一個(gè)線程來(lái)處理客戶(hù)端的交互工作
?? ??? ?ClientHandler hander = new ClientHandler(socket);
?? ??? ?Thread t = new Thread(hander);
?? ??? ?t.start();
?? ?}
}

3. 開(kāi)啟多線程、服務(wù)端接收讀取信息并廣播

因?yàn)榉?wù)端與多個(gè)客戶(hù)端相連，所以要用多線程，即一個(gè)客戶(hù)端用一條線程。

在服務(wù)端類(lèi)中創(chuàng)建一個(gè)內(nèi)部類(lèi)ClientHandler實(shí)現(xiàn)Runnable接口并重寫(xiě)run()方法創(chuàng)建線程
屬性有客戶(hù)端的Socket對(duì)象
有參構(gòu)造方法中通過(guò)客戶(hù)端的Socket獲取到其地址host，并且把地址打印出來(lái)
這樣在main()方法中，實(shí)例化服務(wù)端類(lèi)的對(duì)象之后，start方法開(kāi)啟服務(wù)端，當(dāng)有客戶(hù)端連接上時(shí)，就能輸出這個(gè)客戶(hù)端的ip地址。

ClientHandler類(lèi)要重寫(xiě)run()方法，使用輸入流InputStream讀取客戶(hù)端發(fā)來(lái)的信息，再使用輸出流OutputStream給所有客戶(hù)端廣播收到的信息、用戶(hù)上下線和在線人數(shù)

class Server:

/**
?* ClientHandler
?* 該線程類(lèi)是與指定的客戶(hù)端進(jìn)行交互工作；
?* @author zxm
?*
?*/
class ClientHandler implements Runnable{
?? ?//當(dāng)前線程客戶(hù)端的Socket
?? ?private Socket socket;
?? ?
?? ?//該客戶(hù)端的地址
?? ?private String host;
?? ?
?? ?public ClientHandler(Socket socket) {
?? ??? ?this.socket=socket;
?? ??? ?/*
?? ??? ? * 通過(guò)socket獲取遠(yuǎn)程計(jì)算機(jī)地址
?? ??? ? * 對(duì)于服務(wù)端而言，遠(yuǎn)程計(jì)算機(jī)就是客戶(hù)端
?? ??? ? */
?? ??? ?InetAddress address = socket.getInetAddress();
?? ??? ?
?? ??? ?//獲取ip地址
?? ??? ?host = address.getHostAddress();
?? ??? ?System.out.println("host"+host);
?? ?}

?? ?@Override
?? ?public void run() {
?? ??? ?PrintWriter pw = null;
?? ??? ?try {
?? ??? ??? ?//廣播給所有客戶(hù)端，當(dāng)前用戶(hù)上線了
?? ??? ??? ?sendMessage("["+host+"]上線了");
?? ??? ??? ?OutputStream out = socket.getOutputStream();
?? ??? ??? ?OutputStreamWriter osw = new OutputStreamWriter(out,"UTF-8");
?? ??? ??? ?pw = new PrintWriter(osw,true);

?? ??? ??? ?//將該客戶(hù)的輸出流存入共享集合，以便消息可以廣播給該客戶(hù)端
?? ??? ??? ?addOut(pw);
?? ??? ??? ?
?? ??? ??? ?//廣播當(dāng)前在線人數(shù)
?? ??? ??? ?sendMessage("當(dāng)前在線人數(shù)["+allOut.size()+"]");
?? ??? ??? ?
?? ??? ??? ?//處理來(lái)自客戶(hù)端的數(shù)據(jù)
?? ??? ??? ?InputStream in = socket.getInputStream();
?? ??? ??? ?InputStreamReader isr = new InputStreamReader(in,"utf-8");
?? ??? ??? ?BufferedReader br = new BufferedReader(isr);
?? ??? ??? ?/*
?? ??? ??? ? * 服務(wù)端讀取客戶(hù)端發(fā)送過(guò)來(lái)的每一句字符時(shí)
?? ??? ??? ? * 由于客戶(hù)端所在的操作系統(tǒng)不同，這里客戶(hù)端斷開(kāi)時(shí)結(jié)果也不同
?? ??? ??? ? * windows客戶(hù)端開(kāi)始br.readLine拋出異常
?? ??? ??? ? * Linux客戶(hù)端斷開(kāi)是返回null
?? ??? ??? ? *?
?? ??? ??? ? */
?? ??? ??? ?String message = null;
?? ??? ??? ?while((message = br.readLine())!=null) {
?? ??? ??? ??? ?sendMessage(host+"說(shuō)："+message);
?? ??? ??? ?}
?? ??? ??? ?
?? ??? ?} catch (Exception e) {
?? ??? ??? ?// TODO Auto-generated catch block
?? ??? ??? ?e.printStackTrace();
?? ??? ?}finally {
?? ??? ??? ?//將該客戶(hù)端的輸出流從共享集合中刪除
?? ??? ??? ?removeOut(pw);
?? ??? ??? ?
?? ??? ??? ?//廣播給所有客戶(hù)端，當(dāng)前用戶(hù)下線
?? ??? ??? ?sendMessage("["+host+"]下線了");
?? ??? ??? ?
?? ??? ??? ?//廣播當(dāng)前在線人數(shù)
?? ??? ??? ?sendMessage("當(dāng)前在線人數(shù)["+allOut.size()+"]");
?? ??? ??? ?
?? ??? ??? ?try {
?? ??? ??? ??? ?socket.close();
?? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ?// TODO Auto-generated catch block
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?}
?? ??? ?}
?? ?}
}

因此服務(wù)端類(lèi)中要寫(xiě)一個(gè)sendMessage()方法，為了在接收到一個(gè)客戶(hù)端的信息后，把這個(gè)信息轉(zhuǎn)發(fā)給所有客戶(hù)端，這就是廣播的效果。
寫(xiě)一個(gè)集合allOut，用來(lái)存放所有客戶(hù)端的輸出流，客戶(hù)端的數(shù)量就是集合里元素的個(gè)數(shù)
再寫(xiě)兩個(gè)方法，一個(gè)是addOut()方法把上線客戶(hù)端的輸出流放進(jìn)集合（在run方法中使用addOut()，獲取到啟用新線程的客戶(hù)端的輸出流，把輸出流加到集合中），
另一個(gè)是removeOut()方法拿出集合（同理run()方法中使用，把socket關(guān)閉的客戶(hù)端的輸出流移除集合）。

所以sendMessage()方法的參數(shù)就是某個(gè)客戶(hù)端發(fā)的字符串信息message，遍歷allOut集合，把message在每個(gè)輸出流中打印，用PrintWrite類(lèi)中的print方法。
當(dāng)客戶(hù)端連接服務(wù)端時(shí)，sendMessage()方法打印這個(gè)服務(wù)端的地址加上上線了，同理客戶(hù)端關(guān)閉socket的時(shí)候打印下線了，
同時(shí)上下線后再打印allOut集合的大小，也就是當(dāng)前連接服務(wù)端的客戶(hù)端數(shù)量，就是在線人數(shù)。

class Server:

//存放所有客戶(hù)端的輸出流的集合，用于廣播
private List<PrintWriter> allOut;

//將給定的輸出流放入共享集合
private synchronized void addOut(PrintWriter out){
?? ?allOut.add(out);
}

//將給定的輸出流移除共享集合
private synchronized void removeOut(PrintWriter out){
?? ?allOut.remove(out);
}

//將給定的消息發(fā)給多個(gè)客戶(hù)端
private synchronized void sendMessage(String message) {
?? ?
?? ?for(PrintWriter out:allOut) {
?? ??? ?out.println(message);
?? ?}
}

4. 客戶(hù)端讀取信息

這個(gè)時(shí)候所有的客戶(hù)端都收到了某個(gè)客戶(hù)發(fā)的消息，但是還沒(méi)讀，所以客戶(hù)端類(lèi)中要加輸入流才能讀取，
創(chuàng)建ServerHandler類(lèi)實(shí)現(xiàn)Runnable接口，輸入流讀取并輸出。

class Client:

class ServerHandler implements Runnable{
?? ?/**
?? ? * 該線程用于讀取服務(wù)端發(fā)送過(guò)來(lái)的消息，并輸出到
?? ? * 客戶(hù)端的控制臺(tái)上
?? ? * @author zxm
?? ? *
?? ? */
?? ?@Override
?? ?public void run() {
?? ??? ?try {
?? ??? ??? ?InputStream in = socket.getInputStream();//輸入流
?? ??? ??? ?InputStreamReader isr = new InputStreamReader(in,"UTF-8");//以u(píng)tf-8讀
?? ??? ??? ?BufferedReader br = new BufferedReader(isr);
?? ??? ??? ?String message = null;
?? ??? ??? ?while((message=br.readLine())!=null) {
?? ??? ??? ??? ?System.out.println(message);
?? ??? ??? ?}
?? ??? ?} catch (Exception e) {
?? ??? ??? ?e.printStackTrace();
?? ??? ?}?
?? ?}
}

三、完整代碼

1. 客戶(hù)端

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.io.UnsupportedEncodingException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

/**
?* 聊天室服務(wù)端
?* @author zxm
?*/
public class Client {
?? ?
?? ?//用于與服務(wù)端通信的Socket
?? ?private Socket socket;
?? ?
?? ?public Client() throws Exception {
?? ??? ?/*
?? ??? ? * 初始化Socket的同時(shí)要制定服務(wù)端的IP地址和端口號(hào)
?? ??? ? * ip地址用于我們?cè)诰W(wǎng)絡(luò)上找到服務(wù)端的所在計(jì)算在
?? ??? ? * 端口號(hào)用于找到服務(wù)器上的服務(wù)端應(yīng)用程序。
?? ??? ? *?
?? ??? ? * *實(shí)例化Socket的過(guò)程就是連接服務(wù)端的過(guò)程若
?? ??? ? * 服務(wù)端無(wú)響應(yīng)，這里得構(gòu)造方法得拋出異常。
?? ??? ? *?
?? ??? ? */
?? ??? ?try {
?? ??? ??? ?System.out.println("正在連接服務(wù)器......");
?? ??? ??? ?//localhost 127.0.0.1
?? ??? ??? ?socket = new Socket("LAPTOP-TCK59O6Q",8888);
?? ??? ??? ?System.out.println("與服務(wù)端連接完畢");
?? ??? ?} catch (Exception e) {
?? ??? ??? ?System.out.println("初始化失敗");
?? ??? ??? ?throw e;
?? ??? ?}
?? ?}
?? ?
?? ?public void start() throws Exception {
?? ??? ?/*
?? ??? ? * 客戶(hù)端開(kāi)始工作的方法
?? ??? ? */
?? ??? ?try {
?? ??? ??? ?//啟動(dòng)用于讀取服務(wù)端發(fā)送消息的線程
?? ??? ??? ?ServerHandler handler = new ServerHandler();
?? ??? ??? ?//ServerHandler是自己寫(xiě)的類(lèi)，實(shí)現(xiàn)Runnable接口,有多線程功能
?? ??? ??? ?Thread t = new Thread(handler);
?? ??? ??? ?t.start();
?? ??? ??? ?
?? ??? ??? ?//將數(shù)據(jù)發(fā)送到服務(wù)端
?? ??? ??? ?OutputStream out = socket.getOutputStream();//獲取輸出流對(duì)象
?? ??? ??? ?OutputStreamWriter osw = new OutputStreamWriter(out,"utf-8");//轉(zhuǎn)化成utf-8格式
?? ??? ??? ?PrintWriter pw = new PrintWriter(osw,true);
?? ??? ??? ?Scanner scan = new Scanner(System.in);
?? ??? ??? ?while(true) {
?? ??? ??? ??? ?String message = scan.nextLine();//得到鍵盤(pán)錄入的信息
?? ??? ??? ??? ?pw.println(message);//把信息輸出到服務(wù)端
?? ??? ??? ?}
?? ??? ??? ?
?? ??? ?} catch (Exception e) {
?? ??? ??? ?System.out.println("客戶(hù)端運(yùn)行失敗");
?? ??? ??? ?throw e;
?? ??? ?}?
?? ??? ?
?? ?}

?? ?public static void main(String[] args) throws Exception {
?? ??? ?
?? ??? ?try {
?? ??? ??? ?Client client = new Client();
?? ??? ??? ?client.start();
?? ??? ?} catch (Exception e) {
?? ??? ??? ?System.out.println("客戶(hù)端運(yùn)行失敗");
?? ??? ??? ?e.printStackTrace();
?? ??? ?}
?? ??? ?

?? ?}
?? ?
?? ?class ServerHandler implements Runnable{
?? ??? ?/**
?? ??? ? * 該線程用于讀取服務(wù)端發(fā)送過(guò)來(lái)的消息，并輸出到
?? ??? ? * 客戶(hù)端的控制臺(tái)上
?? ??? ? * @author zxm
?? ??? ? *
?? ??? ? */
?? ??? ?@Override
?? ??? ?public void run() {
?? ??? ??? ?try {
?? ??? ??? ??? ?InputStream in = socket.getInputStream();//輸入流
?? ??? ??? ??? ?InputStreamReader isr = new InputStreamReader(in,"UTF-8");//以u(píng)tf-8讀
?? ??? ??? ??? ?BufferedReader br = new BufferedReader(isr);
?? ??? ??? ??? ?String message = null;
?? ??? ??? ??? ?while((message=br.readLine())!=null) {
?? ??? ??? ??? ??? ?System.out.println(message);
?? ??? ??? ??? ?}
?? ??? ??? ?} catch (Exception e) {
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?}?
?? ??? ?}
?? ?}
?? ?

}

2. 服務(wù)端

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

/**
?* 聊天室服務(wù)端
?* @author zxm?
?*/
public class Server {
?? ?/*
?? ? * 運(yùn)行在服務(wù)端的socket
?? ? * 該類(lèi)的作用是：
?? ? * ?? ?1.申請(qǐng)服務(wù)端口，客戶(hù)端就是通過(guò)它申請(qǐng)的服務(wù)端口連接上服務(wù)端應(yīng)用的。
?? ? * ?2.監(jiān)聽(tīng)申請(qǐng)的服務(wù)端口感知客戶(hù)端的連接，并創(chuàng)建一個(gè)socket與該客戶(hù)通信。
?? ? */
?? ?private ServerSocket server;
?? ?
?? ?//存放所有客戶(hù)端的輸出流的集合，用于廣播
?? ?private List<PrintWriter> allOut;
?? ?
?? ?//將給定的輸出流放入共享集合
?? ?private synchronized void addOut(PrintWriter out){
?? ??? ?allOut.add(out);
?? ?}
?? ?
?? ?//將給定的輸出流移除共享集合
?? ?private synchronized void removeOut(PrintWriter out){
?? ??? ?allOut.remove(out);
?? ?}
?? ?
?? ?//將給定的消息發(fā)給多個(gè)客戶(hù)端
?? ?private synchronized void sendMessage(String message) {
?? ??? ?
?? ??? ?for(PrintWriter out:allOut) {
?? ??? ??? ?out.println(message);
?? ??? ?}
?? ?}
?? ?
?? ?//構(gòu)造方法初始化服務(wù)端
?? ?public Server() throws IOException {
?? ??? ?//實(shí)例化serverSocket的同時(shí)，指定服務(wù)端的端口號(hào)；
?? ??? ?try {
?? ??? ??? ?server = new ServerSocket(8888);
?? ??? ??? ?allOut = new ArrayList<PrintWriter>();
?? ??? ?} catch (Exception e) {
?? ??? ??? ?System.out.println("服務(wù)端初始化失敗");
?? ??? ??? ?throw e;
?? ??? ?}
?? ?}
?? ?
?? ?//服務(wù)端工作的方法
?? ?public void start() throws IOException {
?? ??? ?/*
?? ??? ? * ServerSocket提供了一個(gè)accept的方法，該方法是一個(gè)阻塞方法，
?? ??? ? * 用于監(jiān)聽(tīng)其打開(kāi)的8888端口；當(dāng)一個(gè)客戶(hù)端通過(guò)該端口與服務(wù)端連接時(shí)，
?? ??? ? * accept方法就會(huì)解除阻塞，然后創(chuàng)建一個(gè)socket實(shí)例并返回，
?? ??? ? * socket的作用就是與剛剛連接上的客戶(hù)端進(jìn)行通信。
?? ??? ? */
?? ??? ?while(true) {
?? ??? ??? ?System.out.println("等待客戶(hù)端連接...");
?? ??? ??? ?Socket socket = server.accept();
?? ??? ??? ?System.out.println("一個(gè)客戶(hù)端連接了！");
?? ??? ??? ?//啟動(dòng)一個(gè)線程來(lái)處理客戶(hù)端的交互工作
?? ??? ??? ?ClientHandler hander = new ClientHandler(socket);
?? ??? ??? ?Thread t = new Thread(hander);
?? ??? ??? ?t.start();
?? ??? ?}
?? ?}
?? ?
?? ?
?? ?public static void main(String[] args) throws Exception {
?? ??? ?Server server = new Server();
?? ??? ?server.start();
?? ?}
?? ?
?? ?/**
?? ? * 該線程類(lèi)是與指定的客戶(hù)端進(jìn)行交互工作；
?? ? * @author zxm
?? ? *
?? ? */
?? ?class ClientHandler implements Runnable{
?? ??? ?//當(dāng)前線程客戶(hù)端的Socket
?? ??? ?private Socket socket;
?? ??? ?
?? ??? ?//該客戶(hù)端的地址
?? ??? ?private String host;
?? ??? ?
?? ??? ?public ClientHandler(Socket socket) {
?? ??? ??? ?this.socket=socket;
?? ??? ??? ?/*
?? ??? ??? ? * 通過(guò)socket獲取遠(yuǎn)程計(jì)算機(jī)地址
?? ??? ??? ? * 對(duì)于服務(wù)端而言，遠(yuǎn)程計(jì)算機(jī)就是客戶(hù)端
?? ??? ??? ? */
?? ??? ??? ?InetAddress address = socket.getInetAddress();
?? ??? ??? ?
?? ??? ??? ?//獲取ip地址
?? ??? ??? ?host = address.getHostAddress();
?? ??? ??? ?System.out.println("host"+host);
?? ??? ?}

?? ??? ?@Override
?? ??? ?public void run() {
?? ??? ??? ?PrintWriter pw = null;
?? ??? ??? ?try {
?? ??? ??? ??? ?//廣播給所有客戶(hù)端，當(dāng)前用戶(hù)上線了
?? ??? ??? ??? ?sendMessage("["+host+"]上線了");
?? ??? ??? ??? ?OutputStream out = socket.getOutputStream();
?? ??? ??? ??? ?OutputStreamWriter osw = new OutputStreamWriter(out,"UTF-8");
?? ??? ??? ??? ?pw = new PrintWriter(osw,true);

?? ??? ??? ??? ?//將該客戶(hù)的輸出流存入共享集合，以便消息可以廣播給該客戶(hù)端
?? ??? ??? ??? ?addOut(pw);
?? ??? ??? ??? ?
?? ??? ??? ??? ?//廣播當(dāng)前在線人數(shù)
?? ??? ??? ??? ?sendMessage("當(dāng)前在線人數(shù)["+allOut.size()+"]");
?? ??? ??? ??? ?
?? ??? ??? ??? ?//處理來(lái)自客戶(hù)端的數(shù)據(jù)
?? ??? ??? ??? ?InputStream in = socket.getInputStream();
?? ??? ??? ??? ?InputStreamReader isr = new InputStreamReader(in,"utf-8");
?? ??? ??? ??? ?BufferedReader br = new BufferedReader(isr);
?? ??? ??? ??? ?/*
?? ??? ??? ??? ? * 服務(wù)端讀取客戶(hù)端發(fā)送過(guò)來(lái)的每一句字符時(shí)
?? ??? ??? ??? ? * 由于客戶(hù)端所在的操作系統(tǒng)不同，這里客戶(hù)端斷開(kāi)時(shí)結(jié)果也不同
?? ??? ??? ??? ? * windows客戶(hù)端開(kāi)始br.readLine拋出異常
?? ??? ??? ??? ? * Linux客戶(hù)端斷開(kāi)是返回null
?? ??? ??? ??? ? *?
?? ??? ??? ??? ? */
?? ??? ??? ??? ?String message = null;
?? ??? ??? ??? ?while((message = br.readLine())!=null) {
?? ??? ??? ??? ??? ?sendMessage(host+"說(shuō)："+message);
?? ??? ??? ??? ?}
?? ??? ??? ??? ?
?? ??? ??? ?} catch (Exception e) {
?? ??? ??? ??? ?// TODO Auto-generated catch block
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?}finally {
?? ??? ??? ??? ?//將該客戶(hù)端的輸出流從共享集合中刪除
?? ??? ??? ??? ?removeOut(pw);
?? ??? ??? ??? ?
?? ??? ??? ??? ?//廣播給所有客戶(hù)端，當(dāng)前用戶(hù)下線
?? ??? ??? ??? ?sendMessage("["+host+"]下線了");
?? ??? ??? ??? ?
?? ??? ??? ??? ?//廣播當(dāng)前在線人數(shù)
?? ??? ??? ??? ?sendMessage("當(dāng)前在線人數(shù)["+allOut.size()+"]");
?? ??? ??? ??? ?
?? ??? ??? ??? ?try {
?? ??? ??? ??? ??? ?socket.close();
?? ??? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ??? ?// TODO Auto-generated catch block
?? ??? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ??? ?}
?? ??? ??? ?}
?? ??? ?}
?? ?}
?? ?
}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: