欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java Socket實(shí)現(xiàn)聊天室附1500行源代碼

 更新時(shí)間:2021年10月18日 11:08:27   作者:碼農(nóng)C風(fēng)  
Socket是應(yīng)用層與TCP/IP協(xié)議族通信的中間軟件抽象層,它是一組接口。本篇文章手把手帶你通過(guò)Java Socket來(lái)實(shí)現(xiàn)自己的聊天室,大家可以在過(guò)程中查缺補(bǔ)漏,溫故而知新

Java養(yǎng)成計(jì)劃(打卡第31,2天)

內(nèi)容管理:Sockect聊天室的實(shí)現(xiàn)

Java界面 使用了各種組件,對(duì)于這部分不了解的不用擔(dān)心,目前掌握一個(gè)大概就OK

項(xiàng)目需求分析

需要完成一個(gè)簡(jiǎn)單聊天工具的界面及功能,實(shí)現(xiàn)服務(wù)器中轉(zhuǎn)下的多客戶端之間的通信,系統(tǒng)完成的功能有

  • 程序啟動(dòng)后能看到當(dāng)前有那些機(jī)器上線,可彈出對(duì)話聊天框,可以在其中編輯要發(fā)送的聊天信息,并進(jìn)行發(fā)送
  • 一旦某個(gè)網(wǎng)內(nèi)的機(jī)器上線了,可即時(shí)通知,并能更新用戶界面的用戶列表
  • 雙擊某個(gè)列表項(xiàng)時(shí),可彈出對(duì)話聊天框,可以在其中編輯要發(fā)送的信息并發(fā)送
  • 聊天界面人性化,下面時(shí)發(fā)送框,上面有已有聊天記錄,并借助滾動(dòng)條看到當(dāng)次所有聊天記錄
  • 當(dāng)有人向本機(jī)器發(fā)送消息時(shí),可顯示用戶接收到的信息,并且顯示是誰(shuí)所發(fā),同時(shí)進(jìn)行信息的回復(fù)

基礎(chǔ)分析

首先這是一個(gè)聊天工具,使用的是C/S結(jié)構(gòu),要模擬就要使用net的Scocket和ServerSocket模擬客戶端和服務(wù)端

這里綜合運(yùn)用了多種知識(shí),已經(jīng)不再是簡(jiǎn)單的java SE知識(shí),其中界面編程占據(jù)主要代碼,這里可以貼幾張圖看看效果,這是我肝了2天才肝完的,這里已經(jīng)可以實(shí)現(xiàn)多態(tài)設(shè)備的連接

分為3個(gè)包

Sever包主要是服務(wù)器的相關(guān)代碼,主要是實(shí)現(xiàn)與用戶的交互

Dao包是模擬的數(shù)據(jù)庫(kù)包,存儲(chǔ)所有的用戶信息,實(shí)現(xiàn)增刪改的操作

Client是客戶代碼包,只要在電腦上運(yùn)行這里的代碼,就可以出現(xiàn)客戶端界面,約定好ip和端口號(hào)就可以通信了。這里就真正實(shí)現(xiàn)了客戶端型軟件,只是軟件功能簡(jiǎn)單,可以使用web編程實(shí)現(xiàn)另外一種架構(gòu)
可以來(lái)看一下界面

在這里插入圖片描述

再來(lái)看一下客戶端和服務(wù)端的交流

在這里插入圖片描述

項(xiàng)目部分代碼摘要

Dao的鏈表存儲(chǔ)實(shí)現(xiàn)

package Dao;

/**
 * 演示程序?yàn)榱撕?jiǎn)化就不用數(shù)據(jù)庫(kù)存儲(chǔ),使用單鏈表完成數(shù)據(jù)庫(kù)各項(xiàng)功能
 * 這里一定要寫(xiě)測(cè)試代碼檢查各項(xiàng)功能是否可用
 * 最開(kāi)開(kāi)始我測(cè)試了add,del,find功能,卻沒(méi)有測(cè)試getCount功能,結(jié)果存在問(wèn)題,后面突然放開(kāi)測(cè)試才發(fā)現(xiàn)錯(cuò)誤
 */
public class UserLinkList {
	private  Node head;
	private int count;

