JAVA聊天室源码.doc

《JAVA聊天室源码.doc》由会员分享，可在线阅读，更多相关《JAVA聊天室源码.doc（61页珍藏版）》请在得力文库 - 分享文档赚钱的网站上搜索。

1、Four short words sum up what has lifted most successful individuals above the crowd: a little bit more.-author-dateJAVA聊天室源码/聊天室服务器/聊天室服务器import .*;import java.io.*;import java.util.*;import java.awt.event.*;import java.awt.*;import javax.swing.*;class Server extends JFrame private TextArea msgA = n

2、ew TextArea();/服务器用来输入的文本域private TextArea area = new TextArea();/服务器显示消息的文本域private TextField portT = new TextField(8888);private java.awt.List list = new java.awt.List();/在线客户列表private ServerSocket server;/服务器private Socket client;/客户端private Map container = new HashMap();/HashMapvoid init() /设置几个

3、面板/ Panel p1 = new Panel(); Panel p2 = new Panel(); Panel p3 = new Panel(); Panel p4 = new Panel(); Panel p5 = new Panel(); Panel p6 = new Panel(); Panel p7 = new Panel(); Panel p8 = new Panel(); Panel p9 = new Panel(); Panel p10 = new Panel(); /设置两个主要的文本框 Label lb1 = new Label(服务器界面); lb1.setBackgr

