思路

客戶端讀寫各一個類，可以使內(nèi)部類，實現(xiàn)Runnable。讀寫類都與服務(wù)器端建立連接，一個收，一個發(fā)。

客戶端實現(xiàn)接收和轉(zhuǎn)發(fā)。多線程實現(xiàn)每個客戶端的連接(使與各客戶端的連接獨立)。

服務(wù)器端中創(chuàng)建一個公共緩沖池，用于存放消息。通過服務(wù)器中的轉(zhuǎn)發(fā)方法轉(zhuǎn)發(fā)給個客戶端。

客戶端?代碼

package _20191218;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.IOException;

import java.net.Socket;

import java.net.UnknownHostException;

import java.util.Scanner;

/**

*多人聊天室，客戶端，實時發(fā)送接收數(shù)據(jù)，要實現(xiàn)多線程

*/

public class TCPMultipleChatClient {

public static void main(String[] args) {

System.out.println("-------局域網(wǎng)聊天室-----------");

Scanner scan1 = new Scanner(System.in);

System.out.print("請輸入您的昵稱：");

String username = scan1.nextLine();

String address = "176.195.108.53";//服務(wù)器地址

int port = 6788;//服務(wù)器程序端口

Socket client = null;

try {

client = new Socket(address,port);

System.out.println("成功登入，可以開始聊天了！");

System.out.println("------------------------");

} catch (UnknownHostException e) {

System.err.println("服務(wù)器連接失敗");

} catch (IOException e) {

System.err.println("服務(wù)器連接失敗");

}

/**

* 啟動接收器與發(fā)送器

*/

new Thread(new Sender(client),username).start();

new Thread(new Receiver(client)).start();

}

}

//發(fā)送器：實現(xiàn)Runnable

class Sender implements Runnable{

private boolean flag = true;//服務(wù)器存活為 true

//輸出流

private DataOutputStream dos;

//構(gòu)造器：初始化

public Sender(Socket client) {

try {

dos = new DataOutputStream(client.getOutputStream());

} catch (IOException e) {

System.err.println("服務(wù)器未開啟，連接失敗");

}

}

public void sendMessage() {

Scanner scan = new Scanner(System.in);

String message = scan.nextLine();

try {

dos.writeUTF(Thread.currentThread().getName()+":"+message);

dos.flush();

} catch (IOException e) {

System.err.println("Sender:服務(wù)器關(guān)閉");

flag = false;

}

}

public void run() {

while(flag) {

sendMessage();

try {

Thread.sleep(500);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

}

//接收器:實現(xiàn)Runnable

class Receiver implements Runnable{

private boolean flag = true;//服務(wù)器存活為 true

//輸入流

private DataInputStream dis;

public Receiver(Socket client) {

try {

dis = new DataInputStream(client.getInputStream());

} catch (IOException e) {

e.printStackTrace();

}

}

//讀取消息

public void readMessage() {

try {

System.out.println(dis.readUTF());

} catch (IOException e) {

System.err.println("Reciver:服務(wù)器關(guān)閉");

flag =false;

}

}

public void run() {

while(flag) {

readMessage();

try {

Thread.sleep(500);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

}

//}

服務(wù)器端?代碼

package _20191218;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.Scanner;

/**

* 多人聊天室，服務(wù)端，實時轉(zhuǎn)發(fā)數(shù)據(jù)

*/

public class TCPMultipleChatServer {

public static void main(String[] args) {

System.out.println("服務(wù)端開啟");

//創(chuàng)建服務(wù)器端

ServerSocket server = null;

try {

server = new ServerSocket(6788);//服務(wù)器端口

} catch (IOException e) {

e.printStackTrace();

}

//容器

Container container = new Container();

//循環(huán)監(jiān)聽

while(true) {

//阻塞監(jiān)聽連接請求

try {

Socket client = server.accept();

System.out.println("一位用戶成功連接");

container.doCount();

//開啟接收器

new Thread(new Receiver(client,container)).start();

//開啟轉(zhuǎn)發(fā)器

new Thread(new Transmit(client,container)).start();

} catch (IOException e) {

e.printStackTrace();

}

}

}

static class Container{

//StringBuffer wrap = new StringBuffer();

static int userCount = 0;//當(dāng)前用戶量

private int now = 0;//已轉(zhuǎn)發(fā)量

private String[] strs = new String[1024];//消息隊列

private int i = 0;//消息計數(shù)器

public void add(String message) {

strs[i]=message;

i++;

}

public static void doCount() {//用戶量加一

userCount++;

}

public void subUserCount() {//用戶量減一

userCount--;

}

public void reset() {

if(now == userCount) {

strs = new String[1024];

now = 0;

}

}

}

static class Receiver implements Runnable{

private boolean flag = true;

private Container container;

private DataInputStream dis;

public Receiver(Socket client,Container container) {

this.container = container;

try {

dis = new DataInputStream(client.getInputStream());

} catch (IOException e) {

e.printStackTrace();

}

}

//讀取消息

public void readMessage() {

try {

//存入容器

String str = "";

if(!(str = dis.readUTF()).equals("")) {

container.add(str);

}

} catch (IOException e) {

flag = false;

System.err.println("Read:用戶已離開會話");

container.subUserCount();

}

}

public void run() {

while(flag) {

readMessage();

}

}

}

//轉(zhuǎn)發(fā)

static class Transmit implements Runnable{

private boolean flag = true;

private Container container;

private DataOutputStream dos;

public Transmit(Socket client, Container container) {

this.container = container;

try {

this.dos = new DataOutputStream(client.getOutputStream());

} catch (IOException e) {

flag = false;

System.err.println("Transmit:用戶已離開會話");

}

}

public void run() {

while(flag) {

transmit();

try {

Thread.sleep(500);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

public void transmit() {

for(String str : container.strs) {

try {

if(str==null) {

continue;

}

System.out.println("已轉(zhuǎn)發(fā)消息："+str);

container.now++;

dos.writeUTF(str);

dos.flush();

} catch (IOException e) {

e.printStackTrace();

}

}

container.reset();//轉(zhuǎn)發(fā)完后清空

}

}

}

演示

服務(wù)器端運行一個，客戶端運行多個。

總結(jié)

以上是生活随笔為你收集整理的c语言tcp多线程聊天室,66 网络编程（五）——TCP多线程实现多人聊天室的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。