	public boolean addUser(Node client)
	{
		if(head == null)
		{//頭節(jié)點(diǎn)也存儲(chǔ)數(shù)據(jù)
			head = client;
			count++;
			return true;
		}
		else {
			Node p = head;
			for(;p.next != null;p = p.next);
			{
				p.next = client;
				count++;
				return true;
			}
		}
	}
	
	public int getCount() {
		return count;
	}
	
	public Node findUser(String name)
	{
		Node p = head;
		while(p != null )//p.next != null沒(méi)有包含最后一個(gè)結(jié)點(diǎn)
		{
			if(p.username.equals(name))
			{
				return p;
			}
			p = p.next;
		}
		return null;
	}
	
	public Node findUser(int index)
	{
		int pos = 0;
		Node p = head;
		while(p != null&& pos < index)
		{
			p = p.next;
			pos++;
		}
		if(p != null&& pos == index)
		{
			return p;
		}
		return null;
	}
	
	public boolean delUser(Node client)
	{//刪除后長(zhǎng)度也要減少
		Node p = head;
		if(p.username.equals(client.username))
		{//刪除頭結(jié)點(diǎn)
			head = head.next;
			count--;
			return true;
		}
		while(p != null)
		{//忘記循環(huán)了
			if(p.next.username.equals(client.username))
			{
				p.next = p.next.next;
				count--;
				return true;
			}
			p = p.next;
		}
		return false;
	}
	
	/**
	 * 這里可以設(shè)置一個(gè)顯示的方法,供檢查使用
	 */
	public void display() {
		Node p = head;
		int pos = 1;
		while(p != null)
		{
			System.out.println("第"+pos + "個(gè)用戶"+p.username);
			p = p.next;
			pos++;
		}
	}
}
/*	
	public static void main(String[] args) {//經(jīng)過(guò)測(cè)試發(fā)現(xiàn)沒(méi)有問(wèn)題,可以正常使用
		Node client1 = new Node();
		client1.username = "張三";
		Node client2 = new Node();
		client2.username = "李四";
		Node client3 = new Node();
		client3.username = "王五";
		//其他的就不測(cè)試了,反正該項(xiàng)就可以測(cè)試了
		UserLinkList userLinkList = new UserLinkList();//自動(dòng)初始化
		userLinkList.addUser(client1);
		userLinkList.addUser(client2);
		userLinkList.addUser(client3);
//		userLinkList.display();
		Node node = userLinkList.findUser(0);
		userLinkList.delUser(node);
		userLinkList.display();
		System.out.println(userLinkList.getCount());
	}
*/

現(xiàn)在編寫(xiě)這段代碼應(yīng)當(dāng)是非常簡(jiǎn)單的,注意一定要測(cè)試

ServerListen

簡(jiǎn)單看一下這個(gè)監(jiān)聽(tīng)線程,可以監(jiān)聽(tīng)用戶是否上線

package Server;
/**
 * @author OMEY-PC
 *本程序的作用是實(shí)現(xiàn)服務(wù)器偵聽(tīng)的線程化,其中run方法通過(guò)client = new Node();創(chuàng)建一個(gè)客戶端對(duì)象,通過(guò)client.socket = server.accept來(lái)設(shè)定接口,通過(guò)client.input
 *output來(lái)建立輸入輸出流
 */

import java.io.*;
import java.net.*;
import Dao.*; //連接數(shù)據(jù)
import javax.swing.*;

