位置：首页>> 软件编程>> java编程>> Java聊天室之使用Socket实现通信功能

Java聊天室之使用Socket实现通信功能

作者：小虚竹and掘金　　发布时间：2022-03-08 09:46:27　

标签：Java,聊天室,Socket,通信

一、题目描述

题目实现：使用套接字实现了服务器端与客户端的通信。

运行程序，在服务器端的文本框中输入信息，然后按回车键，客户端就会收到服务器端发送的信息;

在客户端的文本框中输入信息，然后按回车键，服务器端就会收到客户端发送的信息，发送信息后的效果。

二、解题思路

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

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

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

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

对文本框添加一个事件：实现向客户端发磅信息。

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

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

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

技术重点：

通过Socket类的getInpuStream()方法来获得输入流对象，并借助 InputStreamReader类将输入流对象转换为BufferedReader对象读取接收到的信息;

使用getOutputStream()方法获得输出流对象实现，并创建了PrintWriter对象发送信息。。

三、代码详解

ServerSocketFrame

package com.xiaoxuzhu;

import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;
import java.net.*;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
/**
* 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 JTextField tf_send;
private JTextArea ta_info;
private PrintWriter writer; // 声明PrintWriter类对象
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对象
reader = new BufferedReader(new InputStreamReader(socket
.getInputStream())); // 实例化BufferedReader对象
writer = new PrintWriter(socket.getOutputStream(), true);
getClientInfo(); // 调用getClientInfo()方法
}
} catch (Exception e) {
e.printStackTrace(); // 输出异常信息
}
}

private void getClientInfo() {
try {
while (true) { // 如果套接字是连接状态
String line = reader.readLine();
if (line != null)
ta_info.append("接收到客户机发送的信息：" + line + "\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, 379, 260);

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

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

final JPanel panel = new JPanel();
getContentPane().add(panel, BorderLayout.NORTH);

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) {
writer.println(tf_send.getText()); // 将文本框中信息写入流
ta_info.append("服务器发送的信息是：" + tf_send.getText() + "\n"); // 将文本框中信息显示在文本域中
tf_send.setText(""); // 将文本框清空
}
});
tf_send.setPreferredSize(new Dimension(220, 25));
panel.add(tf_send);
}
}

ClientSocketFrame

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

/**
* 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 JLabel label;
private JPanel panel;
private PrintWriter writer; // 声明PrintWriter类对象
private BufferedReader reader; // 声明BufferedReader对象
private Socket socket; // 声明Socket对象
private JTextArea ta_info = new JTextArea(); // 创建JtextArea对象
private JTextField tf_send = new JTextField(); // 创建JtextField对象

public ClientSocketFrame() { // 构造方法
super(); // 调用父类的构造方法
setTitle("客户端程序");
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
setBounds(100, 100, 361, 257);
final JScrollPane scrollPane = new JScrollPane();
getContentPane().add(scrollPane, BorderLayout.CENTER);
scrollPane.setViewportView(ta_info);
getContentPane().add(getPanel(), BorderLayout.NORTH);
}

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

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

private void getClientInfo() {
try {
while (true) { // 如果套接字是连接状态
if (reader != null) {
String line = reader.readLine();
if (line != null)
ta_info.append("接收到服务器发送的信息：" + line + "\n"); // 获得客户端信息
}
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (reader != null) {

reader.close();// 关闭流

}
if (socket != null) {
socket.close(); // 关闭套接字
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

/**
* @return
*/
protected JPanel getPanel() {
if (panel == null) {
panel = new JPanel();
panel.add(getLabel());
tf_send.setPreferredSize(new Dimension(200, 25));
panel.add(tf_send);
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(""); // 将文本框清空
}
});
}
return panel;
}

/**
* @return
*/
protected JLabel getLabel() {
if (label == null) {
label = new JLabel();
label.setText("客户端发送的信息：");
}
return label;
}
}