本文實例為大家分享了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<String> 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); JLabel 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('登錄'); LOGIN.setBounds(395, 34, 66, 23); 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<String>(); 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); LOGIN.addActionListener(new ActionListener() { 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+'rn'); } public void addItem(String user) { clientWin.itemUsers.addElement(user); } public void addItems(String[] users) { for(int i=0;i<users.length;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+'rn'); } 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<SocketThread> 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<a1OnlineList.size();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<a1OnlineList.size();i++) { SocketThread s=a1OnlineList.get(i); sUsers+=s.getName()+'_'; } sc.sendMsg('USERLISTS|'+sUsers); } } public void sendNewUsertoAll(SocketThread sc) { for(int i=0;i<a1OnlineList.size();i++) { SocketThread s=a1OnlineList.get(i); s.sendMsg('ADD|'+sc.getName()); } } //通過Mame用戶名查找目標 public SocketThread getSocketThreadByName(String sName) { for(int i=0;i<a1OnlineList.size();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<a1OnlineList.size();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|MSGinfoString 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(); }}

實現結果如下：

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持好吧啦網。