导语:如何运用Java socket实现多人聊天室功能呢?下面是小编给大家提供的代码实现,大家可以参考阅读,更多详情请关注应届毕业生考试网。
目录结构:
ChatClient:
package ;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,就可以实现多人聊天了,你也试试。