public class ServerListen extends Thread{
	ServerSocket server;
	JComboBox combobox;
	JTextArea textarea;
	JTextField textfield;
	UserLinkList userLinkList;
	Node client;
	ServerReceive recvThread;
	public boolean isStop;
	/**
	 * 聊天服務(wù)端的用戶上下線偵聽(tīng)類(lèi)
	 */
	public ServerListen(ServerSocket server,JComboBox combobox,JTextArea textarea,JTextField textField,UserLinkList userLinkList) {
		this.server = server;
		this.combobox = combobox;
		this.textarea = textarea;
		this.textfield = textField;
		this.userLinkList = userLinkList;
		isStop = false;
	}
	@Override
	public void run() {
		while(!isStop && !server.isClosed())//沒(méi)有停止服務(wù)
		{
			try {
				client = new Node();
				client.socket = server.accept();//用來(lái)指代所連接的客戶端
				client.output = new ObjectOutputStream(client.socket.getOutputStream());
				client.output.flush();
				client.input = new ObjectInputStream(client.socket.getInputStream());
				client.username = (String)client.input.readObject();
				//顯示提示信息
			    combobox.addItem(client.username);//改成用戶名
			    userLinkList.addUser(client);
			    textarea.append("用戶" + client.username+"上線"+"\n");
			    textfield.setText("在線用戶"+ userLinkList.getCount()+"人\n");
			    
			    recvThread = new ServerReceive(textarea,textfield,combobox,client,userLinkList);
			    recvThread.start();//啟動(dòng)線程
			}catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
}

ServerReceive

該線程實(shí)現(xiàn)服務(wù)器與用戶之間的信息交互

package Server;
/**
 * @author OMEY-PC
 *服務(wù)器收發(fā)消息的類(lèi)
 */

import java.net.ServerSocket;

import javax.swing.*;
import Dao.*;

public class ServerReceive extends Thread{
	JTextArea textarea;//消息展示域
	JTextField textfield;//文本輸入域
	JComboBox combobox; //復(fù)選框
	Node client;//用戶
	UserLinkList userLinkList;
	public boolean isStop;
	public ServerReceive(JTextArea textarea, JTextField textfield, JComboBox combobox, Node client,
			UserLinkList userLinkList) {
		this.textarea = textarea;
		this.textfield = textfield;
		this.combobox = combobox;
		this.client = client;
		this.userLinkList = userLinkList;
		isStop = false;
	}
	
	@Override
	public void run()
	{
		//向所有人發(fā)送用戶的列表
		sendUserList();
		while(!isStop && !client.socket.isClosed())
		{
			try {//類(lèi)型,對(duì)誰(shuí),狀況,行為,信息
				String type = (String)client.input.readObject();
				if(type.equalsIgnoreCase("聊天信息"))
				{
					String toSomebody =(String)client.input.readObject();//從客戶端接收信息
					String status = (String)client.input.readObject();
					String action = (String)client.input.readObject();
					String message = (String)client.input.readObject();
					String msg = client.username+" "+ action + "對(duì)"+ toSomebody +" 說(shuō) " + message + "\n";//接收的消息
					if(status.equalsIgnoreCase("悄悄話"))
					{
						msg = "[悄悄話]" + msg; //若為悄悄話,就在前面加上標(biāo)識(shí)
					}
					textarea.append(msg);
					if(toSomebody.equalsIgnoreCase("所有人"))
					{
						sendToAll(msg);//這里是接受的用戶消息,和之前的向所有人發(fā)消息不一樣
					}
					else {//向用戶發(fā)消息
						try {
							client.output.writeObject("聊天信息");
							client.output.flush();//刷新流
							client.output.writeObject(msg);
							client.output.flush();
						}catch (Exception e) {
							e.printStackTrace();
						}
						Node node = userLinkList.findUser(toSomebody);
						if(node != null)
						{
							node.output.writeObject("聊天信息");
							node.output.flush();
							node.output.writeObject(msg);//向選定信息發(fā)送信息
							node.output.flush();//刷新輸出流緩沖區(qū)中的信息
						}
					}
			    }
				else if(type.equalsIgnoreCase("用戶下線"))
				{
					Node node = userLinkList.findUser(client.username);
					userLinkList.delUser(node);
					String msg = "用戶"+ client.username +"下線\n";
					int count = userLinkList.getCount();
					combobox.removeAllItems();
					combobox.addItem("所有人");
					int i = 0;
				    while(i < count)
				    {
				    	node = userLinkList.findUser(i);
				    	if(node == null)
				    	{
				    		i++;
				    		continue;
				    	}
				    	combobox.addItem(node.username);
				    	i++;
				    }
					combobox.setSelectedIndex(0);//選擇第一個(gè),所有人
					textarea.append(msg);
					textfield.setText("在線用戶"+ userLinkList.getCount() +"人\n");
					
					sendToAll(msg);
					sendUserList();//重新發(fā)送用戶列表
					break;
				}
		    }catch (Exception e) {
				e.printStackTrace();
			}
	    }
	}
	/**
	 * 向所有人發(fā)送消息
	 */
	public void sendToAll(String msg)
	{
		int count = userLinkList.getCount();
		int i = 0;
		while(i < count)
		{//給用戶列表中的每一個(gè)人都發(fā)送消息
			Node node = userLinkList.findUser(i);
			if(node == null)
			{
				i++;
				continue;
			}
			try {//輸出流
				node.output.writeObject("聊天信息");
				node.output.flush();
				node.output.writeObject(msg);//聊天消息寫(xiě)入輸出流(to client)
				node.output.flush();
			}catch (Exception e) {
				e.printStackTrace();
			}
			i++;
		}
	}
	/**
	 * 向所有人發(fā)送用戶列表
	 */
	public void sendUserList() {
		String userList = "";
		int count = userLinkList.getCount();
		int i = 0;
		while(i < count)
		{
			Node node = userLinkList.findUser(i);
			if(node == null)
			{
				i++;
				continue;
			}
			userList += node.username;
			userList += "\n";
			i++;
		}
		i = 0; //給每個(gè)人發(fā)送消息
		while(i < count)
		{
			Node node = userLinkList.findUser(i);
			if(node == null)
			{
				i++;
				continue;
			}
			try {
				node.output.writeObject("用戶列表");
				node.output.flush();
				node.output.writeObject(userList);
				node.output.flush();
			}catch (Exception e) {
				e.printStackTrace();
			}
		}
		i++;
	}	
}
/**
 * 本程序可以實(shí)現(xiàn)通過(guò)線程向所有人發(fā)送消息,用戶列表,以及向選定的人發(fā)送聊天消息等,主要是是實(shí)現(xiàn)服務(wù)端收發(fā)消息的線程化,其中sendUserList()發(fā)送列表,
 * client.input.redObject()獲取客戶端發(fā)送到服務(wù)端的消息,通sendToAll(),將發(fā)送到發(fā)送到所有人的信息發(fā)送到各個(gè)客戶端
 */

再看一下客戶端的ClientReceive

該線程是實(shí)現(xiàn)客戶端與系統(tǒng)之間的信息交互,注解豐富

package Client;

import java.io.*;
import java.net.*;

import javax.swing.*;

public class ClientReceive extends Thread{
	private JComboBox combobox;
	private JTextArea textarea;
	Socket socket;
	ObjectOutputStream output;
	ObjectInputStream input;
	JTextField showStatus;
	public ClientReceive(JComboBox combobox, JTextArea textarea, Socket socket, ObjectOutputStream output,
			ObjectInputStream input, JTextField showStatus) {
		this.combobox = combobox;
		this.textarea = textarea;
		this.socket = socket;
		this.output = output;
		this.input = input;
		this.showStatus = showStatus;
	}
	
	@Override
	public void run() {//從服務(wù)端獲得消息
		while(!socket.isClosed())
		{
			try {
				String type = (String)input.readObject();//獲得流,read讀取信息
				if(type.equalsIgnoreCase("系統(tǒng)信息"))
				{
					String sysmsg = (String)input.readObject();
					textarea.append("系統(tǒng)信息" + sysmsg);
				}
				else if(type.equalsIgnoreCase("服務(wù)關(guān)閉"))
				{
					output.close();
					input.close();
					socket.close();
					textarea.append("服務(wù)器已經(jīng)關(guān)閉!\n");
					break;
				}
				else if(type.equalsIgnoreCase("聊天信息"))
				{
					String message = (String)input.readObject();
					textarea.append(message);
				}
				else if(type.equalsIgnoreCase("用戶列表"))
				{
					String userlist = (String)input.readObject();
					String[] usernames = userlist.split("\n"); //用換行符分隔
					combobox.removeAll();//先移出去
					int i = 0;
					combobox.addItem("所有人");
					while(i < usernames.length)
					{
						combobox.addItem(usernames[i]);
						i++;
					}
					combobox.setSelectedIndex(0);
					showStatus.setText("在線用戶"+ usernames.length +" 人");
				}
			}catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
}

其余的界面的部分就不放出來(lái)了,代碼太長(zhǎng),每個(gè)都有400多行,如果有興趣,就到我的gitee上去瀏覽,后面會(huì)放上地址

項(xiàng)目問(wèn)題

選擇框中出現(xiàn)的不是用戶名

查找相應(yīng)模塊發(fā)現(xiàn)是因?yàn)閍ddItem中添加的時(shí)結(jié)點(diǎn),而不是結(jié)點(diǎn)中的username,修改后正常

服務(wù)端點(diǎn)擊消息發(fā)送按鈕沒(méi)有反應(yīng)

查找監(jiān)聽(tīng)器部分,發(fā)現(xiàn)監(jiān)聽(tīng)器監(jiān)聽(tīng)該部分代碼寫(xiě)錯(cuò),將button又寫(xiě)成sysMessage

不能顯示在線人數(shù)

查找偵聽(tīng)線程,啟動(dòng)客戶端發(fā)現(xiàn)拋出異常

Cannot invoke “javax.swing.JTextField.setText(String)” because “this.textfield” is null

textfield為空,查找問(wèn)題源頭;發(fā)現(xiàn)在構(gòu)造方法中:the assignmen to variable has no effect;這是因?yàn)閱卧~拼寫(xiě)錯(cuò)誤,編譯器并沒(méi)有報(bào)錯(cuò)

服務(wù)端退出時(shí)沒(méi)有消息

系統(tǒng)報(bào)錯(cuò)

Cannot read field “input” because “node” is null

意識(shí)到問(wèn)題出在鏈表上,系統(tǒng)要求從0開(kāi)始,而鏈表中的序號(hào)是從1開(kāi)始的,修該鏈表中的findUser中的pos為0就解決

寫(xiě)這個(gè)程序?qū)懥藘商欤苯訌U了~~

到此這篇關(guān)于Java Socket實(shí)現(xiàn)聊天室附1500行源代碼的文章就介紹到這了,更多相關(guān)Java Socket內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • MyBatis 實(shí)現(xiàn)數(shù)據(jù)的批量新增和刪除的操作

