如何运用Java socket实现多人聊天室功能

导语：如何运用Java socket实现多人聊天室功能呢?下面是小编给大家提供的代码实现，大家可以参考阅读，更多详情请关注应届毕业生考试网。

目录结构：

　　ChatClient:

import .*;

import t.*;

import .*;

import .*;

@SuppressWarnings("serial")

public class ChatClient extends Frame {

private TextArea ta = new TextArea();

private TextField tf = new TextField();

private DataOutputStream dos = null;

private DataInputStream dis = null;

private Socket socket = null;

private boolean bConnected = false;

private Thread thread=null;

public static void main(String[] args) {

new ChatClient()eClient();

}

public void frameClient(){

setSize(400, 400);

setLocation(400,300);

add(ta,H);

add(tf,H);

pack();

ctionListener(new TfListener());

//关闭窗口事件监听

indowListener(new WindowAdapter() {

@Override

public void windowClosing(WindowEvent e) {

disconnected();

(0);

}

});

ect();

setVisible(true);

}

//链接服务器地址

private void connect(){

try {

socket = new Socket("", 8888);

thread=new Thread(new ChatThread());

t();

dos = new DataOutputStream(utputStream());

dis = new DataInputStream(nputStream());

} catch (UnknownHostException e) {

// TODO Auto-generated catch block

tStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

tStackTrace();

}

}

//断开连接

private void disconnected(){

bConnected = false;

try {

e();

e();

e();

} catch (IOException e1) {

// TODO Auto-generated catch block

tStackTrace();

}

}

//键盘回车事件

private class TfListener implements ActionListener{

@Override

public void actionPerformed(ActionEvent e) {

String strMsg = ext();

ext("");

try {

eUTF(strMsg);

h();

} catch (IOException e1) {

// TODO Auto-generated catch block

tStackTrace();

}

}

}

//开启线程接受服务器信息

private class ChatThread implements Runnable{

@Override

public void run() {

try {

bConnected = true;

while(bConnected){

String msg = UTF();

String taText = ext();

ext(taText+msg+"n");

}

} catch (SocketException e) {

tln("退出");;

} catch (IOException e) {

tStackTrace();

}

}

}

}

　　ChatServer:

package ;

import .*;

import .*;

import .*;

public class ChatServer {

private boolean started = false;

private List<ChatThread> chatThreads = new ArrayList<ChatThread>();

public static void main(String[] args) {

new ChatServer()tServer();

}

private void startServer(){

try {

//开启服务端Socket

ServerSocket seso = new ServerSocket(8888);

started = true;

while(started){

//接受客户端连接请求

Socket sos = pt();

tln("一个客户端已连接");

//开启线程处理客户端通信

ChatThread ct = new ChatThread(sos);

(ct);

new Thread(ct)t();

}

} catch (IOException e) {

tStackTrace();

}

}

private class ChatThread implements Runnable{

private Socket socket;

private DataInputStream din=null;

private DataOutputStream don=null;

private boolean bConnected = false;

public ChatThread(Socket socket) {

super();

et = socket;

}

//发送信息的函数

private void send(String strMsgIn){

try{

eUTF(strMsgIn);

h();

}catch(IOException e){

tStackTrace();

}

}

@Override

public void run() {

try{

din = new DataInputStream(nputStream());

don = new DataOutputStream(utputStream());

//读取数据

bConnected = true;

while(bConnected){

String strMsgIn = UTF();

tln(strMsgIn);

//接收到数据后发送给每个客户端

for(int i =0;i<();i++){

(i)(strMsgIn);

}

}

}catch (IOException e) {

try {

//如果客户端出错或关闭，直接关闭连接，并移除List中的当前线程

e();

ve(this);

} catch (IOException e1) {

// TODO Auto-generated catch block

tStackTrace();

}

} finally{

try {

e();

e();

e();

} catch (IOException e) {

// TODO Auto-generated catch block

tStackTrace();

}

}

}

}

}

运行ChatSever后，再同时打开多次ChatClient，就可以实现多人聊天了，你也试试。