4、ound(new Color(250,120,150); Label lb2 = new Label(port); BorderLayout border1 = new BorderLayout(); p1.setLayout(border1); p1.add(BorderLayout.CENTER, area); BorderLayout border2 = new BorderLayout(); p5.setLayout(border2); p5.add(BorderLayout.NORTH, p3); p5.add(BorderLayout.CENTER, msgA); BorderLa

5、yout border3 = new BorderLayout(); p7.setLayout(border3); p7.add(BorderLayout.CENTER, p1); p7.add(BorderLayout.SOUTH, p5); p7.setBackground(new Color(250,150,200); JButton startButton = new JButton(启动服务); JButton sendButton = new JButton(发送); JButton flushButton = new JButton(刷新列表); FlowLayout fl =

6、new FlowLayout(FlowLayout.LEFT); p8.setLayout(fl); p8.add(lb2); p8.add(portT); p8.add(startButton); p8.add(sendButton); p8.add(flushButton); p8.setBackground(new Color(250,120,150); BorderLayout border4 = new BorderLayout(); p9.setLayout(border4); p9.add(BorderLayout.CENTER, p7); p9.add(BorderLayout

7、.SOUTH, p8); p10.setLayout(new BorderLayout(); Label lb3 = new Label(在线用户); lb3.setBackground(new Color(250,120,150); p10.add(lb3,BorderLayout.NORTH); p10.add(list,BorderLayout.CENTER); area.setEditable(false); BorderLayout border = new BorderLayout(); this.addWindowListener(new WindowAdapter() publ

8、ic void windowClosing(WindowEvent arg0) System.exit(0); ); this.setLayout(border); this.add(BorderLayout.NORTH, lb1); this.add(BorderLayout.CENTER, p9); this.add(BorderLayout.EAST, p10); this.setTitle(聊天服务器 ); this.setBounds(100, 100, 600, 550); this.setVisible(true); /启动服务按钮监听器 startButton.addActio

9、nListener(new ActionListener() public void actionPerformed(ActionEvent e) Thread t = new Start(); t.start(); );/启动按钮监听器-end /发送按钮监听器 sendButton.addActionListener(new ActionListener() public void actionPerformed(ActionEvent e) String msg = msgA.getText(); if (msg != null & msg != ) /如果消息不为空 Calendar

10、ca = new GregorianCalendar(); int hh = ca.get(Calendar.HOUR_OF_DAY); int mm = ca.get(Calendar.MINUTE); int ss = ca.get(Calendar.SECOND); String time = new String(hh + : + mm + : + ss + ); broadcast(time + 系统消息: + msg);/那么广播这条系统消息 area.append(time + 系统消息: + msg + n); msgA.setText(); );/end /刷新按钮监听器 f

11、lushButton.addActionListener(new ActionListener() public void actionPerformed(ActionEvent e) if (list != null) list.removeAll();/清空在线用户列表,以便刷新 SetMap.Entry mySet = container.entrySet(); for (IteratorMap.Entry it = mySet.iterator(); it.hasNext();) /刷新列表 Map.Entry me = it.next(); String aClientName =

12、me.getKey(); Socket aClient = me.getValue(); String aClientAddress = aClient.getInetAddress().getHostAddress(); list.add(aClientName + - + aClientAddress); /end of for /end of actionPerformed );/end msgA.addKeyListener(new KeyAdapter()/键盘监听器-按下Enter发送信息 public void keyPressed(KeyEvent e) int value =

13、 e.getKeyCode(); if(value = KeyEvent.VK_ENTER) String msg = msgA.getText(); Calendar ca = new GregorianCalendar(); int hh = ca.get(Calendar.HOUR_OF_DAY); int mm = ca.get(Calendar.MINUTE); int ss = ca.get(Calendar.SECOND); String time = new String(hh + : + mm + : + ss + ); broadcast(time + 系统消息: + ms

14、g);/那么广播这条系统消息 area.append(time + 系统消息: + msg + n); msgA.setText(); );/end of init()class Start extends Thread /启动服务器的线程 public void run() try if(server != null & !server.isClosed() area.append(警告!服务器已在启动中!n); else server = new ServerSocket(Integer.parseInt(portT.getText();/启动服务器 area.append(new Dat

15、e().toString() +n+ 恭喜!_+服务器启动成功! + nn); while(true) client = server.accept(); Thread sgS = new SgService(client);/为每位登录的客户创建一个线程 sgS.start();/启动客户线程 catch (Exception e) System.out.println(cuowu 1); e.printStackTrace(); /end of run() /end of Start/处理单个客户的线程class SgService extends Thread/SgService-beg

16、in private Socket client = null;/客户套接字 private BufferedReader br = null;/输入流 private PrintStream ps = null; private int counter = 0;/记录是第几次接受用户的信息 private int mark = 0;/记录用户说不文明用语的次数 private String name = null; SgService(Socket client) /构造方法 this.client = client; public void run() /run()-begin try b

17、r = new BufferedReader(new InputStreamReader(client.getInputStream(); ps = new PrintStream(client.getOutputStream(); String msg = null; while (msg = br.readLine() != null) /无限循环,意味着可以和客户进行无限次交互 if(counter = 0) name = msg; container.put(name,client); list.add(name + - + client.getInetAddress().getHos

18、tAddress(); Calendar ca = new GregorianCalendar(); int hh = ca.get(Calendar.HOUR_OF_DAY); int mm = ca.get(Calendar.MINUTE); int ss = ca.get(Calendar.SECOND); String time = hh + : + mm + : + ss + ; broadcast(time + name + 上线了！); area.append(time + name + 上线了！nn); counter +; else if(msg.equals(你是个笨蛋)

19、mark = mark + 1; if(mark 3) Calendar ca = new GregorianCalendar(); int hh = ca.get(Calendar.HOUR_OF_DAY); int mm = ca.get(Calendar.MINUTE); int ss = ca.get(Calendar.SECOND); String time = new String(hh + : + mm + : + ss + ); singleCom(time +系统消息: 警告！请注意文明用语！ ,client); /在服务器端显示这个用户说不文明语言的次数 area.appe

20、nd(time + 系统消息: + name +第 + mark+ 次使用了不文明用语，特此警告！); else/如果客户第三次说不文明的话,系统就把他踢出聊天室 Calendar ca = new GregorianCalendar(); int hh = ca.get(Calendar.HOUR_OF_DAY); int mm = ca.get(Calendar.MINUTE); int ss = ca.get(Calendar.SECOND); String time = new String(hh + : + mm + : + ss + ); if(mark = 3) singleCo

21、m(time + 系统消息: 由于您多次使用了不文明用语,经警告无效，现已被踢出聊天室! ,client);/告诉他本人 removeClient(name,client);/从系统列表中删除这个人的信息 /并向所有人广播这一消息 broadcast(time + 系统消息: + name + 由于多次使用了不文明用语,经警告无效，现已被踢出聊天室!); area.append(time + 系统消息: + name + 由于多次使用了不文明用语,经警告无效，现已被踢出聊天室!n); else Calendar ca = new GregorianCalendar(); int hh = ca

22、.get(Calendar.HOUR_OF_DAY); int mm = ca.get(Calendar.MINUTE); int ss = ca.get(Calendar.SECOND); String time = new String(hh + : + mm + : + ss + ); area.append(time + name+说:+msg + nn);/将客户发送的消息显示在服务器的窗口中 broadcast(time + name+说:+msg+n);/同时向每个在线客户广播这则消息 /end of while catch (Exception ex) Calendar ca

23、= new GregorianCalendar(); int hh = ca.get(Calendar.HOUR_OF_DAY); int mm = ca.get(Calendar.MINUTE); int ss = ca.get(Calendar.SECOND); String time = new String(hh + : + mm + : + ss + ); area.append(time + name + 下线了!n); broadcast(time + name + 下线了!n); list.remove(name + - + client.getInetAddress().ge

24、tHostAddress(); container.remove(name); /run()-end/SgService-end void removeClient(String name,Socket client)/踢人 list.remove(name + - + client.getInetAddress().getHostAddress(); container.remove(name);/广播void broadcast(String msg) /broadcast()-begin SetMap.Entry mySet = container.entrySet(); Iterato

25、rMap.Entry it = mySet.iterator(); String message = msg; while (it.hasNext() /如果列表中还有客户 Map.Entry me = it.next(); Socket tempClient = me.getValue(); singleCom(message, tempClient);/就把消息向发给这个客户 /broadcast()-end/向单个客户发送消息private void singleCom(String msg, Socket aClient) /singleCommunication-begin try

26、PrintStream pw = new PrintStream(aClient.getOutputStream(); String message = msg; pw.println(msg); catch (Exception ex) ex.printStackTrace(); /singleCommunication-endpublic static void main(String args) new Server().init(); /启动服务器窗口 System.out.println(服务器:);/end of Server/登录界面：import javax.swing.*;i

27、mport java.awt.*;import java.awt.event.*;import java.io.*;import .*;class Login extends JFrame implements ActionListenerTextField txtPort;TextField txtIP;TextField txtName;JButton btnLogin;JButton btnCancel;Socket toServer;BufferedReader in;PrintStream out;public Login() Panel p1=new Panel(); Panel

28、p2=new Panel(); Panel p3=new Panel(); Panel p4=new Panel(); Panel p5=new Panel(); Label l1=new Label(port); Label l2=new Label(IP); Label l3=new Label(昵称); txtPort=new TextField(8888,15); txtIP=new TextField(192.168.55.1,15); txtName=new TextField(小敏,15); p2.add(l1); p2.add(txtPort); p3.add(l2); p3.

29、add(txtIP); p4.add(l3); p4.add(txtName); GridLayout g=new GridLayout(3,1);/三行一列的网格布局管理器 p1.setLayout(g);/设置布局管理器 p1.add(p2);/将组件添加到面板中 p1.add(p3); p1.add(p4); p1.setBackground(new Color(100,250,100);/更改面板颜色 btnLogin=new JButton(登陆); btnCancel=new JButton(取消); btnLogin.addActionListener(this);/添加监听器

30、btnCancel.addActionListener(this); BorderLayout border1=new BorderLayout();/边界布局管理器 this.setLayout(border1); p5.add(btnLogin); p5.add(btnCancel); this.add(BorderLayout.SOUTH,p5); this.add(BorderLayout.CENTER,p1); this.setSize(350,250); this.setTitle(用户登录); this.setResizable(false); this.setLocation(

31、450,250); this.setVisible(true); this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);/关闭窗口 /实现登录和取消按钮的监听器 public void actionPerformed(ActionEvent e) JButton button = (JButton)e.getSource(); if(button.equals(btnCancel) dispose();/如果客户按了取消按钮,那么登录窗口就关闭 else /如果客户按了登录,那么就连接服务器 LoginStart ls = new LoginS

32、tart(); ls.start(); this.dispose(); class LoginStart extends Thread public void run() int port = Integer.parseInt(txtPort.getText();/取得端口号 String ip = txtIP.getText();/取得要连接的服务器的IP地址 String name = txtName.getText();/取得客户姓名 try toServer = new Socket(ip,port); /连接服务端 socket(主机名，端口号); in = new Buffered

33、Reader(new InputStreamReader(toServer.getInputStream(); /建立输入流 out = new PrintStream(toServer.getOutputStream();/输出流 new Client(out,in,name);/如果登录成功,则弹出客户端聊天窗口 dispose(); /同时关闭登录窗口 catch (Exception e2) System.out.println(登录失败!);/如果登录失败,则打印出登录失败,以告知客户 e2.printStackTrace(); public static void main(Str

34、ing args) new Login();/启动登录窗口 /聊天室客户端import java.awt.event.*;import javax.swing.*;import java.io.*;import .*;import java.awt.*;class Client extends JFrame PrintStream out; /输出流 BufferedReader in; /输入流String name;TextArea area = new TextArea();TextArea msgA = new TextArea();TextField frdNameT = new T

35、extField(10);List list =new List(); Panel p10=new Panel();JButton sendButton = new JButton(发送);JButton closeButton = new JButton(关闭);JButton jb1 = new JButton(设置背景颜色);JButton jb2 = new JButton(设置字体颜色);Label lb1 = new Label(昵称:);void init() this.pack(); /设置几个面板 Panel p1=new Panel(); Panel p2=new Pane

36、l(); Panel p3=new Panel(); Panel p4=new Panel(); Panel p5=new Panel(); Panel p6=new Panel(); Panel p7=new Panel(); Panel p8=new Panel(); Panel p9=new Panel(); lb1.setBackground(Color.pink); /设置两个主要的文本框 BorderLayout border1=new BorderLayout(); p1.setLayout(border1); p1.add(BorderLayout.CENTER,area);

37、area.setEditable(false); FlowLayout f2=new FlowLayout(FlowLayout.LEFT); p3.setLayout(f2); p3.add(jb1); p3.add(jb2); BorderLayout border2=new BorderLayout(); p5.setLayout(border2); p5.add(BorderLayout.NORTH,p3); p5.add(BorderLayout.CENTER,msgA); p5.setBackground(Color.pink); BorderLayout border3=new

38、BorderLayout(); p7.setLayout(border3); p7.add(BorderLayout.CENTER,p1); p7.add(BorderLayout.SOUTH,p5); FlowLayout fl=new FlowLayout(FlowLayout.RIGHT); p8.setLayout(fl); p8.add(sendButton); p8.add(closeButton); p8.setBackground(Color.pink); BorderLayout border4=new BorderLayout(); p9.setLayout(border4

39、); p9.add(BorderLayout.CENTER,p7); p9.add(BorderLayout.SOUTH,p8); /窗口关闭 this.addWindowListener(new WindowAdapter() public void windowClosing(WindowEvent arg0) System.exit(0); ); BorderLayout border5=new BorderLayout(); p10.setLayout(border5); p10.add(BorderLayout.CENTER,list); p10.setBackground(Color.pink); /添加背景颜色的监听器 jb1.addActionListener(new ActionListener() public void actionPerformed(ActionEvent e) JColorChooser chooser4=new JColorChooser(); Color color=chooser4.showDialog(Client.this,我的调色盘,Color.yellow); area.setBackground(color);