Java多线程实现聊天客户端和服务器
林弘文
本文向大家介绍Java多线程实现聊天客户端和服务器，包括了Java多线程实现聊天客户端和服务器的使用技巧和注意事项，需要的朋友参考一下
本文实例为大家分享了java聊天室代码，供大家参考，具体内容如下
主要涉及知识
·Java中GUI程序的编写，包括事件监听机制。
·Java的网络通信编程，ServerSocket，Socket类的使用。
·Java中多线程的编程，Thread类，Runnable接口的使用。
源代码
客户端
package project1;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import javax.swing.*;
public class Client {
private JFrame clientFrame;
private JLabel IPLabel;
private JLabel PortLabel;
private JLabel sayLabel;
private JLabel nicknameLabel;
private JTextField IPText;
private JTextField PortText;
private JTextField nicknameText;
private JTextField sayText;
private JButton connectButton;
private JButton nicknameButton;
private JButton sayButton;
private JPanel jPanelNorth;
private JPanel jPanelSouth0;
private JPanel jPanelSouth1;
private JPanel jPanelSouth2;
private JTextArea clientTextArea;
private JScrollPane scroller;
private BufferedReader reader;
private PrintWriter writer;
private String nickname;
public static void main(String args[]) {
Client aClient = new Client();
aClient.startUp();
}
// 初始化组件
public Client() {
nickname = "客户端";
clientFrame = new JFrame();
jPanelNorth = new JPanel();
IPLabel = new JLabel("服务器IP", JLabel.LEFT);
IPText = new JTextField(10);
PortLabel = new JLabel("服务器端口", JLabel.LEFT);
PortText = new JTextField(10);
connectButton = new JButton("连接");
clientTextArea = new JTextArea();
scroller = new JScrollPane(clientTextArea);
jPanelSouth0 = new JPanel();
jPanelSouth1 = new JPanel();
jPanelSouth2 = new JPanel();
nicknameLabel = new JLabel("昵称", JLabel.LEFT);
nicknameText = new JTextField(nickname, 30);
nicknameButton = new JButton("确认");
sayLabel = new JLabel("消息", JLabel.LEFT);
sayText = new JTextField(30);
sayButton = new JButton("确认");
}
// 构建GUI
private void buildGUI() {
// 窗口的设置
clientFrame.setTitle("客户端");
clientFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
clientFrame.setSize(550, 550);
// 北区的组件
jPanelNorth.add(IPLabel);
jPanelNorth.add(IPText);
jPanelNorth.add(PortLabel);
jPanelNorth.add(PortText);
jPanelNorth.add(connectButton);
clientFrame.getContentPane().add(BorderLayout.NORTH, jPanelNorth);
// 中间的组件
clientTextArea.setFocusable(false);
scroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);
scroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);
clientFrame.getContentPane().add(BorderLayout.CENTER, scroller);
// 南区的组件
jPanelSouth1.add(nicknameLabel);
jPanelSouth1.add(nicknameText);
jPanelSouth1.add(nicknameButton);
jPanelSouth2.add(sayLabel);
jPanelSouth2.add(sayText);
jPanelSouth2.add(sayButton);
jPanelSouth0.setLayout(new BoxLayout(jPanelSouth0, BoxLayout.Y_AXIS));
jPanelSouth0.add(jPanelSouth1);
jPanelSouth0.add(jPanelSouth2);
clientFrame.getContentPane().add(BorderLayout.SOUTH, jPanelSouth0);
// 设置窗口可见
clientFrame.setVisible(true);
}
// 客户端运行
public void startUp() {
buildGUI();
// 接收服务器消息的线程
Runnable incomingReader = new Runnable() {
@Override
public void run() {
String message;
try {
while ((message = reader.readLine()) != null) {
clientTextArea.append(message + "\n");
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
};
// 监听Connect按钮，实现服务器的连接
connectButton.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
String aServerIP = IPText.getText();
String aServerPort = PortText.getText();
if (aServerIP.equals("") || aServerPort.equals("")) {
JOptionPane.showMessageDialog(clientFrame, "请输入 完整的 IP和端口！");
} else {
try {
@SuppressWarnings("resource")
Socket clientSocket = new Socket(aServerIP, Integer.parseInt(aServerPort));
InputStreamReader streamReader = new InputStreamReader(clientSocket.getInputStream());
reader = new BufferedReader(streamReader);
writer = new PrintWriter(clientSocket.getOutputStream());
clientTextArea.append("服务器已连接...\n");
Thread readerThread = new Thread(incomingReader);
readerThread.start();
} catch (Exception ex) {
JOptionPane.showMessageDialog(clientFrame, "连接不上服务器!\n请确认 IP 和 端口 输入正确。");
}
}
}
});
// 监听nickname，设置昵称
ActionListener nicknameListener = new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
String aText = nicknameText.getText();
if (!aText.equals("")) {
nickname = aText;
}
}
};
nicknameButton.addActionListener(nicknameListener);
nicknameText.addActionListener(nicknameListener);
nicknameText.addFocusListener(new FocusListener() {
@Override
public void focusGained(FocusEvent e) {
}
@Override
public void focusLost(FocusEvent e) {
String aText = nicknameText.getText();
if (!aText.equals("")) {
nickname = aText;
}
}
});
// 发送消息到服务器
ActionListener SayListener = new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
String aText = sayText.getText();
if (aText.equals("")) {
JOptionPane.showMessageDialog(clientFrame, "内容不能为空！");
} else {
try {
writer.println(nickname + "：" + aText);
writer.flush();
} catch (Exception ex) {
ex.printStackTrace();
}
sayText.setText("");
}
}
};
sayButton.addActionListener(SayListener);
sayText.addActionListener(SayListener);
}
}
服务器
package project1;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import java.util.ArrayList;
import java.util.Iterator;
import javax.swing.*;
public class Server {
private JFrame serverFrame;
private JLabel portLabel;
private JLabel sayLabel;
private JLabel nicknameLabel;
private JTextField portText;
private JTextField sayText;
private JTextField nicknameText;
private JButton startButton;
private JButton sayButton;
private JButton nicknameButton;
private JPanel jPanelNorth;
private JPanel jPanelSouth0;
private JPanel jPanelSouth1;
private JPanel jPanelSouth2;
private JScrollPane scroller;
private JTextArea serverTextArea;
private ArrayList<PrintWriter> clientOutputStreams;
private String nickname;
public static void main(String[] args) {
Server aServer = new Server();
aServer.startUp();
}
// 初始化组件
public Server() {
nickname = "服务器";
serverFrame = new JFrame();
jPanelNorth = new JPanel();
portLabel = new JLabel("端口", JLabel.LEFT);
portText = new JTextField(30);
startButton = new JButton("开始");
serverTextArea = new JTextArea();
scroller = new JScrollPane(serverTextArea);
nicknameLabel = new JLabel("昵称", JLabel.LEFT);
nicknameText = new JTextField(nickname, 30);
nicknameButton = new JButton("确认");
jPanelSouth0 = new JPanel();
jPanelSouth1 = new JPanel();
jPanelSouth2 = new JPanel();
sayLabel = new JLabel("消息", JLabel.LEFT);
sayText = new JTextField(30);
sayButton = new JButton("确认");
}
// 构建GUI
private void buildGUI() {
// 窗口的设置
serverFrame.setTitle("服务器");
serverFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
serverFrame.setSize(550, 550);
// 北区的组件
jPanelNorth.add(portLabel);
jPanelNorth.add(portText);
jPanelNorth.add(startButton);
serverFrame.getContentPane().add(BorderLayout.NORTH, jPanelNorth);
// 中间的组件
serverTextArea.setFocusable(false);
scroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);
scroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);
serverFrame.getContentPane().add(BorderLayout.CENTER, scroller);
// 南区的组件
jPanelSouth1.add(nicknameLabel);
jPanelSouth1.add(nicknameText);
jPanelSouth1.add(nicknameButton);
jPanelSouth2.add(sayLabel);
jPanelSouth2.add(sayText);
jPanelSouth2.add(sayButton);
jPanelSouth0.setLayout(new BoxLayout(jPanelSouth0, BoxLayout.Y_AXIS));
jPanelSouth0.add(jPanelSouth1);
jPanelSouth0.add(jPanelSouth2);
serverFrame.getContentPane().add(BorderLayout.SOUTH, jPanelSouth0);
// 设置窗口可见
serverFrame.setVisible(true);
}
// 服务器运行
public void startUp() {
buildGUI();
// 监听Start按钮，建立端口
ActionListener startListener = new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
clientOutputStreams = new ArrayList<PrintWriter>();
String aPort = portText.getText();
if (aPort.equals("")) {
JOptionPane.showMessageDialog(serverFrame, "请输入正确的端口号！");
} else {
try {
// 等待客户端连接的线程
Runnable serverRunnable = new Runnable() {
@Override
public void run() {
ServerSocket serverSocket;
try {
serverSocket = new ServerSocket(Integer.parseInt(aPort));
serverTextArea.append("正在等待客户端连接...\n");
while (true) {
Socket clientSocket = serverSocket.accept();
serverTextArea.append("客户端已连接...\n");
PrintWriter writer = new PrintWriter(clientSocket.getOutputStream());
clientOutputStreams.add(writer);
Thread t = new Thread(new ClientHandler(clientSocket));
t.start();
}
} catch (NumberFormatException | IOException e) {
e.printStackTrace();
}
}
};
Thread serverThread = new Thread(serverRunnable);
serverThread.start();
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
};
startButton.addActionListener(startListener);
portText.addActionListener(startListener);
// 监听nickname，设置昵称
ActionListener nicknameListener = new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
String aText = nicknameText.getText();
if (!aText.equals("")) {
nickname = aText;
}
}
};
nicknameButton.addActionListener(nicknameListener);
nicknameText.addActionListener(nicknameListener);
nicknameText.addFocusListener(new FocusListener() {
@Override
public void focusGained(FocusEvent e) {
}
@Override
public void focusLost(FocusEvent e) {
String aText = nicknameText.getText();
if (!aText.equals("")) {
nickname = aText;
}
}
});
// 监听Say按钮，发送消息
ActionListener SayListener = new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
String aText = sayText.getText();
if (!aText.equals("")) {
aText = nickname + "：" + aText;
sendToEveryClient(aText);
serverTextArea.append(aText + "\n");
sayText.setText("");
} else {
JOptionPane.showMessageDialog(serverFrame, "内容不能为空！");
}
}
};
sayButton.addActionListener(SayListener);
sayText.addActionListener(SayListener);
}
// 多客户端的线程
public class ClientHandler implements Runnable {
BufferedReader bReader;
Socket aSocket;
public ClientHandler(Socket clientSocket) {
try {
aSocket = clientSocket;
InputStreamReader isReader = new InputStreamReader(aSocket.getInputStream());
bReader = new BufferedReader(isReader);
} catch (Exception ex) {
ex.printStackTrace();
}
}
@Override
public void run() {
String message;
try {
while ((message = bReader.readLine()) != null) {
sendToEveryClient(message);
serverTextArea.append(message + "\n");
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
// 发送消息给所有客户端的方法
private void sendToEveryClient(String message) {
Iterator<PrintWriter> it = clientOutputStreams.iterator();
while (it.hasNext()) {
try {
PrintWriter writer = (PrintWriter) it.next();
writer.println(message);
writer.flush();
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
}
GUI运行截图：
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持小牛知识库。
类似资料：
-
服务器和客户端使用我自己的协议进行通信，看起来像XMPP。我应该实现聊天应用。因此，当一个用户编写String时，它应该立即通过服务器发送给其他客户端。我在服务器上有sendToAll方法。但用户只有在按下回车键时才能看到其他用户的消息。用户如何在不按回车键的情况下接收消息？ 这是我的客户： 以及带有ServerThread的服务器。 服务器线程。
-
问题内容： 服务器和客户端使用我自己的协议（类似于XMPP）进行通信。我应该实现聊天应用程序。因此，当一个用户写String时，应该立即将其通过服务器发送给其他客户端。我在服务器上有sendToAll方法。但是用户只有在按Enter时才能看到其他用户的消息。 用户如何在不按Enter键的情况下接收消息？ 这是我的客户： 和带有ServerThread的服务器。 ServerThread。 问题答案
-
我需要在netty中有一个客户机/服务器通信，用于我的项目目的之一。所以我刚开始用一个handsOn来改进，我正在学习netty，我是一个初学者。 我尝试了一个简单的客户端服务器与Netty聊天。 客户端和服务器正在初始化，我可以看到服务器能够获得用于建立连接的客户端管道，但是当客户端发送消息时，它没有进入ServerAdapterHandler的messageReceived部分。下面是我的源代
-
本文向大家介绍Golang实现的聊天程序服务端和客户端代码分享，包括了Golang实现的聊天程序服务端和客户端代码分享的使用技巧和注意事项，需要的朋友参考一下 实现逻辑 1、Golang 版本 1.3 2、实现原理： 1、主进程建立TCP监听服务，并且初始化一个变量 talkChan := make(map[int]chan string) 2、当主进程ACCEPT连接请求后，利用go
-
我已经实现了一个通过套接字进行通信的全局聊天。客户端写入一条消息，发送到服务器，然后服务器将消息发回给所有客户端。每个客户端都由一个名为ClientThread的类表示，因此每个客户端都是一个线程。每次新客户端连接时，我都会创建一个新的ClientThread实例，并将所有这些实例存储在列表中。现在我想实现一个私人聊天，这样每个客户端就可以私下与另一个客户端交谈（或者2,3或更多的群聊）。 我还想