java實現(xiàn)在線聊天系統(tǒng)
更新時間：2022年09月15日 11:20:41 作者：sd訫訴sd
這篇文章主要為大家詳細介紹了java實現(xiàn)在線聊天系統(tǒng)，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
本文實例為大家分享了java實現(xiàn)在線聊天系統(tǒng)的具體代碼，供大家參考，具體內容如下
本博客是博主在觀看相關視頻后寫下的代碼，希望能夠幫助大家掌握java socket的相關知識。
- 原理介紹
- 代碼展示
原理介紹
一、搭建服務器端
a)、創(chuàng)建ServerSocket對象綁定監(jiān)聽端口。
b)、通過accept()方法監(jiān)聽客戶端的請求。
c)、建立連接后，通過輸入輸出流讀取客戶端發(fā)送的請求信息。
d)、通過輸出流向客戶端發(fā)送請求信息。
e)、關閉相關資源。
二、搭建客戶器端
a)、創(chuàng)建Socket對象，指明需要連接的服務器的地址和端口。
b)、建立連接后，通過輸出流向服務器發(fā)送請求信息。
c)、通過輸入流獲取服務器的響應信息。
d)、關閉響應資源
代碼展示
服務器端代碼：
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;
/**
?* 版本三：轉發(fā)給其他的客戶端 1.保存每一個客戶端的連接
?*
?*/
public class ChatSeverEdition3 {
? ? // 服務器端是否啟動
? ? boolean started = false;
? ? ServerSocket serverSocket = null;
? ? ArrayList<Client> clients = new ArrayList<Client>();
? ? public static void main(String[] args) {
? ? ? ? new ChatSeverEdition3().start();
? ? }
? ? public void start() {
? ? ? ? try {
? ? ? ? ? ? serverSocket = new ServerSocket(8888);
? ? ? ? ? ? started = true;
? ? ? ? } catch (BindException e) {
? ? ? ? ? ? // 多次啟動服務器
? ? ? ? ? ? System.out.println("端口使用中。。。。");
? ? ? ? ? ? System.out.println("請關掉相關程序，并重新運行服務器！");
? ? ? ? ? ? System.exit(0);
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? ? ? try {
? ? ? ? ? ? while (started) {
? ? ? ? ? ? ? ? // 客戶端是否連接
? ? ? ? ? ? ? ? Socket socket = serverSocket.accept();
? ? ? ? ? ? ? ? // main()方法是static方法，不能在其中new動態(tài)類Client
? ? ? ? ? ? ? ? Client client = new Client(socket);
? ? ? ? ? ? ? ? // 線程啟動
? ? ? ? ? ? ? ? new Thread(client).start();
? ? ? ? ? ? ? ? // 將當前啟動的客戶端保存下來
? ? ? ? ? ? ? ? clients.add(client);
? ? ? ? ? ? ? ? System.out.println("new Client成功！");
? ? ? ? ? ? ? ? System.out.println("A Client connected!");
? ? ? ? ? ? }
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? } finally {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? serverSocket.close();
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }
? ? /**
? ? ?*?
? ? ?*?
? ? ?*
? ? ?*/
? ? class Client implements Runnable {
? ? ? ? private Socket s;
? ? ? ? private DataInputStream dis = null;
? ? ? ? private boolean bConnected = false;
? ? ? ? private DataOutputStream dos;
? ? ? ? public Client(Socket s) {
? ? ? ? ? ? this.s = s;
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? dis = new DataInputStream(s.getInputStream());
? ? ? ? ? ? ? ? dos = new DataOutputStream(s.getOutputStream());
? ? ? ? ? ? ? ? bConnected = true;
? ? ? ? ? ? ? ? System.out.println("有一個新的客戶端程序在運行");
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? ? ? // 一個客戶端連接成功以后，一直在執(zhí)行該while部分的代碼，其他客戶端無法連接
? ? ? ? ? ? /**
? ? ? ? ? ? ?* 解決方法： 1.異步解決方法：一直監(jiān)聽接收，其他在另外的地方執(zhí)行 2.使用單獨的線程： 線程：接受客戶端連接
? ? ? ? ? ? ?* 另外的單獨的線程：處理通訊
? ? ? ? ? ? ?*/
? ? ? ? }
? ? ? ? public void sendString(String str) {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? dos.writeUTF(str);
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? clients.remove(this);
? ? ? ? ? ? ? ? System.out.println("對方退出了！?。∥覐腖ist中去掉了?。?！");
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? public void run() {
? ? ? ? ? ? Client client = null;
? ? ? ? ? ? // 注意這部分的包圍關系
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? while (bConnected) {
? ? ? ? ? ? ? ? ? ? String string = dis.readUTF();
? ? ? ? ? ? ? ? ? ? System.out.println(string);
? ? ? ? ? ? ? ? ? ? for (int i = 0; i < clients.size(); i++) {
? ? ? ? ? ? ? ? ? ? ? ? client = clients.get(i);
? ? ? ? ? ? ? ? ? ? ? ? client.sendString(string);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? } catch (EOFException e) {
? ? ? ? ? ? ? ? System.out.println("Client closed!");
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? System.exit(0);
? ? ? ? ? ? } finally {
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? if (dis != null) {
? ? ? ? ? ? ? ? ? ? ? ? dis.close();
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? if (s != null) {
? ? ? ? ? ? ? ? ? ? ? ? s.close();
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? }
}客戶端代碼：
import java.awt.BorderLayout;
import java.awt.Frame;
import java.awt.TextArea;
import java.awt.TextField;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.BindException;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownHostException;
/**
?* 可以和ChatServer版本三配套使用
?*?
?* @author Administrator
?*
?*/
public class ChatClientEdition3 extends Frame {
? ? TextField tfText = new TextField();
? ? TextArea taContent = new TextArea();
? ? Socket socket = null;
? ? DataOutputStream dataOutputStream = null;
? ? DataInputStream dataInputStream = null;
? ? private boolean bConnected = false;
? ? public static void main(String[] args) {
? ? ? ? new ChatClientEdition3().launchFrame();
? ? }
? ? // 加載窗口
? ? public void launchFrame() {
? ? ? ? setLocation(400, 300);
? ? ? ? this.setSize(300, 300);
? ? ? ? this.setTitle("在線聊天時--Quiana");
? ? ? ? add(tfText, BorderLayout.SOUTH);
? ? ? ? add(taContent, BorderLayout.NORTH);
? ? ? ? pack();
? ? ? ? // 窗口關閉的時間監(jiān)聽
? ? ? ? this.addWindowListener(new WindowAdapter() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void windowClosing(WindowEvent e) {
? ? ? ? ? ? ? ? disconnect();
? ? ? ? ? ? ? ? System.exit(0);
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? tfText.addActionListener(new TFListener());
? ? ? ? this.setVisible(true);
? ? ? ? connect();
? ? ? ? new Thread(new RecvThread()).start();
? ? }
? ? // 文字處理的時間監(jiān)聽
? ? private class TFListener implements ActionListener {
? ? ? ? // 敲擊回車時，文字的變化事件
? ? ? ? @Override
? ? ? ? public void actionPerformed(ActionEvent arg0) {
? ? ? ? ? ? String s = tfText.getText().trim(); // 去掉兩端的空格
? ? ? ? ? ? tfText.setText("");
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? dataOutputStream.writeUTF(s);
? ? ? ? ? ? ? ? dataOutputStream.flush();
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }
? ? // 連接到服務器
? ? public void connect() {
? ? ? ? try {
? ? ? ? ? ? // 連接到服務器
? ? ? ? ? ? socket = new Socket("127.0.0.1", 8888);
? ? ? ? ? ? bConnected = true;
? ? ? ? ? ? dataOutputStream = new DataOutputStream(socket.getOutputStream());
? ? ? ? ? ? dataInputStream = new DataInputStream(socket.getInputStream());
? ? ? ? ? ? System.out.println("連接到服務器！??！");
? ? ? ? } catch (BindException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? } catch (UnknownHostException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? }
? ? // 斷開連接
? ? public void disconnect() {
? ? ? ? try {
? ? ? ? ? ? dataOutputStream.close();
? ? ? ? ? ? System.out.println("dataOutputStream成功關閉");
? ? ? ? ? ? socket.close();
? ? ? ? ? ? System.out.println("客戶端socket成功關閉");
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? }
? ? private class RecvThread implements Runnable {
? ? ? ? public void run() {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? while (bConnected) {
? ? ? ? ? ? ? ? ? ? String string = dataInputStream.readUTF();
? ? ? ? ? ? ? ? ? ? if (taContent.getText().length() == 0) {
? ? ? ? ? ? ? ? ? ? ? ? taContent.setText(string);
? ? ? ? ? ? ? ? ? ? } else {
? ? ? ? ? ? ? ? ? ? ? ? taContent.setText(taContent.getText() + "\n" + string);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? } catch (SocketException e) {
? ? ? ? ? ? ? ? System.out.println("退出了，拜拜！");
? ? ? ? ? ? } catch (EOFException e) {
? ? ? ? ? ? ? ? System.out.println("退出了，拜拜！");
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }
}以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
Springboot2.x 使用 Log4j2 異步打印日志的實現(xiàn)
這篇文章主要介紹了Springboot2.x 使用 Log4j2 異步打印日志的實現(xiàn),文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-12-12
要判斷一個字符串是否符合時間格式,可以使用正則表達式,本文主要介紹了Java中使用正則檢查有效日期的實現(xiàn),具有一定的參考價值,感興趣的可以了解一下2023-10-10
這篇文章主要介紹了Java代理模式,結合實例形式詳細分析了java基本數據類型、數據類型轉換、算術運算符、邏輯運算符等相關原理與操作技巧,需要的朋友可以參考下2021-08-08
AbstractProcessor擴展MapStruct自動生成實體映射工具類
這篇文章主要為大家介紹了AbstractProcessor擴展MapStruct自動生成實體映射工具類實現(xiàn)詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-01-01
這篇文章主要介紹了后臺防止表單重復提交,利用Session防止表單重復提交，判斷請求url和數據是否和上一次相同，利用Spring AOP和redis的鎖需要的朋友可以參考下2022-12-12
java中的異常處理是java語言中的一大重要特性，它分離了接收和處理錯誤代碼。這篇文章非常詳細的講解了java中的這一特性，感興趣的小伙伴一起來學習學習吧2021-08-08
Kotlin中使用Java數據類時引發(fā)的Bug解決方式
這篇文章主要介紹了Kotlin中使用Java數據類時引發(fā)的一個Bug,本文給大家分享問題解決方式，感興趣的朋友跟隨小編一起看看吧2023-09-09
這篇文章主要為大家詳細介紹了Java調用外接設備的相關資料，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-07-07
這篇文章主要介紹了springboot集成shiro自定義登陸過濾器方法，文章圍繞主題展開詳細的內容介紹，具有一定的參考價值，需要的小伙伴可以參考一下2022-08-08
這篇文章主要為大家詳細介紹了java設計模式之單例模式的相關資料，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-11-11