Java聊天室之实现接收和发送Socket

一、题目描述

题目实现：网络通信，实现信息的发送和接收。

二、解题思路

创建一个服务器类：ServerSocketFrame，继承JFrame类

写一个getserver() 方法，实例化Socket对象，启用9527当服务的端口。

创建输入流对象，用来接收客户端信息。

再定义一个getClientInfo()方法，用于接收客户端发送的信息。

创建一个客户端类：ClientSocketFrame，继承JFrame类。

写一个connect() 方法，实例化Socket对象，连接本地服务的9527端口服务。

技术重点：

通过Socket类的getInpuStream()方法来获得输入流对象，使用getOutputStream()方法获得输出流对象实现。

三、代码详解

ServerSocketFrame

package com.xiaoxuzhu;
import java.awt.BorderLayout;
import java.io.*;
import java.net.*;
import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;

/**
* Description:
*
* @author xiaoxuzhu
* @version 1.0
*
* <pre>
* 修改记录:
* 修改后版本        修改人修改日期修改内容
* 2022/6/4.1    xiaoxuzhu2022/6/4    Create
* </pre>
* @date 2022/6/4
*/

public class ServerSocketFrame extends JFrame {
   private JTextArea ta_info;// 声明文本域,用于显示连接信息和接收到的信息
   private BufferedReader reader; // 声明BufferedReader对象
   private ServerSocket server; // 声明ServerSocket对象
   private Socket socket; // 声明Socket对象socket

public void getServer() {
       try {
           server = new ServerSocket(9527); // 实例化Socket对象
           ta_info.append("服务器套接字已经创建成功\n"); // 输出信息
           while (true) { // 如果套接字是连接状态
               ta_info.append("等待客户机的连接......\n"); // 输出信息
               socket = server.accept(); // 实例化Socket对象
               ta_info.append("连接成功。\n"); // 输出信息
               reader = new BufferedReader(new InputStreamReader(socket
                       .getInputStream())); // 实例化BufferedReader对象
               getClientInfo(); // 调用getClientInfo()方法
           }
       } catch (Exception e) {
           e.printStackTrace(); // 输出异常信息
       }
   }

private void getClientInfo() {
       try {
           while (true) { // 如果套接字是连接状态
               ta_info.append("接收到客户机发送的信息：" + reader.readLine() + "\n"); // 获得客户端信息
           }
       } catch (Exception e) {
           ta_info.append("客户端已退出。\n"); // 输出异常信息
       } finally {
           try {
               if (reader != null) {
                   reader.close();// 关闭流
               }
               if (socket != null) {
                   socket.close(); // 关闭套接字
               }
           } catch (IOException e) {
               e.printStackTrace();
           }
       }
   }

public static void main(String[] args) { // 主方法
       ServerSocketFrame frame = new ServerSocketFrame(); // 创建本类对象
       frame.setVisible(true);
       frame.getServer(); // 调用方法
   }

public ServerSocketFrame() {
       super();
       setTitle("服务器端程序");
       setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
       setBounds(100, 100, 336, 257);

final JScrollPane scrollPane = new JScrollPane();
       getContentPane().add(scrollPane, BorderLayout.CENTER);

ta_info = new JTextArea();
       scrollPane.setViewportView(ta_info);
   }
}

ClientSocketFrame

package com.xiaoxuzhu;
import java.awt.*;
import java.awt.BorderLayout;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import javax.swing.*;
import javax.swing.JScrollPane;

/**
* Description:
*
* @author xiaoxuzhu
* @version 1.0
*
* <pre>
* 修改记录:
* 修改后版本        修改人修改日期修改内容
* 2022/6/4.1    xiaoxuzhu2022/6/4    Create
* </pre>
* @date 2022/6/4
*/

public class ClientSocketFrame extends JFrame { // 创建类继承JFrame类
   private PrintWriter writer; // 声明PrintWriter类对象
   private Socket socket; // 声明Socket对象
   private JTextArea ta_info = new JTextArea(); // 创建JtextArea对象
   private JTextField tf_send = new JTextField(); // 创建JtextField对象
   private Container cc; // 声明Container对象

public ClientSocketFrame() { // 构造方法
       super(); // 调用父类的构造方法
       setTitle("客户端程序");
       setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
       setBounds(100, 100, 351, 257);
       cc = this.getContentPane(); // 实例化对象
       cc.add(tf_send, "South"); // 将文本框放在窗体的下部
       tf_send.addActionListener(new ActionListener() { // 绑定事件
           public void actionPerformed(ActionEvent e) {
               writer.println(tf_send.getText()); // 将文本框中信息写入流
               ta_info.append("客户端发送的信息是：" + tf_send.getText() + "\n"); // 将文本框中信息显示在文本域中
               tf_send.setText(""); // 将文本框清空
           }
       });
       final JScrollPane scrollPane = new JScrollPane();
       getContentPane().add(scrollPane, BorderLayout.CENTER);
       scrollPane.setViewportView(ta_info);
   }

private void connect() { // 连接套接字方法
       ta_info.append("尝试连接......\n"); // 文本域中信息信息
       try { // 捕捉异常
           socket = new Socket("127.0.0.1", 9527); // 实例化Socket对象
           writer = new PrintWriter(socket.getOutputStream(), true);// 创建输出流对象
           ta_info.append("完成连接。\n"); // 文本域中提示信息
       } catch (Exception e) {
           e.printStackTrace(); // 输出异常信息
       }
   }

public static void main(String[] args) { // 主方法
       ClientSocketFrame clien = new ClientSocketFrame(); // 创建本例对象
       clien.setVisible(true); // 将窗体显示
       clien.connect(); // 调用连接方法
   }
}

服务端启动

客户端启动

客户端发送信息

服务端接收信息

来源：https://juejin.cn/post/7156167887990816799