java實現(xiàn)小型局域網(wǎng)群聊功能(C/S模式)
更新時間：2022年05月19日 14:26:31 作者：西門吃雪
這篇文章主要介紹了java利用TCP協(xié)議實現(xiàn)小型局域網(wǎng)群聊功能(C/S模式) ，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
本文實例為大家分享了java群聊功能，供大家參考，具體內(nèi)容如下
Java 對TCP協(xié)議的支持：
--> java.net包中定義了兩個類ServerSocket 和Socket ，分別用來實現(xiàn)雙向連接的server 端和client 端。
--> Client 類定義客戶端
package com.dragon.java.tcpchat;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
/**
* 客戶端
*
* @author Auser
*
*/
public class Client {
public static void main(String args[]) throws UnknownHostException,
IOException {
Socket client = new Socket("192.168.1.188", 10000);
// 穿件發(fā)送信息的線程
new ClientSend(client).start();
// 創(chuàng)建接收信息的線程
new ClientReceive(client).start();
// 因為要實現(xiàn)聊天功能，而不是只發(fā)送一次信息，所以輸出流和客戶端都不能關閉。
// client.shutdownOutput();
// client.close();
}
}
--> ClientSend 類 定義客戶端向服務端發(fā)送信息的線程
package com.dragon.java.tcpchat;
import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;
/**
* 客戶端向服務端發(fā)送信息的線程
*
* @author Auser
*
*/
public class ClientSend extends Thread {
private Scanner scanner;
private Socket socket;
public ClientSend(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
scanner = new Scanner(System.in);
try {
PrintStream ps = new PrintStream(socket.getOutputStream());
String line = "";
// 阻塞式發(fā)送信息
while ((line = scanner.nextLine()) != null) {
ps.println(line);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
--> ClientReceive 類 定義客戶端接收服務端信息的線程
package com.dragon.java.tcpchat;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;
/**
* 客戶端接收信息的線程
*
* @author Auser
*
*/
public class ClientReceive extends Thread {
private Socket socket;
public ClientReceive(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
try {
BufferedReader br = new BufferedReader(new InputStreamReader(
socket.getInputStream()));
// 按行接收信息
String line = "";
while ((line = br.readLine()) != null) {
System.out.println(line);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
--> Server 類定義服務端
package com.dragon.java.tcpchat;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
/**
* 服務器
*
* @author Auser
*
*/
public class Server {
public static void main(String[] args) throws IOException,
InterruptedException {
List<Socket> list = new ArrayList<>();
// 創(chuàng)建服務器端的套接字
ServerSocket server = new ServerSocket(10000);
while (true) {
// 接收客戶端的阻塞方法
Socket socket = server.accept();
// 設計到多個線程可能會對集合進行增刪的操作，要進行同步的處理
synchronized (list) {
list.add(socket);
}
// 啟動一個新的線程去處理這個客戶端的交流
new HandleSocket(socket, list).start();
}
// 因為不知道客戶端什么時候發(fā)送信息，所以服務端要一直開啟不能關閉。
}
}
--> HandleSocket 類對連接到服務端的客戶端進行操作(上下線通知、屏蔽拉黑、將信息發(fā)送到每個客戶端等...)
package com.dragon.java.tcpchat;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.Socket;
import java.util.List;
/**
* 處理每個(單個)連接到服務器的客戶端的線程
*
* @author Auser
*
*/
public class HandleSocket extends Thread {
private Socket socket;
private List<Socket> list;
/**
* 構造方法
*
* @param socket
* 當前連接的客戶端
* @param list
* 存儲已連接客戶端的集合
*/
public HandleSocket(Socket socket, List<Socket> list) {
this.socket = socket;
this.list = list;
}
/**
* 線程run方法
*/
@Override
public void run() {
InetAddress address = socket.getInetAddress(); // 獲取連接到服務器的這的客戶端的地址
String ip = address.getHostAddress();
System.out.println(ip + "上線了！");
if (ip.equals("192.168.1.117")) {
synchronized (list) {
sendToAll(ip + "由于違規(guī)操作，已被拉入黑名單！");
list.remove(socket);
}
return;
}
try {
BufferedReader br = new BufferedReader(new InputStreamReader(
socket.getInputStream(), "gbk"));
String line = "";
while ((line = br.readLine()) != null) {
String msg = ip + ":" + line;
System.out.println(msg); // 輸出到服務器端的控制臺
// 把這個客戶端說的話，發(fā)給其他所有的客戶端
sendToAll(msg);
}
} catch (IOException e) {
// e.printStackTrace();
System.out.println(ip + "下線了！");
synchronized (list) {
list.remove(socket);
}
}
}
/**
* 把信息發(fā)送給所有的客戶端，去除當前socket
*
* @param msg
* 發(fā)送的信息
*/
private void sendToAll(String msg) {
synchronized (list) {
for (Socket s : list) {
if (s != socket) {
try {
PrintStream ps = new PrintStream(s.getOutputStream());
ps.println();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}
}
--> 注意：因為要實現(xiàn)客戶端連接到服務端，即客戶端要先找到服務端，所以服務端要先開啟，再開啟服務端...
以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
這篇文章主要介紹了JPA中JpaRepository接口的使用方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
解析Orika的MapperFacade 屬性賦值的使用問題
在我們實際開發(fā)中，常常會有對象與對象之間的轉化，或者把一個對象的數(shù)據(jù)轉化到另一個數(shù)據(jù)之中，如果我們手動的一個一個的set就會比較麻煩，代碼段看起來也會比較長。而Orika的MapperFacade就是解決這個問題的，實現(xiàn)對象屬性的復制2021-12-12
API版本控制是確保系統(tǒng)平穩(wěn)演進的關鍵策略,這篇文章主要為大家詳細介紹了SpringBoot中6種API版本控制策略,大家可以根據(jù)需要自行選擇2025-04-04
Feign是Netflix公司開發(fā)的一個聲明式的REST調(diào)用客戶端; Ribbon負載均衡、 Hystrⅸ服務熔斷是我們Spring Cloud中進行微服務開發(fā)非?；A的組件,在使用的過程中我們也發(fā)現(xiàn)它們一般都是同時出現(xiàn)的,而且配置也都非常相似2022-11-11
這篇文章主要為大家詳細介紹了java web實現(xiàn)簡易收費站，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一2020-11-11
這篇文章主要為大家詳細介紹了java使用鏈表實現(xiàn)約瑟夫環(huán)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2019-05-05
淺談String類型如何轉換為time類型存進數(shù)據(jù)庫
這篇文章主要介紹了String類型如何轉換為time類型存進數(shù)據(jù)庫，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
SpringBoot如何在運行時動態(tài)添加數(shù)據(jù)源
這篇文章主要介紹了SpringBoot如何在運行時動態(tài)添加數(shù)據(jù)源,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-10-10
flowable動態(tài)創(chuàng)建多級流程模板實現(xiàn)demo
這篇文章主要為大家介紹了flowable動態(tài)創(chuàng)建多級流程模板實現(xiàn)demo，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-05-05
堆排序是利用堆這種數(shù)據(jù)結構而設計的一種排序算法，堆排序是一種選擇排序，它的最壞，最好，平均時間復雜度均為O(nlogn)，它也是不穩(wěn)定排序。首先簡單了解下堆結構2022-01-01