    MyBatis 實(shí)現(xiàn)數(shù)據(jù)的批量新增和刪除的操作

    這篇文章主要介紹了MyBatis 實(shí)現(xiàn)數(shù)據(jù)的批量新增和刪除的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2021-02-02
  • Java常用加密算法實(shí)例總結(jié)

    Java常用加密算法實(shí)例總結(jié)

    這篇文章主要介紹了Java常用加密算法,結(jié)合實(shí)例形式總結(jié)分析了base64、md5、sha、rsa、des等加密算法實(shí)現(xiàn)技巧,需要的朋友可以參考下
    2017-10-10
  • jstack報(bào)錯(cuò)Unable to open socket file解決

    jstack報(bào)錯(cuò)Unable to open socket file解決

    這篇文章主要為大家介紹了jstack報(bào)錯(cuò)Unable to open socket file的解決方法詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2024-02-02
  • SpringBoot整合WebSocket實(shí)現(xiàn)后端向前端主動(dòng)推送消息方式

    SpringBoot整合WebSocket實(shí)現(xiàn)后端向前端主動(dòng)推送消息方式

    這篇文章主要介紹了SpringBoot整合WebSocket實(shí)現(xiàn)后端向前端主動(dòng)推送消息方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-10-10
  • 為什么Java中只有值傳遞

