Java实现聊天机器人完善版-APISpace

Java实现聊天机器人完善版

本文实例为大家分享了java实现聊天机器人完善版的具体代码，供大家参考，具体内容如下

Client代码：

package GUISocket.chat.Client;

import javax.swing.JFrame;

import javax.swing.JPanel;

import java.awt.EventQueue;

import javax.swing.JLabel;

import javax.swing.JList;

import javax.swing.JTextField;

import javax.swing.DefaultListModel;

import javax.swing.JButton;

import javax.swing.JTextArea;

import javax.swing.jscrollPane;

import javax.swing.ScrollPaneConstants;

import javax.swing.border.EmptyBorder;

import java.awt.event.ActionListener;

import java.awt.event.ActionEvent;

public class ClientForm extends JFrame {

private JPanel contentPane;

DefaultListModel itemUsers;

private JTextField textIP;

private JTextField textPort;

public JTextField textUser;

public JTextArea textLog;

public JList listUser;

public JTextArea textSend ;

public static void main(String[] args) {

EventQueue.invokeLater(new Runnable() {

public void run() {

try {

ClientForm frame = new ClientForm();

frame.setVisible(true);

ClientMG.getClientMG().setClientForm(frame);

} catch (Exception e) {

e.printStackTrace();

}

});

}

public ClientForm() {

setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

setBounds(100, 100, 589, 607);

contentPane = new JPanel();

contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));

setContentPane(contentPane);

contentPane.setLayout(null);

JcwcsZrxdSLabel label = new JLabel("配置信息");

label.setBounds(10, 10, 54, 15);

contentPane.add(label);

JLabel lblIp = new JLabel("IP");

lblIp.setBounds(10, 35, 27, 15);

contentPane.add(lblIp);

textIP = new JTextField();

textIP.setText("192.168.1.6");

textIP.setBounds(33, 35, 92, 21);

contentPane.add(textIP);

textIP.setColumns(10);

JLabel label_1 = new JLabel("端口");

label_1.setBounds(137, 35, 38, 15);

contentPane.add(label_1);

textPort = new JTextField();

textPort.setText("8900");

textPort.setBounds(168, 32, 66, 21);

contentPane.add(textPort);

textPort.setColumns(10);

JLabel label_2 = new JLabel("用户名");

label_2.setBounds(255, 38, 54, 15);

contentPane.add(label_2);

textUser = new JTextField();

textUser.setBounds(302, 35, 66, 21);

contentPane.add(textUser);

textUser.setColumns(10);

JButton LOGIN = new JButton("登录");

contentPane.add(LOGIN);

JButton btnClose = new JButton("关闭");

btnClose.setBounds(480, 31, 71, 23);

contentPane.add(btnClose);

JPanel panel = new JPanel();

panel.setBounds(0, 10, 573, 61);

contentPane.add(panel);

panel.setLayout(null);

JPanel panel_1 = new JPanel();

panel_1.setBounds(0, 81, 573, 369);

contentPane.add(panel_1);

panel_1.setLayout(null);

JLabel label_3 = new JLabel("聊天记录");

label_3.setBounds(10, 10, 54, 15);

panel_1.add(label_3);

JScrollPane scrollPane = new JScrollPane();

scrollPane.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);

scrollPane.setBounds(20, 35, 323, 324);

panel_1.add(scrollPane);

textLog = new JTextArea();

textLog.setWrapStyleWord(true);

textLog.setLineWrap(true);

scrollPane.setViewportView(textLog);

JLabel label_4 = new JLabel("在线用户");

label_4.setBounds(351, 10, 54, 15);

panel_1.add(label_4);

JScrollPane scrollPane_1 = new JScrollPane();

scrollPane_1.setBounds(353, 35, 210, 324);

panel_1.add(scrollPane_1);

this.itemUsers=new DefaultListModel();

this.listUser=new JList(itemUsers);

scrollPane_1.setViewportView(this.listUser);

JPanel panel_2 = new JPanel();

panel_2.setBounds(10, 449, 553, 119);

contentPane.add(panel_2);

panel_2.setLayout(null);

JLabel label_5 = new JLabel("操作");

label_5.setBounds(10, 10, 54, 15);

panel_2.add(label_5);

JScrollPane scrollPane_2 = new JScrollPane();

scrollPane_2.setBounds(10, 22, 533, 64);

panel_2.add(scrollPane_2);

textSend = new JTextArea();

textSend.setWrapStyleWord(true);

textSend.setLineWrap(true);

scrollPane_2.setViewportView(textSend);

JButton button_1 = new JButton("群发");

button_1.addActionListener(new Button_1ActionListener());

button_1.setBounds(307, 86, 93, 23);

panel_2.add(button_1);

JButton sendMG = new JButton("发送");

sendMG.addActionListener(new SendMGActionListener());

sendMG.setBounds(432, 86, 93, 23);

panel_2.add(sendMG);

public void actionPerformed(ActionEvent e) {

//连接服务器user

String IP=textIP.getText().trim();

int port=Integer.parseInt(textPort.getText().trim());

String user=textUser.getText().trim();

if(ClientMG.getClientMG().Connect(IP,port,user)) {

ClientMG.getClientMG().setLogTxt("已经连接到服务器");

}

else {

ClientMG.getClientMG().setLogTxt("连接服务器失败");

}

});

}

