回城传送–》《JAVA筑基100例》

文章目录

  • 零、前言
  • 一、题目描述
  • 二、解题思路
  • 三、代码详解
  • 四、推荐专栏
  • 五、示例源码下载

零、前言

​ 今天是学习 JAVA语言 打卡的第100天,每天我会提供一篇文章供群成员阅读( 不需要订阅付钱 ),读完文章之后,按解题思路,自己再实现一遍。在小虚竹JAVA社区 中对应的 【打卡贴】打卡,今天的任务就算完成了。

​ 因为大家都在一起学习同一篇文章,所以有什么问题都可以在群里问,群里的小伙伴可以迅速地帮到你,一个人可以走得很快,一群人可以走得很远,有一起学习交流的战友,是多么幸运的事情。

​ 学完后,自己写篇学习报告的博客,可以发布到小虚竹JAVA社区 ,供学弟学妹们参考。

​ 我的学习策略很简单,题海策略+ 费曼学习法。如果能把这100题都认认真真自己实现一遍,那意味着 JAVA语言 已经筑基成功了。后面的进阶学习,可以继续跟着我,一起走向架构师之路。

一、题目描述

题目实现:实现聊天室客户端。运行程序,用户登录服务器后,可以从用户列表中选择单个用户进行聊天,也可以选择多个用户进行聊天。

二、解题思路

创建一个服务类:ChatClientFrame,继承JFrame类。用于进行用户登录、发送聊天信息和显示聊天信息,在该类中完成窗体界面的设计。

定义createClientSocket)方法,用于创建套接字对象、输出流对象以及启动线程对象对服务器转发的信息进行处理。

定义内部线程类ClientThread,用于对服务器端转发的信息进行处理,并显示在相应的控件中。

定义发送聊天信息的send()方法。

技术重点:

通过线程对接收到的信息进行处理,其中分为3种情况,第一种接收到的是登录用户,第二种接收到的是退出提示,第三种接收到的是消息。

使用maven-assembly-plugin插件,把引用的第三方jar包打到项目的jar包中。

启动上一题的服务端,运行服务端

启动多个客户端:

java -jar basics100-1.0-SNAPSHOT.jar

三、代码详解

引入hutool的pom,和使用maven-assembly-plugin插件

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.xiaoxuzhu</groupId><artifactId>basics100</artifactId><version>1.0-SNAPSHOT</version><dependencies><dependency><groupId>cn.hutool</groupId><artifactId>hutool-core</artifactId><version>5.6.5</version></dependency></dependencies><build><plugins><plugin><artifactId>maven-assembly-plugin</artifactId><configuration><archive><manifest><mainClass>com.xiaoxuzhu.ChatClientFrame</mainClass></manifest><manifestEntries><Class-Path>.</Class-Path></manifestEntries></archive><descriptorRefs><descriptorRef>jar-with-dependencies</descriptorRef></descriptorRefs><appendAssemblyId>false</appendAssemblyId></configuration><executions><execution><id>make-assembly</id> <phase>package</phase> <goals><goal>single</goal></goals></execution></executions></plugin></plugins></build></project>

ChatClientFrame

