温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

怎么用Java Socket实现聊天室

发布时间:2021-10-18 14:29:06 来源:亿速云 阅读:230 作者:iii 栏目:开发技术

这篇文章主要介绍“怎么用Java Socket实现聊天室”,在日常操作中,相信很多人在怎么用Java Socket实现聊天室问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”怎么用Java Socket实现聊天室”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

项目需求分析

需要完成一个简单聊天工具的界面及功能,实现服务器中转下的多客户端之间的通信,系统完成的功能有

  • 程序启动后能看到当前有那些机器上线,可弹出对话聊天框,可以在其中编辑要发送的聊天信息,并进行发送

  • 一旦某个网内的机器上线了,可即时通知,并能更新用户界面的用户列表

  • 双击某个列表项时,可弹出对话聊天框,可以在其中编辑要发送的信息并发送

  • 聊天界面人性化,下面时发送框,上面有已有聊天记录,并借助滚动条看到当次所有聊天记录

  • 当有人向本机器发送消息时,可显示用户接收到的信息,并且显示是谁所发,同时进行信息的回复

基础分析

首先这是一个聊天工具,使用的是C/S结构,要模拟就要使用net的Scocket和ServerSocket模拟客户端和服务端

这里综合运用了多种知识,已经不再是简单的java SE知识,其中界面编程占据主要代码,这里可以贴几张图看看效果,这是我肝了2天才肝完的,这里已经可以实现多态设备的连接

分为3个包

Sever包主要是服务器的相关代码,主要是实现与用户的交互

Dao包是模拟的数据库包,存储所有的用户信息,实现增删改的操作

Client是客户代码包,只要在电脑上运行这里的代码,就可以出现客户端界面,约定好ip和端口号就可以通信了。这里就真正实现了客户端型软件,只是软件功能简单,可以使用web编程实现另外一种架构
可以来看一下界面

怎么用Java Socket实现聊天室

再来看一下客户端和服务端的交流

怎么用Java Socket实现聊天室

项目部分代码摘要

Dao的链表存储实现
package Dao;

/**
 * 演示程序为了简化就不用数据库存储,使用单链表完成数据库各项功能
 * 这里一定要写测试代码检查各项功能是否可用
 * 最开开始我测试了add,del,find功能,却没有测试getCount功能,结果存在问题,后面突然放开测试才发现错误
 */
public class UserLinkList {
	private  Node head;
	private int count;

	public boolean addUser(Node client)
	{
		if(head == null)
		{//头节点也存储数据
			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没有包含最后一个结点
		{
			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)
	{//删除后长度也要减少
		Node p = head;
		if(p.username.equals(client.username))
		{//删除头结点
			head = head.next;
			count--;
			return true;
		}
		while(p != null)
		{//忘记循环了
			if(p.next.username.equals(client.username))
			{
				p.next = p.next.next;
				count--;
				return true;
			}
			p = p.next;
		}
		return false;
	}
	
	/**
	 * 这里可以设置一个显示的方法,供检查使用
	 */
	public void display() {
		Node p = head;
		int pos = 1;
		while(p != null)
		{
			System.out.println("第"+pos + "个用户"+p.username);
			p = p.next;
			pos++;
		}
	}
}
/*	
	public static void main(String[] args) {//经过测试发现没有问题,可以正常使用
		Node client1 = new Node();
		client1.username = "张三";
		Node client2 = new Node();
		client2.username = "李四";
		Node client3 = new Node();
		client3.username = "王五";
		//其他的就不测试了,反正该项就可以测试了
		UserLinkList userLinkList = new UserLinkList();//自动初始化
		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());
	}
*/

现在编写这段代码应当是非常简单的,注意一定要测试

ServerListen

简单看一下这个监听线程,可以监听用户是否上线

package Server;
/**
 * @author OMEY-PC
 *本程序的作用是实现服务器侦听的线程化,其中run方法通过client = new Node();创建一个客户端对象,通过client.socket = server.accept来设定接口,通过client.input
 *output来建立输入输出流
 */

import java.io.*;
import java.net.*;
import Dao.*; //连接数据
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;
	/**
	 * 聊天服务端的用户上下线侦听类
	 */
	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())//没有停止服务
		{
			try {
				client = new Node();
				client.socket = server.accept();//用来指代所连接的客户端
				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();//启动线程
			}catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
}
ServerReceive

该线程实现服务器与用户之间的信息交互

package Server;
/**
 * @author OMEY-PC
 *服务器收发消息的类
 */

import java.net.ServerSocket;

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

public class ServerReceive extends Thread{
	JTextArea textarea;//消息展示域
	JTextField textfield;//文本输入域
	JComboBox combobox; //复选框
	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()
	{
		//向所有人发送用户的列表
		sendUserList();
		while(!isStop && !client.socket.isClosed())
		{
			try {//类型,对谁,状况,行为,信息
				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 + "对"+ toSomebody +" 说 " + message + "\n";//接收的消息
					if(status.equalsIgnoreCase("悄悄话"))
					{
						msg = "[悄悄话]" + msg; //若为悄悄话,就在前面加上标识
					}
					textarea.append(msg);
					if(toSomebody.equalsIgnoreCase("所有人"))
					{
						sendToAll(msg);//这里是接受的用户消息,和之前的向所有人发消息不一样
					}
					else {//向用户发消息
						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);//向选定信息发送信息
							node.output.flush();//刷新输出流缓冲区中的信息
						}
					}
			    }
				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);//选择第一个,所有人
					textarea.append(msg);
					textfield.setText("在线用户"+ userLinkList.getCount() +"人\n");
					