private class SendMGActionListener implements ActionListener {

public void actionPerformed(ActionEvent e) {

//发送信息

//1.获取选择的用户名称

//2.发送给服务器端含有接收用户信息的交互协议串

String SenderName=ClientMG.getClientMG().getClientThd().getName();

String RecName=listUser.getSelectedValue().toString();

String MSGinfo=textSend.getText().trim();

String sMsg="MSG|"+SenderName+"|"+RecName+"|"+MSGinfo;

ClientMG.getClientMG().getClientThd().sendMsg(sMsg);

//将消息内容显示到聊天记录中

//[发送者]

//消息内容

//清空发送消息框

ClientMG.getClientMG().setLogTxt("[我]：");

ClientMG.getClientMG().setLogTxt(MSGinfo);

textSend.setText("");

}

private class Button_1ActionListener implements ActionListener {

public void actionPerformed(ActionEvent e) {

//群发信息

//1.获取选择的用户名称

//2.发送给服务器端含有接收用户信息的交互协议串

//发送到服务器，MSG|SenderName|RecName|MSGInfo

String SenderName=ClientMG.getClientMG().getClientThd().getName();

String RecName="ALL";

String MSGinfo=textSend.getText().trim();

String sMsg="MSG|"+SenderName+"|"+RecName+"|"+MSGinfo;

ClientMG.getClientMG().getClientThd().sendMsg(sMsg);

//将消息内容显示到聊天记录中

//[发送者]

//消息内容

//清空发送消息框

ClientMG.getClientMG().setLogTxt("[我]：");

ClientMG.getClientMG().setLogTxt(MSGinfo);

textSend.setText("");

}

ClientMG代码：

package GUISocket.chat.Client;

import java.net.Socket;

public class ClientMG {

private static final ClientMG clientmg=new ClientMG();

private ClientMG() {}

public static ClientMG getClientMG() {

return clientmg;

}

private ClientForm clientWin;

public void setClientForm(ClientForm c) {

clientWin=c;

}

public void setLogTxt(String str) {

clientWin.textLog.append(str+"\r\n");

}

public void addItem(String user) {

clientWin.itemUsers.addElement(user);

}

public void addItems(String[] users) {

for(int i=0;i

clientWin.itemUsers.addElement(users[i]);

}

SocketThread sthd;

public boolean Connect(String IP,int port,String user) {

Socket socket=null;

try {

socket=new Socket(IP,port);

sthd=new SocketThread(socket, user);

sthd.start();

return true;

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

return false;

}

public SocketThread getClientThd() {

return sthd;

}

SocketThread代码：

package GUISocket.chat.Client;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class SocketThread extends Thread{

BufferedReader br=null;

PrintWriter pw=null;

Socket socket=null;

public SocketThread(Socket socket,String user){

super(user);//登录时用的用户名

this.socket=socket;

}

public void run() {

try {

br=new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8")));

String sLOGIN="LOGIN|"+this.getName();

sendMsg(sLOGIN);

String str="";

while((str=br.readLine())!=null) {

String[] commands=str.split("\\|");

if(commands[0].equals("USERLISTS")) {//USERLISTS|user1_user2_user3

String[] sUsers=commands[1].split("\\_");

ClientMG.getClientMG().addItems(sUsers);

}

else if(commands[0].equals("ADD")) {//ADD|UserName

String sNewUser=commands[1];

ClientMG.getClientMG().addItem(sNewUser);

}

else if(commands[0].equals("MSG")) {//格式 MSG|SenderName|MSGinfo

String SenderName=commands[1];

String MSGinfo=commands[2];

//将消息内容显示到聊天记录中

//[发送者]

//消息内容

ClientMG.getClientMG().setLogTxt("["+SenderName+"]");

ClientMG.getClientMG().setLogTxt(MSGinfo);

}

//ClientMG.getClientMG().setLogTxt(str);

}

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}finally {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e2) {

// TODO: handle exception

}

public void sendMsg(String str) {

pw.println(str);

pw.flush();

}

ServerForm代码：

package GUISocket.chat.Server;

import javax.swing.JFrame;

import javax.swing.JPanel;

import java.awt.EventQueue;

import javax.swing.JLabel;

import javax.swing.JTextField;

import javax.swing.JButton;

import javax.swing.JTextArea;

import javax.swing.JScrollPane;

import javax.swing.ScrollPaneConstants;

import javax.swing.border.EmptyBorder;

import java.awt.event.ActionListener;

import java.awt.event.ActionEvent;

public class ServerForm extends JFrame {

/**

private JPanel contentPane;

public JTextArea textLog;

private JTextField textPort;

public static void main(String[] args) {

EventQueue.invokeLater(new Runnable() {

public void run() {

try {

ServerForm frame = new ServerForm();

frame.setVisible(true);

ServerMG.getServerMG().setServerForm(frame);

} catch (Exception e) {

e.printStackTrace();

}

});

}

public ServerForm() {

setTitle("多人聊天服务器");

setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

setBounds(100, 100, 510, 566);

contentPane = new JPanel();

contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));

setContentPane(contentPane);

contentPane.setLayout(null);

JLabel lblNewLabel = new JLabel("配置信息");

lblNewLabel.setBounds(20, 10, 54, 15);

contentPane.add(lblNewLabel);

JLabel label = new JLabel("端口:");

label.setBounds(30, 34, 39, 15);

contentPane.add(label);

textPort = new JTextField();

textPort.setText("8900");

textPort.setBounds(65, 31, 66, 21);

contentPane.add(textPort);

textPort.setColumns(10);

JButton btnStart = new JButton("开启服务");

btnStart.addActionListener(new BtnStartActionListener());

btnStart.setBounds(180, 30, 93, 23);

contentPane.add(btnStart);

JButton btnClose = new JButton("关闭服务");

btnClose.addActionListener(new BtnCloseActionListener());

btnClose.setBounds(325, 30, 93, 23);

contentPane.add(btnClose);

JPanel panel = new JPanel();

panel.setBounds(10, 10, 474, 54);

contentPane.add(panel);

panel.setLayout(null);

JLabel label_1 = new JLabel("消息记录");

label_1.setBounds(10, 94, 54, 15);

contentPane.add(label_1);

JPanel panel_1 = new JPanel();

panel_1.setBounds(0, 81, 474, 436);

contentPane.add(panel_1);

panel_1.setLayout(null);

JScrollPane scrollPane = new JScrollPane();

scrollPane.setBounds(10, 41, 464, 368);

panel_1.add(scrollPane);

scrollPane.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);

textLog = new JTextArea();

textLog.setLineWrap(true);

textLog.setWrapStyleWord(true);

scrollPane.setViewportView(textLog);

}

private class BtnCloseActionListener implements ActionListener {

public void actionPerformed(ActionEvent e) {

}

private class BtnStartActionListener implements ActionListener {

public void actionPerformed(ActionEvent e) {

//开启服务

int port=Integer.parseInt(textPort.getText().trim());

if(ServerMG.getServerMG().CreateServer(port)) {

ServerMG.getServerMG().setLogTxt("服务器开启...");

}

else {

ServerMG.getServerMG().setLogTxt("服务器开启失败...");

}

ServerListener代码：

package GUISocket.chat.Server;

import java.net.ServerSocket;

import java.net.Socket;

public class ServerListener extends Thread{

Socket socket=null;

ServerSocket server=null;

public ServerListener(ServerSocket server) {

this.server=server;

}

public void run() {

try {

while(true) {

socket=server.accept();

ServerMG.getServerMG().setLogTxt("客户端： "+socket);

new SocketThread(socket).start();

}

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}

SeverMG代码：

package GUISocket.chat.Server;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.ArrayList;

import javax.swing.JTextArea;

public class ServerMG {

private static final ServerMG servermg=new ServerMG();

private ServerMG() {}

public static ServerMG getServerMG() {

return servermg;

}

//主界面的操作

private ServerForm serverWin;

//将窗体对象注册到管理类当中

public void setServerForm(ServerForm s) {

serverWin=s;

}

//设置主界面

public void setLogTxt(String str) {

serverWin.textLog.append(str+"\r\n");

}

private ServerSocket server;

public boolean CreateServer(int port) {

try {

server=new ServerSocket(port);

new ServerListener(server).start();

return true;

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

return false;

}

//ArrayList操作

ArrayList a1OnlineList=new ArrayList<>();//存放所有和

public synchronized void addList(SocketThread sc) {

//限制重名

a1OnlineList.add(sc);

}

public void clearList() {

a1OnlineList.clear();

}

public synchronized void removeList(SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(s.equals(sc)) {

a1OnlineList.remove(sc);

break;

}

//信息的管理

public void getOnlineNames(SocketThread sc) {

//非第1次登录时，得到所有的在线用户

if(a1OnlineList.size()>0) {

String sUsers="";//给客户端，USERLISTS|user1_user2_user3

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

sUsers+=s.getName()+"_";

}

sc.sendMsg("USERLISTS|"+sUsers);

}

public void sendNewUsertoAll(SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

s.sendMsg("ADD|"+sc.getName());

}

//通过Mame用户名查找目标

public SocketThread getSocketThreadByName(String sName) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(s.getName().equals(sName)) {

return s;

}

return null;

}

//发送给所有人，但是要排除自身

public void sendMsgtoAll(String sMsg,SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(!s.equals(sc)) {

s.sendMsg(sMsg);

}

SocketThread代码：

package GUISocket.chat.Server;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class SocketThread extends Thread{

BufferedReader br=null;

PrintWriter pw=null;

Socket socket=null;

public SocketThread(Socket socket) {

this.socket = socket;

}

public void run() {

try {

br=new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8")));

String str="";

while((str=br.readLine())!=null) {//循环响应客户的发送信息//接受客户端发过来的信息

String [] commands=str.split("\\|");

if(commands[0].equals("LOGIN")) {//解析登录请求，格式，LOGIN|UserName

String sUSER=commands[1];

this.setName(sUSER);//将用户名信息放入Threadname中

//1.得到所有在线用户信息名称，发回客户端：USERLISTS|user1_user2_user3

ServerMG.getServerMG().getOnlineNames(this);

//2.将当前登录用户的信息(用户名),发送给已经在线的其他用户，ADD|userName

ServerMG.getServerMG().sendNewUsertoAll(this);

//3.将当前登录的Socket信息放入ArrayList中

ServerMG.getServerMG().addList(this);

}

else if(commands[0].equals("MSG")) {//格式：MSG|SenderName|RecName|MSGoinfo

String SenderName=commands[1];

String RecName=commands[2];

String MSGinfo=commands[3];

//群聊

if(RecName.equals("ALL")) {

String sMsg="MSG!"+SenderName+"|"+MSGinfo;//格式：MSG|SenderName|MSGinfo

ServerMG.getServerMG().sendMsgtoAll(sMsg,this);

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到所有人。");

}

//私聊

else {

//通过RecName用户名查找，找到目标SocketThread

SocketThread sc=ServerMG.getServerMG().getSocketThreadByName(RecName);

if(sc!=null) {

//目标对象发送信息，MSG|SenderName|MSGinfo

String sMsg="MSG!"+SenderName+"|"+MSGinfo;

sc.sendMsg(sMsg);

//写入信息日志

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到"+RecName);

}

} catch (Exception e) {

e.printStackTrace();

}finally {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e2) {

// TODO: handle exception

}

public void closeChat() {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e) {

e.printStackTrace();

}

public void sendMsg(String str) {

pw.println(str);

pw.flush();

}

实现结果如下：

clientWin.itemUsers.addElement(users[i]);

}

SocketThread sthd;

public boolean Connect(String IP,int port,String user) {

Socket socket=null;

try {

socket=new Socket(IP,port);

sthd=new SocketThread(socket, user);

sthd.start();

return true;

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

return false;

}

public SocketThread getClientThd() {

return sthd;

}

SocketThread代码：

package GUISocket.chat.Client;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class SocketThread extends Thread{

BufferedReader br=null;

PrintWriter pw=null;

Socket socket=null;

public SocketThread(Socket socket,String user){

super(user);//登录时用的用户名

this.socket=socket;

}

public void run() {

try {

br=new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8")));

String sLOGIN="LOGIN|"+this.getName();

sendMsg(sLOGIN);

String str="";

while((str=br.readLine())!=null) {

String[] commands=str.split("\\|");

if(commands[0].equals("USERLISTS")) {//USERLISTS|user1_user2_user3

String[] sUsers=commands[1].split("\\_");

ClientMG.getClientMG().addItems(sUsers);

}

else if(commands[0].equals("ADD")) {//ADD|UserName

String sNewUser=commands[1];

ClientMG.getClientMG().addItem(sNewUser);

}

else if(commands[0].equals("MSG")) {//格式 MSG|SenderName|MSGinfo

String SenderName=commands[1];

String MSGinfo=commands[2];

//将消息内容显示到聊天记录中

//[发送者]

//消息内容

ClientMG.getClientMG().setLogTxt("["+SenderName+"]");

ClientMG.getClientMG().setLogTxt(MSGinfo);

}

//ClientMG.getClientMG().setLogTxt(str);

}

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}finally {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e2) {

// TODO: handle exception

}

public void sendMsg(String str) {

pw.println(str);

pw.flush();

}

ServerForm代码：

package GUISocket.chat.Server;

import javax.swing.JFrame;

import javax.swing.JPanel;

import java.awt.EventQueue;

import javax.swing.JLabel;

import javax.swing.JTextField;

import javax.swing.JButton;

import javax.swing.JTextArea;

import javax.swing.JScrollPane;

import javax.swing.ScrollPaneConstants;

import javax.swing.border.EmptyBorder;

import java.awt.event.ActionListener;

import java.awt.event.ActionEvent;

public class ServerForm extends JFrame {

/**

private JPanel contentPane;

public JTextArea textLog;

private JTextField textPort;

public static void main(String[] args) {

EventQueue.invokeLater(new Runnable() {

public void run() {

try {

ServerForm frame = new ServerForm();

frame.setVisible(true);

ServerMG.getServerMG().setServerForm(frame);

} catch (Exception e) {

e.printStackTrace();

}

});

}

public ServerForm() {

setTitle("多人聊天服务器");

setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

setBounds(100, 100, 510, 566);

contentPane = new JPanel();

contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));

setContentPane(contentPane);

contentPane.setLayout(null);

JLabel lblNewLabel = new JLabel("配置信息");

lblNewLabel.setBounds(20, 10, 54, 15);

contentPane.add(lblNewLabel);

JLabel label = new JLabel("端口:");

label.setBounds(30, 34, 39, 15);

contentPane.add(label);

textPort = new JTextField();

textPort.setText("8900");

textPort.setBounds(65, 31, 66, 21);

contentPane.add(textPort);

textPort.setColumns(10);

JButton btnStart = new JButton("开启服务");

btnStart.addActionListener(new BtnStartActionListener());

btnStart.setBounds(180, 30, 93, 23);

contentPane.add(btnStart);

JButton btnClose = new JButton("关闭服务");

btnClose.addActionListener(new BtnCloseActionListener());

btnClose.setBounds(325, 30, 93, 23);

contentPane.add(btnClose);

JPanel panel = new JPanel();

panel.setBounds(10, 10, 474, 54);

contentPane.add(panel);

panel.setLayout(null);

JLabel label_1 = new JLabel("消息记录");

label_1.setBounds(10, 94, 54, 15);

contentPane.add(label_1);

JPanel panel_1 = new JPanel();

panel_1.setBounds(0, 81, 474, 436);

contentPane.add(panel_1);

panel_1.setLayout(null);

JScrollPane scrollPane = new JScrollPane();

scrollPane.setBounds(10, 41, 464, 368);

panel_1.add(scrollPane);

scrollPane.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);

textLog = new JTextArea();

textLog.setLineWrap(true);

textLog.setWrapStyleWord(true);

scrollPane.setViewportView(textLog);

}

private class BtnCloseActionListener implements ActionListener {

public void actionPerformed(ActionEvent e) {

}

private class BtnStartActionListener implements ActionListener {

public void actionPerformed(ActionEvent e) {

//开启服务

int port=Integer.parseInt(textPort.getText().trim());

if(ServerMG.getServerMG().CreateServer(port)) {

ServerMG.getServerMG().setLogTxt("服务器开启...");

}

else {

ServerMG.getServerMG().setLogTxt("服务器开启失败...");

}

ServerListener代码：

package GUISocket.chat.Server;

import java.net.ServerSocket;

import java.net.Socket;

public class ServerListener extends Thread{

Socket socket=null;

ServerSocket server=null;

public ServerListener(ServerSocket server) {

this.server=server;

}

public void run() {

try {

while(true) {

socket=server.accept();

ServerMG.getServerMG().setLogTxt("客户端： "+socket);

new SocketThread(socket).start();

}

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}

SeverMG代码：

package GUISocket.chat.Server;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.ArrayList;

import javax.swing.JTextArea;

public class ServerMG {

private static final ServerMG servermg=new ServerMG();

private ServerMG() {}

public static ServerMG getServerMG() {

return servermg;

}

//主界面的操作

private ServerForm serverWin;

//将窗体对象注册到管理类当中

public void setServerForm(ServerForm s) {

serverWin=s;

}

//设置主界面

public void setLogTxt(String str) {

serverWin.textLog.append(str+"\r\n");

}

private ServerSocket server;

public boolean CreateServer(int port) {

try {

server=new ServerSocket(port);

new ServerListener(server).start();

return true;

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

return false;

}

//ArrayList操作

ArrayList a1OnlineList=new ArrayList<>();//存放所有和

public synchronized void addList(SocketThread sc) {

//限制重名

a1OnlineList.add(sc);

}

public void clearList() {

a1OnlineList.clear();

}

public synchronized void removeList(SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(s.equals(sc)) {

a1OnlineList.remove(sc);

break;

}

//信息的管理

public void getOnlineNames(SocketThread sc) {

//非第1次登录时，得到所有的在线用户

if(a1OnlineList.size()>0) {

String sUsers="";//给客户端，USERLISTS|user1_user2_user3

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

sUsers+=s.getName()+"_";

}

sc.sendMsg("USERLISTS|"+sUsers);

}

public void sendNewUsertoAll(SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

s.sendMsg("ADD|"+sc.getName());

}

//通过Mame用户名查找目标

public SocketThread getSocketThreadByName(String sName) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(s.getName().equals(sName)) {

return s;

}

return null;

}

//发送给所有人，但是要排除自身

public void sendMsgtoAll(String sMsg,SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(!s.equals(sc)) {

s.sendMsg(sMsg);

}

SocketThread代码：

package GUISocket.chat.Server;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class SocketThread extends Thread{

BufferedReader br=null;

PrintWriter pw=null;

Socket socket=null;

public SocketThread(Socket socket) {

this.socket = socket;

}

public void run() {

try {

br=new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8")));

String str="";

while((str=br.readLine())!=null) {//循环响应客户的发送信息//接受客户端发过来的信息

String [] commands=str.split("\\|");

if(commands[0].equals("LOGIN")) {//解析登录请求，格式，LOGIN|UserName

String sUSER=commands[1];

this.setName(sUSER);//将用户名信息放入Threadname中

//1.得到所有在线用户信息名称，发回客户端：USERLISTS|user1_user2_user3

ServerMG.getServerMG().getOnlineNames(this);

//2.将当前登录用户的信息(用户名),发送给已经在线的其他用户，ADD|userName

ServerMG.getServerMG().sendNewUsertoAll(this);

//3.将当前登录的Socket信息放入ArrayList中

ServerMG.getServerMG().addList(this);

}

else if(commands[0].equals("MSG")) {//格式：MSG|SenderName|RecName|MSGoinfo

String SenderName=commands[1];

String RecName=commands[2];

String MSGinfo=commands[3];

//群聊

if(RecName.equals("ALL")) {

String sMsg="MSG!"+SenderName+"|"+MSGinfo;//格式：MSG|SenderName|MSGinfo

ServerMG.getServerMG().sendMsgtoAll(sMsg,this);

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到所有人。");

}

//私聊

else {

//通过RecName用户名查找，找到目标SocketThread

SocketThread sc=ServerMG.getServerMG().getSocketThreadByName(RecName);

if(sc!=null) {

//目标对象发送信息，MSG|SenderName|MSGinfo

String sMsg="MSG!"+SenderName+"|"+MSGinfo;

sc.sendMsg(sMsg);

//写入信息日志

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到"+RecName);

}

} catch (Exception e) {

e.printStackTrace();

}finally {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e2) {

// TODO: handle exception

}

public void closeChat() {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e) {

e.printStackTrace();

}

public void sendMsg(String str) {

pw.println(str);

pw.flush();

}

实现结果如下：

SocketThread s=a1OnlineList.get(i);

if(s.equals(sc)) {

a1OnlineList.remove(sc);

break;

}

//信息的管理

public void getOnlineNames(SocketThread sc) {

//非第1次登录时，得到所有的在线用户

if(a1OnlineList.size()>0) {

String sUsers="";//给客户端，USERLISTS|user1_user2_user3

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

sUsers+=s.getName()+"_";

}

sc.sendMsg("USERLISTS|"+sUsers);

}

public void sendNewUsertoAll(SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

s.sendMsg("ADD|"+sc.getName());

}

//通过Mame用户名查找目标

public SocketThread getSocketThreadByName(String sName) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(s.getName().equals(sName)) {

return s;

}

return null;

}

//发送给所有人，但是要排除自身

public void sendMsgtoAll(String sMsg,SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(!s.equals(sc)) {

s.sendMsg(sMsg);

}

SocketThread代码：

package GUISocket.chat.Server;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class SocketThread extends Thread{

BufferedReader br=null;

PrintWriter pw=null;

Socket socket=null;

public SocketThread(Socket socket) {

this.socket = socket;

}

public void run() {

try {

br=new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8")));

String str="";

while((str=br.readLine())!=null) {//循环响应客户的发送信息//接受客户端发过来的信息

String [] commands=str.split("\\|");

if(commands[0].equals("LOGIN")) {//解析登录请求，格式，LOGIN|UserName

String sUSER=commands[1];

this.setName(sUSER);//将用户名信息放入Threadname中

//1.得到所有在线用户信息名称，发回客户端：USERLISTS|user1_user2_user3

ServerMG.getServerMG().getOnlineNames(this);

//2.将当前登录用户的信息(用户名),发送给已经在线的其他用户，ADD|userName

ServerMG.getServerMG().sendNewUsertoAll(this);

//3.将当前登录的Socket信息放入ArrayList中

ServerMG.getServerMG().addList(this);

}

else if(commands[0].equals("MSG")) {//格式：MSG|SenderName|RecName|MSGoinfo

String SenderName=commands[1];

String RecName=commands[2];

String MSGinfo=commands[3];

//群聊

if(RecName.equals("ALL")) {

String sMsg="MSG!"+SenderName+"|"+MSGinfo;//格式：MSG|SenderName|MSGinfo

ServerMG.getServerMG().sendMsgtoAll(sMsg,this);

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到所有人。");

}

//私聊

else {

//通过RecName用户名查找，找到目标SocketThread

SocketThread sc=ServerMG.getServerMG().getSocketThreadByName(RecName);

if(sc!=null) {

//目标对象发送信息，MSG|SenderName|MSGinfo

String sMsg="MSG!"+SenderName+"|"+MSGinfo;

sc.sendMsg(sMsg);

//写入信息日志

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到"+RecName);

}

} catch (Exception e) {

e.printStackTrace();

}finally {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e2) {

// TODO: handle exception

}

public void closeChat() {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e) {

e.printStackTrace();

}

public void sendMsg(String str) {

pw.println(str);

pw.flush();

}

实现结果如下：

SocketThread s=a1OnlineList.get(i);

sUsers+=s.getName()+"_";

}

sc.sendMsg("USERLISTS|"+sUsers);

}

public void sendNewUsertoAll(SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

s.sendMsg("ADD|"+sc.getName());

}

//通过Mame用户名查找目标

public SocketThread getSocketThreadByName(String sName) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(s.getName().equals(sName)) {

return s;

}

return null;

}

//发送给所有人，但是要排除自身

public void sendMsgtoAll(String sMsg,SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(!s.equals(sc)) {

s.sendMsg(sMsg);

}

SocketThread代码：

package GUISocket.chat.Server;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class SocketThread extends Thread{

BufferedReader br=null;

PrintWriter pw=null;

Socket socket=null;

public SocketThread(Socket socket) {

this.socket = socket;

}

public void run() {

try {

br=new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8")));

String str="";

while((str=br.readLine())!=null) {//循环响应客户的发送信息//接受客户端发过来的信息

String [] commands=str.split("\\|");

if(commands[0].equals("LOGIN")) {//解析登录请求，格式，LOGIN|UserName

String sUSER=commands[1];

this.setName(sUSER);//将用户名信息放入Threadname中

//1.得到所有在线用户信息名称，发回客户端：USERLISTS|user1_user2_user3

ServerMG.getServerMG().getOnlineNames(this);

//2.将当前登录用户的信息(用户名),发送给已经在线的其他用户，ADD|userName

ServerMG.getServerMG().sendNewUsertoAll(this);

//3.将当前登录的Socket信息放入ArrayList中

ServerMG.getServerMG().addList(this);

}

else if(commands[0].equals("MSG")) {//格式：MSG|SenderName|RecName|MSGoinfo

String SenderName=commands[1];

String RecName=commands[2];

String MSGinfo=commands[3];

//群聊

if(RecName.equals("ALL")) {

String sMsg="MSG!"+SenderName+"|"+MSGinfo;//格式：MSG|SenderName|MSGinfo

ServerMG.getServerMG().sendMsgtoAll(sMsg,this);

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到所有人。");

}

//私聊

else {

//通过RecName用户名查找，找到目标SocketThread

SocketThread sc=ServerMG.getServerMG().getSocketThreadByName(RecName);

if(sc!=null) {

//目标对象发送信息，MSG|SenderName|MSGinfo

String sMsg="MSG!"+SenderName+"|"+MSGinfo;

sc.sendMsg(sMsg);

//写入信息日志

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到"+RecName);

}

} catch (Exception e) {

e.printStackTrace();

}finally {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e2) {

// TODO: handle exception

}

public void closeChat() {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e) {

e.printStackTrace();

}

public void sendMsg(String str) {

pw.println(str);

pw.flush();

}

实现结果如下：

SocketThread s=a1OnlineList.get(i);

s.sendMsg("ADD|"+sc.getName());

}

//通过Mame用户名查找目标

public SocketThread getSocketThreadByName(String sName) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(s.getName().equals(sName)) {

return s;

}

return null;

}

//发送给所有人，但是要排除自身

public void sendMsgtoAll(String sMsg,SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(!s.equals(sc)) {

s.sendMsg(sMsg);

}

SocketThread代码：

package GUISocket.chat.Server;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class SocketThread extends Thread{

BufferedReader br=null;

PrintWriter pw=null;

Socket socket=null;

public SocketThread(Socket socket) {

this.socket = socket;

}

public void run() {

try {

br=new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8")));

String str="";

while((str=br.readLine())!=null) {//循环响应客户的发送信息//接受客户端发过来的信息

String [] commands=str.split("\\|");

if(commands[0].equals("LOGIN")) {//解析登录请求，格式，LOGIN|UserName

String sUSER=commands[1];

this.setName(sUSER);//将用户名信息放入Threadname中

//1.得到所有在线用户信息名称，发回客户端：USERLISTS|user1_user2_user3

ServerMG.getServerMG().getOnlineNames(this);

//2.将当前登录用户的信息(用户名),发送给已经在线的其他用户，ADD|userName

ServerMG.getServerMG().sendNewUsertoAll(this);

//3.将当前登录的Socket信息放入ArrayList中

ServerMG.getServerMG().addList(this);

}

else if(commands[0].equals("MSG")) {//格式：MSG|SenderName|RecName|MSGoinfo

String SenderName=commands[1];

String RecName=commands[2];

String MSGinfo=commands[3];

//群聊

if(RecName.equals("ALL")) {

String sMsg="MSG!"+SenderName+"|"+MSGinfo;//格式：MSG|SenderName|MSGinfo

ServerMG.getServerMG().sendMsgtoAll(sMsg,this);

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到所有人。");

}

//私聊

else {

//通过RecName用户名查找，找到目标SocketThread

SocketThread sc=ServerMG.getServerMG().getSocketThreadByName(RecName);

if(sc!=null) {

//目标对象发送信息，MSG|SenderName|MSGinfo

String sMsg="MSG!"+SenderName+"|"+MSGinfo;

sc.sendMsg(sMsg);

//写入信息日志

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到"+RecName);

}

} catch (Exception e) {

e.printStackTrace();

}finally {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e2) {

// TODO: handle exception

}

public void closeChat() {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e) {

e.printStackTrace();

}

public void sendMsg(String str) {

pw.println(str);

pw.flush();

}

实现结果如下：

SocketThread s=a1OnlineList.get(i);

if(s.getName().equals(sName)) {

return s;

}

return null;

}

//发送给所有人，但是要排除自身

public void sendMsgtoAll(String sMsg,SocketThread sc) {

for(int i=0;i

SocketThread s=a1OnlineList.get(i);

if(!s.equals(sc)) {

s.sendMsg(sMsg);

}

SocketThread代码：

package GUISocket.chat.Server;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class SocketThread extends Thread{

BufferedReader br=null;

PrintWriter pw=null;

Socket socket=null;

public SocketThread(Socket socket) {

this.socket = socket;

}

public void run() {

try {

br=new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8")));

String str="";

while((str=br.readLine())!=null) {//循环响应客户的发送信息//接受客户端发过来的信息

String [] commands=str.split("\\|");

if(commands[0].equals("LOGIN")) {//解析登录请求，格式，LOGIN|UserName

String sUSER=commands[1];

this.setName(sUSER);//将用户名信息放入Threadname中

//1.得到所有在线用户信息名称，发回客户端：USERLISTS|user1_user2_user3

ServerMG.getServerMG().getOnlineNames(this);

//2.将当前登录用户的信息(用户名),发送给已经在线的其他用户，ADD|userName

ServerMG.getServerMG().sendNewUsertoAll(this);

//3.将当前登录的Socket信息放入ArrayList中

ServerMG.getServerMG().addList(this);

}

else if(commands[0].equals("MSG")) {//格式：MSG|SenderName|RecName|MSGoinfo

String SenderName=commands[1];

String RecName=commands[2];

String MSGinfo=commands[3];

//群聊

if(RecName.equals("ALL")) {

String sMsg="MSG!"+SenderName+"|"+MSGinfo;//格式：MSG|SenderName|MSGinfo

ServerMG.getServerMG().sendMsgtoAll(sMsg,this);

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到所有人。");

}

//私聊

else {

//通过RecName用户名查找，找到目标SocketThread

SocketThread sc=ServerMG.getServerMG().getSocketThreadByName(RecName);

if(sc!=null) {

//目标对象发送信息，MSG|SenderName|MSGinfo

String sMsg="MSG!"+SenderName+"|"+MSGinfo;

sc.sendMsg(sMsg);

//写入信息日志

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到"+RecName);

}

} catch (Exception e) {

e.printStackTrace();

}finally {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e2) {

// TODO: handle exception

}

public void closeChat() {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e) {

e.printStackTrace();

}

public void sendMsg(String str) {

pw.println(str);

pw.flush();

}

实现结果如下：

SocketThread s=a1OnlineList.get(i);

if(!s.equals(sc)) {

s.sendMsg(sMsg);

}

SocketThread代码：

package GUISocket.chat.Server;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

public class SocketThread extends Thread{

BufferedReader br=null;

PrintWriter pw=null;

Socket socket=null;

public SocketThread(Socket socket) {

this.socket = socket;

}

public void run() {

try {

br=new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8")));

String str="";

while((str=br.readLine())!=null) {//循环响应客户的发送信息//接受客户端发过来的信息

String [] commands=str.split("\\|");

if(commands[0].equals("LOGIN")) {//解析登录请求，格式，LOGIN|UserName

String sUSER=commands[1];

this.setName(sUSER);//将用户名信息放入Threadname中

//1.得到所有在线用户信息名称，发回客户端：USERLISTS|user1_user2_user3

ServerMG.getServerMG().getOnlineNames(this);

//2.将当前登录用户的信息(用户名),发送给已经在线的其他用户，ADD|userName

ServerMG.getServerMG().sendNewUsertoAll(this);

//3.将当前登录的Socket信息放入ArrayList中

ServerMG.getServerMG().addList(this);

}

else if(commands[0].equals("MSG")) {//格式：MSG|SenderName|RecName|MSGoinfo

String SenderName=commands[1];

String RecName=commands[2];

String MSGinfo=commands[3];

//群聊

if(RecName.equals("ALL")) {

String sMsg="MSG!"+SenderName+"|"+MSGinfo;//格式：MSG|SenderName|MSGinfo

ServerMG.getServerMG().sendMsgtoAll(sMsg,this);

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到所有人。");

}

//私聊

else {

//通过RecName用户名查找，找到目标SocketThread

SocketThread sc=ServerMG.getServerMG().getSocketThreadByName(RecName);

if(sc!=null) {

//目标对象发送信息，MSG|SenderName|MSGinfo

String sMsg="MSG!"+SenderName+"|"+MSGinfo;

sc.sendMsg(sMsg);

//写入信息日志

ServerMG.getServerMG().setLogTxt(SenderName+"发送信息["+MSGinfo+"]到"+RecName);

}

} catch (Exception e) {

e.printStackTrace();

}finally {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e2) {

// TODO: handle exception

}

public void closeChat() {

try {

if(pw!=null)

pw.close();

if(br!=null)

br.close();

if(socket!=null)

socket.close();

} catch (Exception e) {

e.printStackTrace();

}

public void sendMsg(String str) {

pw.println(str);

pw.flush();

}

实现结果如下：

mysql连接测试不成功的原因有哪些

226 2022-12-31

Java实现聊天机器人完善版

mysql连接测试不成功的原因有哪些

宝塔数据库启动不了怎么解决

宝塔无法启动MySQL怎么解决

推荐文章

api接口有哪几种分类及功能

什么是API接口?API接口简单介绍

短信API接口概述，短信API接口的优势

7款快递物流的物流查询API工具，物流快递查询API接口怎么对接？

企业四要素: 了解企业经营成功的关键

什么是语音验证码?,语音验证码平台有哪些

全国工商查询系统怎么查企业名录

哪些平台提供实名认证的接口？

PHP如何调用API接口?

如何使用百度天气预报API接口?

最近发表

热评文章

数据接口api（数据接口API开发平台）

数据开放接口api（数据服务api开发）

Python爬虫教程：爬取酷狗音乐（python爬取

hbuilder怎么更改字体大小和颜色

直播平台api接口 - 构建卓越的直播平台

实时股票数据api接口（股票实时行情api接口）