package com.xiaoxuzhu;import cn.hutool.core.io.resource.ResourceUtil;import java.awt.*;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.awt.event.MouseAdapter;import java.awt.event.MouseEvent;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.ObjectOutputStream;import java.net.Socket;import java.net.URL;import java.net.UnknownHostException;import java.text.DateFormat;import java.util.Date;import java.util.Vector;import javax.swing.*;/** * Description:* * @author xiaoxuzhu * @version 1.0 * * 
 * 修改记录: * 修改后版本修改人修改日期修改内容 * 2022/6/6.1xiaoxuzhu2022/6/6Create * 

* @date 2022/6/6 */public class ChatClientFrame extends JFrame {private JTextField tf_newUser;private JList user_list;private JTextArea ta_info;private JTextField tf_send;private ObjectOutputStream out;// 声明输出流对象private Socket socket;private boolean loginFlag = false;// 为true时表示已经登录,为false时表示未登录public static void main(String args[]) {System.out.println(SwingUtilities.isEventDispatchThread());EventQueue.invokeLater(new Runnable() {public void run() {System.out.println(SwingUtilities.isEventDispatchThread());try {ChatClientFrame frame = new ChatClientFrame();frame.setVisible(true);frame.createClientSocket();// 调用方法创建套接字对象} catch (Exception e) {e.printStackTrace();}}});}public void createClientSocket() {try { socket = new Socket("127.0.0.1", 9527);// 创建套接字对象out = new ObjectOutputStream(socket.getOutputStream());// 创建输出流对象SwingWorker<Void,Void> worker=new SwingWorker<Void, Void>() {@Overrideprotected Void doInBackground() throws Exception {try {System.out.println(SwingUtilities.isEventDispatchThread());BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));// 创建输入流对象DefaultComboBoxModel model = (DefaultComboBoxModel) user_list.getModel();// 获得列表框的模型while (true) {String info = in.readLine().trim();// 读取信息if (!info.startsWith("MSG:")) {// 接收到的不是消息if (info.startsWith("退出:")) {// 接收到的是退出消息model.removeElement(info.substring(3));// 从用户列表中移除用户} else {// 接收到的是登录用户boolean itemFlag = false;// 标记是否为列表框添加列表项,为true不添加,为false添加for (int i = 0; i < model.getSize(); i++) {// 对用户列表进行遍历if (info.equals((String) model.getElementAt(i))) {// 如果用户列表中存在该用户名itemFlag = true;// 设置为true,表示不添加到用户列表break;// 结束for循环}}if (!itemFlag) {model.addElement(info);// 将登录用户添加到用户列表}}} else {// 如果获得的是消息,则在文本域中显示接收到的消息DateFormat df = DateFormat.getDateInstance();// 获得DateFormat实例String dateString = df.format(new Date()); // 格式化为日期df = DateFormat.getTimeInstance(DateFormat.MEDIUM);// 获得DateFormat实例String timeString = df.format(new Date()); // 格式化为时间String sendUser = info.substring(4,info.indexOf(":发送给:"));// 获得发送信息的用户String receiveInfo = info.substring(info.indexOf(":的信息是:")+6);// 获得接收到的信息ta_info.append(""+sendUser + "" +dateString+""+timeString+"\n"+receiveInfo+"\n");// 在文本域中显示信息ta_info.setSelectionStart(ta_info.getText().length()-1);// 设置选择起始位置ta_info.setSelectionEnd(ta_info.getText().length());// 设置选择的结束位置tf_send.requestFocus();// 使发送信息文本框获得焦点}}} catch (IOException e) {e.printStackTrace();}return null;}};worker.execute();//new ClientThread(socket).start();// 创建并启动线程对象} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}class ClientThread extends Thread {Socket socket;public ClientThread(Socket socket) {this.socket = socket;}public void run() { }}private void send() {if (!loginFlag) {JOptionPane.showMessageDialog(null, "请先登录。");return;// 如果用户没登录则返回}String sendUserName = tf_newUser.getText().trim();// 获得登录用户名String info = tf_send.getText();// 获得输入的发送信息if (info.equals("")) {return;// 如果没输入信息则返回,即不发送}Vector<String> v = new Vector<String>();// 创建向量对象,用于存储发送的消息Object[] receiveUserNames = user_list.getSelectedValues();// 获得选择的用户数组if (receiveUserNames.length <= 0) {return;// 如果没选择用户则返回}for (int i = 0; i < receiveUserNames.length; i++) {String msg = sendUserName + ":发送给:" + (String) receiveUserNames[i]+ ":的信息是: " + info;// 定义发送的信息v.add(msg);// 将信息添加到向量}try {out.writeObject(v);// 将向量写入输出流,完成信息的发送out.flush();// 刷新输出缓冲区} catch (IOException e) {e.printStackTrace();}DateFormat df = DateFormat.getDateInstance();// 获得DateFormat实例String dateString = df.format(new Date()); // 格式化为日期df = DateFormat.getTimeInstance(DateFormat.MEDIUM);// 获得DateFormat实例String timeString = df.format(new Date()); // 格式化为时间String sendUser = tf_newUser.getText().trim();// 获得发送信息的用户String receiveInfo = tf_send.getText().trim();// 显示发送的信息ta_info.append(""+sendUser + "" +dateString+""+timeString+"\n"+receiveInfo+"\n");// 在文本域中显示信息tf_send.setText(null);// 清空文本框ta_info.setSelectionStart(ta_info.getText().length()-1);// 设置选择的起始位置ta_info.setSelectionEnd(ta_info.getText().length());// 设置选择的结束位置tf_send.requestFocus();// 使发送信息文本框获得焦点}/** * Create the frame */public ChatClientFrame() {super();setTitle("聊天室客户端");setBounds(100, 100, 385, 288);final JPanel panel = new JPanel();getContentPane().add(panel, BorderLayout.SOUTH);final JLabel label = new JLabel();label.setText("输入聊天内容:");panel.add(label);tf_send = new JTextField();tf_send.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {send();// 调用方法发送信息}});tf_send.setPreferredSize(new Dimension(180, 25));panel.add(tf_send);final JButton button = new JButton();button.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {send();// 调用方法发送信息}});button.setText("发送");panel.add(button);final JSplitPane splitPane = new JSplitPane();splitPane.setDividerLocation(100);getContentPane().add(splitPane, BorderLayout.CENTER);final JScrollPane scrollPane = new JScrollPane();splitPane.setRightComponent(scrollPane);ta_info = new JTextArea();ta_info.setFont(new Font("", Font.BOLD, 14));scrollPane.setViewportView(ta_info);final JScrollPane scrollPane_1 = new JScrollPane();splitPane.setLeftComponent(scrollPane_1);user_list = new JList();user_list.setModel(new DefaultComboBoxModel(new String[] { "" }));scrollPane_1.setViewportView(user_list);final JPanel panel_1 = new JPanel();getContentPane().add(panel_1, BorderLayout.NORTH);final JLabel label_1 = new JLabel();label_1.setText("用户名称:");panel_1.add(label_1);tf_newUser = new JTextField();tf_newUser.setPreferredSize(new Dimension(140, 25));panel_1.add(tf_newUser);final JButton button_1 = new JButton();button_1.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {if (loginFlag) {// 已登录标记为trueJOptionPane.showMessageDialog(null, "在同一窗口只能登录一次。");return;}String userName = tf_newUser.getText().trim();// 获得登录用户名Vector v = new Vector();// 定义向量,用于存储登录用户v.add("用户:" + userName);// 添加登录用户try {out.writeObject(v);// 将用户向量发送到服务器out.flush();// 刷新输出缓冲区} catch (IOException ex) {ex.printStackTrace();}tf_newUser.setEnabled(false);// 禁用用户文本框loginFlag = true;// 将已登录标记设置为true}});button_1.setText("登录");panel_1.add(button_1);final JButton button_2 = new JButton();button_2.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {String exitUser = tf_newUser.getText().trim();Vector v = new Vector();v.add("退出:" + exitUser);try {out.writeObject(v);out.flush();// 刷新输出缓冲区} catch (IOException ex) {ex.printStackTrace();}System.exit(0); // 退出系统}});button_2.setText("退出");panel_1.add(button_2);//托盘if (SystemTray.isSupported()){// 判断是否支持系统托盘URL url= ResourceUtil.getResource("client.png",null); // 获取图片所在的URLImageIcon icon = new ImageIcon(url);// 实例化图像对象Image image=icon.getImage();// 获得Image对象TrayIcon trayIcon=new TrayIcon(image);// 创建托盘图标trayIcon.addMouseListener(new MouseAdapter(){ // 为托盘添加鼠标适配器public void mouseClicked(MouseEvent e){ // 鼠标事件if (e.getClickCount()==2){// 判断是否双击了鼠标showFrame();// 调用方法显示窗体}}});trayIcon.setToolTip("系统托盘");// 添加工具提示文本PopupMenu popupMenu=new PopupMenu();// 创建弹出菜单MenuItem exit=new MenuItem("退出"); // 创建菜单项exit.addActionListener(new ActionListener() { // 添加事件监听器public void actionPerformed(final ActionEvent arg0) {String exitUser = tf_newUser.getText().trim();Vector v = new Vector();v.add("退出:" + exitUser);try {out.writeObject(v);out.flush();// 刷新输出缓冲区} catch (IOException ex) {ex.printStackTrace();}System.exit(0); // 退出系统}});popupMenu.add(exit);// 为弹出菜单添加菜单项trayIcon.setPopupMenu(popupMenu); // 为托盘图标加弹出菜弹SystemTray systemTray=SystemTray.getSystemTray(); // 获得系统托盘对象try{systemTray.add(trayIcon); // 为系统托盘加托盘图标}catch(Exception e){e.printStackTrace();}}}public void showFrame(){this.setVisible(true);// 显示窗体this.setState(Frame.NORMAL);}}

上一题服务端启动:

第一个客户端:小小 启动

第二个客户端:虚虚 启动

第三个客户端:竹竹 启动

小小给竹竹发消息

竹竹回复小小:

小小收到回复:

四、推荐专栏

《JAVA从零到壹》

《JAVA筑基100例》

五、示例源码下载

关注下面的公众号,回复筑基+题目号

筑基100