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