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)視頻后寫(xiě)下的代碼，希望能夠幫助大家掌握java socket的相關(guān)知識(shí)。

原理介紹
代碼展示

原理介紹

一、搭建服務(wù)器端

a)、創(chuàng)建ServerSocket對(duì)象綁定監(jiān)聽(tīng)端口。
b)、通過(guò)accept()方法監(jiān)聽(tīng)客戶端的請(qǐng)求。
c)、建立連接后，通過(guò)輸入輸出流讀取客戶端發(fā)送的請(qǐng)求信息。
d)、通過(guò)輸出流向客戶端發(fā)送請(qǐng)求信息。
e)、關(guān)閉相關(guān)資源。

二、搭建客戶器端

a)、創(chuàng)建Socket對(duì)象，指明需要連接的服務(wù)器的地址和端口。
b)、建立連接后，通過(guò)輸出流向服務(wù)器發(fā)送請(qǐng)求信息。
c)、通過(guò)輸入流獲取服務(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("請(qǐng)關(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)的客戶端保存下來(lái)
? ? ? ? ? ? ? ? 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部分的代碼，其他客戶端無(wú)法連接
? ? ? ? ? ? /**
? ? ? ? ? ? ?* 解決方法： 1.異步解決方法：一直監(jiān)聽(tīng)接收，其他在另外的地方執(zhí)行 2.使用單獨(dú)的線程： 線程：接受客戶端連接
? ? ? ? ? ? ?* 另外的單獨(dú)的線程：處理通訊
? ? ? ? ? ? ?*/

? ? ? ? }

? ? ? ? public void sendString(String str) {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? dos.writeUTF(str);
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? clients.remove(this);
? ? ? ? ? ? ? ? System.out.println("對(duì)方退出了?。?！我從List中去掉了?。?！");
? ? ? ? ? ? }
? ? ? ? }

? ? ? ? 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)聽(tīng)
? ? ? ? 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)聽(tīng)
? ? private class TFListener implements ActionListener {
? ? ? ? // 敲擊回車(chē)時(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();
? ? ? ? }
? ? }

? ? // 斷開(kāi)連接
? ? 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();
? ? ? ? ? ? }

? ? ? ? }

? ? }

}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: