Java網絡編程實例——簡單模擬在線聊天
更新時間：2021年05月31日 11:56:52 作者：bluesky
學了java網絡，也是該做個小案例來鞏固一下了。本次案例將使用UDP和多線程模擬即時聊天，簡單練練手。
1、前提知識
需要知道簡單的IO流操作，以及簡單的UDP發(fā)送數(shù)據(jù)包的原理。
需要用到的類：DatagramSocket、DatagramPacket
UDP數(shù)據(jù)包基于DatagramSocket發(fā)送和接收，DatagramPacket用于封裝數(shù)據(jù)包
看下案例：
客戶端發(fā)送消息：
正常情況下從控制臺讀信息，封裝到DatagramPacket之中，再由DatagramSocket的send方法發(fā)出
讀取到bye的時候退出聊天
public class UdpOnlineClient {
public static void main(String[] args) throws IOException {
DatagramSocket socket = new DatagramSocket(10000);
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
while (true) {
String data = bufferedReader.readLine();
byte[] datas = data.getBytes();
DatagramPacket packet = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress("localhost", 9999));
socket.send(packet);
if (data.equals("bye")){
break;
}
}
socket.close();
}
}
服務端接收消息：
DatagramSocket的receive方法接收客戶端發(fā)送的消息，打印到控制臺，如果信息是bye則退出聊天
public class UdpOnlineServer {
public static void main(String[] args) throws IOException {
DatagramSocket socket = new DatagramSocket(9999);
while (true){
byte[] buffer = new byte[1024];
DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);
socket.receive(packet);
String msg = new String(packet.getData(), 0, packet.getLength());
System.out.println(msg);
if(msg.equals("bye")){
break;
}
}
socket.close();
}
}
試驗：正常開啟客戶端和服務端后：
客戶端發(fā)送消息：
服務端接收到信息即成功：
有了這個思路，我們只需要把發(fā)送和接收封裝成發(fā)送類和接收類，使用多線程即可實現(xiàn)聊天了
2、實現(xiàn)思路：
創(chuàng)建UDP發(fā)送實現(xiàn)類TaskSend、UDP接收實現(xiàn)類TaskReceive，以及模擬多線程通信的通信類ChatThread1、ChatThread2
UDP發(fā)送實現(xiàn)類TaskSend：
public class TaskSend implements Runnable{
private String sendIP;
//自己的服務端口
private int ownPort;
private int sendPort;
//讀取控制臺輸入流
private BufferedReader bufferedReader;
private DatagramSocket socket;
public TaskSend(String sendIP, int ownPort, int sendPort) {
this.sendIP = sendIP;
this.sendPort = sendPort;
try {
socket = new DatagramSocket(ownPort);
bufferedReader = new BufferedReader(new InputStreamReader(System.in));
} catch (SocketException e) {
e.printStackTrace();
} finally {
}
}
//發(fā)送消息
public void run() {
while (true) {
try {
String data = bufferedReader.readLine();
//打印自己的消息
System.out.println("我："+data);
byte[] datas = data.getBytes();
DatagramPacket packet = new DatagramPacket(datas, 0, datas.length,new InetSocketAddress(sendIP,sendPort));
socket.send(packet);
if (data.equals("bye")) {
break;
}
} catch (IOException e) {
e.printStackTrace();
} finally {
}
}
socket.close();
}
}
UDP接收實現(xiàn)類TaskReceive：
public class TaskReceive implements Runnable{
private int ownPort;
//發(fā)送信息的人
private String msgOwner;
private DatagramSocket socket;
public TaskReceive(int ownPort, String msgOwner) {
this.msgOwner = msgOwner;
try {
socket = new DatagramSocket(ownPort);
} catch (SocketException e) {
e.printStackTrace();
} finally {
}
}
//接收消息
public void run() {
while (true) {
try {
byte[] buffer = new byte[1024];
DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);
socket.receive(packet);
String msg = new String(packet.getData(), 0, packet.getLength());
System.out.println(msgOwner+"："+msg);
if (msg.equals("bye")) {
break;
}
} catch (IOException e) {
e.printStackTrace();
} finally {
}
}
socket.close();
}
}
之后使用兩個通信類開啟多線程模擬一下：
模擬老師
public class ChatThread1 {
public static void main(String[] args) {
new Thread(new TaskSend("localhost",9999,10000)).start();
new Thread(new TaskReceive(9998,"老師")).start();
}
}
模擬學生
public class ChatThread2 {
public static void main(String[] args) {
new Thread(new TaskReceive(9999,"學生")).start();
new Thread(new TaskSend("localhost",9998,10001)).start();
}
}
實例：
學生
老師
到此簡單的在線聊天功能就完成了，可以鞏固一下之前學習的網絡知識
以上就是Java網絡編程實例——簡單模擬在線聊天的詳細內容，更多關于Java 模擬在線聊天的資料請關注腳本之家其它相關文章！
相關文章
如何去掉IntelliJ IDEA中mybatis對應的xml文件警告
這篇文章主要介紹了如何去掉IntelliJ IDEA中mybatis對應的xml文件警告問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-04-04
這篇文章主要介紹了Java父類調用子類的方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-04-04
SpringBoot 2.6.x整合springfox 3.0報錯問題及解決方案
這篇文章主要介紹了SpringBoot 2.6.x整合springfox 3.0報錯問題及解決方案,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-01-01
這篇文章主要介紹了mybatis如何批量更新list對象問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-12-12
這篇文章主要介紹了Spring啟動后獲取所有擁有特定注解的Bean實例代碼，分享了相關代碼示例，小編覺得還是挺不錯的，具有一定借鑒價值，需要的朋友可以參考下2018-02-02
springboot druid數(shù)據(jù)庫配置密碼加密的實現(xiàn)
Druid是阿里開發(fā)的數(shù)據(jù)庫連接池,本文主要介紹了springboot druid數(shù)據(jù)庫配置密碼加密的實現(xiàn),具有一定的參考價值,感興趣的可以了解一下2024-06-06
這篇文章主要介紹了Spring?Cloud?Eureka(全面解析)?大白話，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
用3個實例從原理到實戰(zhàn)講清楚Log4j史詩級漏洞
最近應該很多人都在關注著一個漏洞Apache Log4j 2遠程代碼執(zhí)行,該漏洞一旦被攻擊者利用會造成嚴重危害,這篇文章主要給大家介紹了關于如何用3個實例從原理到實戰(zhàn)講清楚Log4j史詩級漏洞的相關資料,需要的朋友可以參考下2021-12-12
這篇文章主要介紹了IDEA打包應用程序的教程，本文通過圖文并茂的形式給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-07-07
下面小編就為大家?guī)硪黄钊肫饰鰆ava中的集合框架。小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2016-05-05