JAVA Socket实现多客户端聊天
生活随笔
收集整理的這篇文章主要介紹了
JAVA Socket实现多客户端聊天
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
本實例實現了多客戶端運行并進行聊天的功能 服務端聊天效果為：
客戶端聊天效果：
服務器端代碼：
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;public class MyServer {
private ServerSocket ss = null;
private Boolean isConnected = false;
private ChatThread chatThread[];
private int maxClient = 10;
private int clientNum = 0;public MyServer() {}public static void main(String[] args) {
new MyServer().startServer();
}private void startServer() {
try {
ss = new ServerSocket(8888, maxClient);
isConnected = true;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}if (isConnected) {
System.out.println("服務器上線了~");
} else {
System.out.println("服務器沒上線~");
}if (isConnected) {
chatThread = new ChatThread[maxClient];
for (int i = 0; i < maxClient; i++) {
try {
chatThread[i] = new ChatThread(ss.accept());
chatThread[i].start();
clientNum++;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}private class ChatThread extends Thread {
private Socket socket = null;
private String ip;
private DataInputStream dis;
private DataOutputStream dos;public ChatThread(Socket socket) {
this.socket = socket;
ip = socket.getInetAddress().toString();
ip = ip.replace("/", "");
System.out.println(ip + "上線了");
try {
dis = new DataInputStream(socket.getInputStream());
dos = new DataOutputStream(socket.getOutputStream());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}public void run() {while (isConnected) {
try {
String message = dis.readUTF();
System.out.println(ip + "說：\n" + message);
for (int i = 0; i < maxClient; i++) {
if (chatThread[i] != null) {
chatThread[i].dos.writeUTF(ip + "說：\n" + message);
chatThread[i].dos.flush();
}
}
} catch (IOException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
System.out.println(ip + "下線了");
break;
}
}
}
}
}
客戶端代碼：
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;import javax.swing.JOptionPane;public class Client {
private Socket s = null;
private OutputStream os;
private InputStream is;
private String str = null;
private Boolean isConnected = false;
private DataInputStream dis;
private DataOutputStream dos;public static void main(String[] args) {
new Client().StartClient();
}
private void StartClient(){
try {
s = new Socket("192.168.1.100", 8888);
isConnected = true;
System.out.println("連接到服務器了");dis = new DataInputStream(s.getInputStream());
dos = new DataOutputStream(s.getOutputStream());new ClientThread().start();
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
private class ClientThread extends Thread{
public void run() {
while (isConnected) {
try {
str = JOptionPane.showInputDialog("請輸入要說的話:");
if (str != null) {
dos.writeUTF(str);
}else{
s.close();
isConnected = false;
}
String message = dis.readUTF();
System.out.println(message);
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
總結
以上是生活随笔為你收集整理的JAVA Socket实现多客户端聊天的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： WINDOW下，node.js的安装
- 下一篇： ShopEx 属性筛选增加 不限 条件