					sendToAll(msg);
					sendUserList();//重新发送用户列表
					break;
				}
		    }catch (Exception e) {
				e.printStackTrace();
			}
	    }
	}
	/**
	 * 向所有人发送消息
	 */
	public void sendToAll(String msg)
	{
		int count = userLinkList.getCount();
		int i = 0;
		while(i < count)
		{//给用户列表中的每一个人都发送消息
			Node node = userLinkList.findUser(i);
			if(node == null)
			{
				i++;
				continue;
			}
			try {//输出流
				node.output.writeObject("聊天信息");
				node.output.flush();
				node.output.writeObject(msg);//聊天消息写入输出流(to client)
				node.output.flush();
			}catch (Exception e) {
				e.printStackTrace();
			}
			i++;
		}
	}
	/**
	 * 向所有人发送用户列表
	 */
	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; //给每个人发送消息
		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++;
	}	
}
/**
 * 本程序可以实现通过线程向所有人发送消息,用户列表,以及向选定的人发送聊天消息等,主要是是实现服务端收发消息的线程化,其中sendUserList()发送列表,
 * client.input.redObject()获取客户端发送到服务端的消息,通sendToAll(),将发送到发送到所有人的信息发送到各个客户端
 */
再看一下客户端的ClientReceive

该线程是实现客户端与系统之间的信息交互,注解丰富

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() {//从服务端获得消息
		while(!socket.isClosed())
		{
			try {
				String type = (String)input.readObject();//获得流,read读取信息
				if(type.equalsIgnoreCase("系统信息"))
				{
					String sysmsg = (String)input.readObject();
					textarea.append("系统信息" + sysmsg);
				}
				else if(type.equalsIgnoreCase("服务关闭"))
				{
					output.close();
					input.close();
					socket.close();
					textarea.append("服务器已经关闭!\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();
			}
		}
	}
}

其余的界面的部分就不放出来了,代码太长,每个都有400多行,如果有兴趣,就到我的gitee上去浏览,后面会放上地址

项目问题

选择框中出现的不是用户名

查找相应模块发现是因为addItem中添加的时结点,而不是结点中的username,修改后正常

服务端点击消息发送按钮没有反应

查找监听器部分,发现监听器监听该部分代码写错,将button又写成sysMessage

不能显示在线人数

查找侦听线程,启动客户端发现抛出异常

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

textfield为空,查找问题源头;发现在构造方法中:the assignmen to variable has no effect;这是因为单词拼写错误,编译器并没有报错

服务端退出时没有消息

系统报错

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

意识到问题出在链表上,系统要求从0开始,而链表中的序号是从1开始的,修该链表中的findUser中的pos为0就解决

到此,关于“怎么用Java Socket实现聊天室”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注亿速云网站,小编会继续努力为大家带来更多实用的文章!

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI