導(dǎo)讀熱詞

最近研究了下Java socket通信基礎(chǔ)，利用代碼實(shí)現(xiàn)了一個(gè)簡單的多人聊天室功能，現(xiàn)把代碼共享下，希望能幫到有興趣了解的人。

目錄結(jié)構(gòu)：

ChatClient:

package com.panda.chat;

import java.awt.*;

import java.awt.event.*;

import java.io.*;

import java.net.*;

@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().frameClient();

}

public void frameClient(){

setSize(400,400);

setLocation(400,300);

add(ta,BorderLayout.NORTH);

add(tf,BorderLayout.SOUTH);

pack();

tf.addActionListener(new TfListener());

//關(guān)閉窗口事件監(jiān)聽

this.addWindowListener(new WindowAdapter() {

@Override

public void windowClosing(WindowEvent e) {

disconnected();

System.exit(0);

}

});

this.connect();

setVisible(true);

}

//鏈接服務(wù)器地址

private void connect(){

try {

socket = new Socket("127.0.0.1",8888);

thread=new Thread(new ChatThread());

thread.start();

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

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

} catch (UnknownHostException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

//斷開連接

private void disconnected(){

bConnected = false;

try {

dos.close();

dis.close();

socket.close();

} catch (IOException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}

}

//鍵盤回車事件

private class TfListener implements ActionListener{

@Override

public void actionPerformed(ActionEvent e) {

String strMsg = tf.getText();

tf.setText("");

try {

dos.writeUTF(strMsg);

dos.flush();

} catch (IOException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}

}

}

//開啟線程接受服務(wù)器信息

private class ChatThread implements Runnable{

@Override

public void run() {

try {

bConnected = true;

while(bConnected){

String msg = dis.readUTF();

String taText = ta.getText();

ta.setText(taText+msg+"\n");

}

} catch (SocketException e) {

System.out.println("退出");;

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

ChatServer:

package com.panda.chat;

import java.io.*;

import java.net.*;

import java.util.*;

public class ChatServer {

private boolean started = false;

private List chatThreads = new ArrayList();

public static void main(String[] args) {

new ChatServer().startServer();

}

private void startServer(){

try {

//開啟服務(wù)端Socket

ServerSocket seso = new ServerSocket(8888);

started = true;

while(started){

//接受客戶端連接請求

Socket sos = seso.accept();

System.out.println("一個(gè)客戶端已連接");

//開啟線程處理客戶端通信

ChatThread ct = new ChatThread(sos);

chatThreads.add(ct);

new Thread(ct).start();

}

} catch (IOException e) {

e.printStackTrace();

}

}

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();

this.socket = socket;

}

//發(fā)送信息的函數(shù)

private void send(String strMsgIn){

try{

don.writeUTF(strMsgIn);

don.flush();

}catch(IOException e){

e.printStackTrace();

}

}

@Override

public void run() {

try{

din = new DataInputStream(socket.getInputStream());

don = new DataOutputStream(socket.getOutputStream());

//讀取數(shù)據(jù)

bConnected = true;

while(bConnected){

String strMsgIn = din.readUTF();

System.out.println(strMsgIn);

//接收到數(shù)據(jù)后發(fā)送給每個(gè)客戶端

for(int i =0;i

chatThreads.get(i).send(strMsgIn);

}

}

}catch (IOException e) {

try {

//如果客戶端出錯(cuò)或關(guān)閉，直接關(guān)閉連接，并移除List中的當(dāng)前線程

socket.close();

chatThreads.remove(this);

} catch (IOException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}

} finally{

try {

din.close();

don.close();

socket.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

}

運(yùn)行ChatSever后，再同時(shí)打開多次ChatClient，就可以實(shí)現(xiàn)多人聊天了，你也試試。

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持編程小技巧。

相關(guān)文章

總結(jié)

如果覺得編程之家網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將編程之家網(wǎng)站推薦給程序員好友。

本圖文內(nèi)容來源于網(wǎng)友網(wǎng)絡(luò)收集整理提供，作為學(xué)習(xí)參考使用，版權(quán)屬于原作者。

如您喜歡交流學(xué)習(xí)經(jīng)驗(yàn)，點(diǎn)擊鏈接加入交流1群：1065694478(已滿)交流2群：163560250

總結(jié)

以上是生活随笔為你收集整理的java socket 聊天室_java利用Socket实现聊天室功能实例的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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