nt.KeyAdapter;

{//继承窗口来实现窗口功能/*设置接受客户端的集合,把接入服务器的客户端存入集合,方便后续的消息转发*/ArrayListSocket

socketsClients

ArrayList();/*由于下面线程需要调用窗口的一些东西,所以需要全局变量*/JTextArea

jTextArea;JTextArea

JTextArea(30,20);//只能设置几列JButton

jButtonSend

BorderLayout());//显示消息this.setDefaultCloseOperation(EXIT_ON_CLOSE);//关闭窗口结束程序this.setTitle(来自客户端的消息);this.setSize(500,

500);jTextArea

JTextArea();//显示客户端的信息jTextArea.setEditable(false);//不可以修改

面板信息JScrollPane

JScrollPane(jTextArea);priorPanel.add(clientInformation,BorderLayout.CENTER);//写一个发布公告的窗口JPanel

sendPanel

JScrollPane(jTextSend);jScrollPane.setPreferredSize(new

Dimension(400,50));sendPanel.add(jScrollPane);sendPanel.add(jButtonSend);priorPanel.add(sendPanel,BorderLayout.SOUTH);this.add(priorPanel);//创建监听发送键

jButtonSend.addActionListener(new

ActionListener()

{/*用来对每个客户端发送公告*/Overridepublic

void

来自服务器的公告:jTextSend.getText()\n;//把公告发布到聊天界面jTextArea.append(announcement);/*使用for循环来遍历每个客户端的对象*/for(Socket

soc:socketsClients){DataOutputStream

dataOutputStream

DataOutputStream(soc.getOutputStream());dataOutputStream.writeUTF(announcement\n);}

catch

{ioException.printStackTrace();}}jTextSend.setText(null);}});this.setVisible(true);

{//创建服务器对象

ServerSocket(9998);//使用无限循环来不停接受客户端的连接while(true){Socket

socketClient

serverSocket.accept();//接收到一个就向集合加入一个客户端socketsClients.add(socketClient);//就收一个连接就在后台提示一遍System.out.println(有socketsClients.size()个邓钦文连接到服务器!);//然后启动该客户端的线程

SocketThread(socketClient).start();}//处理客户端输入的东西}

catch

{e.printStackTrace();System.out.println(服务器启动失败!);}}//创建监听//创建内部类

线程class

DataInputStream(socket.getInputStream());this.socket

socket;}/*重写run方法

dataInputStream.readUTF();/*读取客户端的信息

并打印到自己的窗口上*/jTextArea.append(msg\n);//给每一个客户端发送信息

soc:socketsClients){DataOutputStream

dataOutputStream

DataOutputStream(soc.getOutputStream());dataOutputStream.writeUTF(msg\n);}}

catch

{e.printStackTrace();System.out.println(读取失败!);socketsClients.remove(socket);return;}}}}}客户端

登录界面

{this.setSize(600,500);this.setTitle(欢迎登录);this.setResizable(true);this.setDefaultCloseOperation(EXIT_ON_CLOSE);//关闭窗口结束程序this.setLocationRelativeTo(this);JPanel

jPanelLast

JLabel(欢迎登录);jLabel.setFont(new

Font(宋体,Font.BOLD,30));//中间部分JPanel

jPanelMiddle

JTextField(15);jPanelAccount.add(jLabelAccount);jPanelAccount.add(jTextFieldAccount);JPanel

jPanelPassword

JPasswordField(15);jPanelPassword.add(jLabelPassword);jPanelPassword.add(jTextFieldPassword);//底部

登录按钮端JPanel

JButton(注册);jPanelButton.add(enterButton);jPanelButton.add(signButton);jPanelTop.add(jLabel);jPanelMiddle.add(jPanelAccount);jPanelMiddle.add(jPanelPassword);jPanelFoot.add(jPanelButton);jPanelLast.add(jPanelTop);jPanelLast.add(jPanelMiddle);jPanelLast.add(jPanelFoot);this.add(jPanelLast);this.setVisible(true);

来判断用户的读取enterButton.addActionListener(new

ActionListener()

//1.判断不能为空if(jTextFieldAccount.getText().length()0||jTextFieldPassword.getText().length()0)

{JOptionPane.showMessageDialog(null,

//2.输入只能为数字与字母if((jTextFieldAccount.getText().matches([a-zA-Z0-9]*)jTextFieldPassword.getText().matches([a-zA-Z0-9]*))false){JOptionPane.showMessageDialog(null,输入的账号或密码只能为字母和数字);return;}//如果都满足了登录成功

客户端对象

ChatFrame(jTextFieldAccount.getText(),socket);dispose();//关闭了登录窗口}

catch

{ioException.printStackTrace();JOptionPane.showMessageDialog(null,无法连接服务器);}}});}}聊天界面

import

600);this.setTitle(欢迎来到account聊天室);this.setResizable(true);this.setDefaultCloseOperation(DO_NOTHING_ON_CLOSE);JPanel

jPanelEnd

BorderLayout());//最终面板jTextArea

new

JTextArea();jTextArea.setEditable(false);JScrollPane

jScrollPane1

JScrollPane(jTextArea);jPanelEnd.add(jScrollPane1,BorderLayout.CENTER);JPanel

jPanelInput

JTextArea(5,40);//带滑动的窗口JScrollPane

jScrollPane2

JScrollPane(jTextArea2);//不能通过add加入,只能通过构造方法加入,这样不会出现不显示的问题jPanelInput.add(jScrollPane2);JButton

jButtonSend

JButton(发送);jPanelInput.add(jButtonSend);jPanelEnd.add(jPanelInput,BorderLayout.SOUTH);this.add(jPanelEnd);try

{new

{e.printStackTrace();JOptionPane.showMessageDialog(null,发送错误);}

//关闭窗口,显示登录窗口this.addWindowListener(new

WindowAdapter()

{System.out.println(你确定要关闭我妈?);int

res

JOptionPane.showConfirmDialog(null,你确定要关闭我吗,操作提示,JOptionPane.OK_CANCEL_OPTION);if(res0){//点击确定new

EnterFrame();dispose();//关闭当前对象}}});//监听发送事件try

{DataOutputStream

DataOutputStream(socket.getOutputStream());String

message

socketOutput.toString();jButtonSend.addActionListener(new

ActionListener()

{if(message.length()0){JOptionPane.showMessageDialog(null,输入消息不能为空!);return;}String

msg

{socketOutput.writeUTF(msg);System.out.println(msg);jTextArea2.setText();}

catch

{ioException.printStackTrace();JOptionPane.showMessageDialog(null,发生错误);}}});}

catch

{e.printStackTrace();}this.setVisible(true);

ClientThread

DataInputStream(socket.getInputStream());this.socket

void

{while(true){/*把接受的到信息添加到窗口中*/String

msg

inputStream.readUTF();jTextArea.append(msg\n);}}

catch

{e.printStackTrace();return;}}}

}启动程序