    為什么Java中只有值傳遞

    這篇文章主要介紹了為什么Java中只有值傳遞,幫助大家更好的理解和使用Java,感興趣的朋友可以了解下
    2021-01-01
  • JWT Token實(shí)現(xiàn)方法及步驟詳解

    JWT Token實(shí)現(xiàn)方法及步驟詳解

    這篇文章主要介紹了JWT Token實(shí)現(xiàn)方法及步驟詳解,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-09-09
  • Java中Stream流Map分組方式詳細(xì)匯總

    Java中Stream流Map分組方式詳細(xì)匯總

    Stream將要處理的元素集合看作一種流,在流的過(guò)程中借助Stream?API對(duì)流中的元素進(jìn)行操作,比如篩選、排序、聚合等,下面這篇文章主要給大家介紹了關(guān)于Java中Stream流Map分組方式的相關(guān)資料,需要的朋友可以參考下
    2024-01-01
  • java實(shí)現(xiàn)日歷窗口小程序

    java實(shí)現(xiàn)日歷窗口小程序

    這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)日歷窗口小程序,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2022-06-06
  • Eclipse IDE可支持Java 14編程

    Eclipse IDE可支持Java 14編程

    這篇文章主要介紹了Eclipse IDE可支持Java 14編程,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2020-04-04
  • 淺談SpringBoot @Autowired的兩種注入方式

    淺談SpringBoot @Autowired的兩種注入方式

    本文主要介紹了兩種SpringBoot @Autowired注入方式,具有一定的參考價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2021-06-06

最新評(píng)論