Java聊天室之使用Socket实现通信功能
作者:小虚竹and掘金 时间:2022-03-08 09:46:27
一、题目描述
题目实现:使用套接字实现了服务器端与客户端的通信。
运行程序,在服务器端的文本框中输入信息,然后按回车键,客户端就会收到服务器端发送的信息;
在客户端的文本框中输入信息,然后按回车键,服务器端就会收到客户端发送的信息,发送信息后的效果。
二、解题思路
创建一个服务器类: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;
}
}
服务器启动:
客户端启动:
服务端向客户端发送消息
客户端接收消息
客户端发送消息
服务端接收消息
来源:https://juejin.cn/post/7156377870867103758
标签:Java,聊天室,Socket,通信
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
5分钟快速学会spring boot整合JdbcTemplate的方法
2022-04-01 15:56:11
![](https://img.aspxhome.com/file/2023/6/61296_0s.jpg)
解决feign调用接口不稳定的问题
2022-01-13 19:28:46
微信随机生成红包金额算法java版
2023-07-27 16:01:39
MyBatis查询时属性名和字段名不一致问题的解决方法
2023-10-23 16:56:36
Spring 应用中集成 Apache Shiro的方法
2023-02-18 05:44:55
java并发编程包JUC线程同步CyclicBarrier语法示例
2023-01-18 07:44:58
![](https://img.aspxhome.com/file/2023/7/63687_0s.png)
java读写二进制文件的解决方法
2022-08-03 14:45:55
C++实现无重复字符的最长子串
2023-11-02 22:49:00
springboot 使用QQ邮箱发送邮件的操作方法
2022-03-03 14:36:22
![](https://img.aspxhome.com/file/2023/8/62218_0s.png)
java判断字符串String是否为空问题浅析
2023-08-25 07:06:06
详解Servlet3.0新特性(从注解配置到websocket编程)
2023-08-08 14:29:48
![](https://img.aspxhome.com/file/2023/3/58033_0s.png)
Spring Boot中使用Redis实战案例
2021-06-03 04:17:04
![](https://img.aspxhome.com/file/2023/1/66481_0s.jpg)
Java 如何将网络资源url转化为File文件
2023-05-28 09:23:37
详解Java类库的概念以及import的使用方法
2022-04-18 06:56:54
![](https://img.aspxhome.com/file/2023/4/62774_0s.png)
使用springboot跳转到指定页面和(重定向,请求转发的实例)
2021-10-21 11:09:24
![](https://img.aspxhome.com/file/2023/2/65762_0s.jpg)
Spring拦截器HandlerInterceptor接口代码解析
2022-09-05 10:51:04
Java源码解析HashMap的keySet()方法
2023-11-11 06:33:05
![](https://img.aspxhome.com/file/2023/7/58837_0s.png)
分析Java设计模式之组合模式
2023-11-25 13:13:30
![](https://img.aspxhome.com/file/2023/6/59856_0s.jpg)
Zookeeper事务日志预分配空间解读
2022-03-16 22:36:49
java中超过long范围的超大整数相加算法详解(面试高频)
2022-09-15 11:22:05
![](https://img.aspxhome.com/file/2023/0/61850_0s.png)