计算机网络课程设计UDP聊天室代码(共30页).doc

《计算机网络课程设计UDP聊天室代码(共30页).doc》由会员分享，可在线阅读，更多相关《计算机网络课程设计UDP聊天室代码(共30页).doc（30页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、精选优质文档-倾情为你奉上计算网络UDP聊天室 学 院 计算机学院 专 业 软件工程 年级班别 2011级1班 学 号 学生姓名 指导教师 许青林 成 绩 .实验目的 UDP是无链接的通信方式，通信开销小，利用UDP实现聊天系统。通过实验掌握UDP的工作原理及应用方法。.实验要求 1、采用多线程技术，多用户同时在线。 2、实现群聊功能，一个人发消息多人可收到。 3、用JAVA实现 UDP开发模型如下： .系统结构聊天系统分为服务器端和客户端。服务器程序作为一个中转站，所有客户端都只与服务器进行通信。如图：.程序设计服务器端：服务器与客户间通过套接口Socket连接。在java中使用套接口相当简

2、单，Java API为处理套接口的通信提供了一个类.Socket.,使得编写网络应用程序相对容易服务器采用多线程以满足多用户的请求，服务端主要用到InetAddress, DatagramSocket, DatagramPacket三个类；InetAddress用于描述和包装一个Internet IP地址；DatagramSocket用于接收和发送UDP的Socket实例；DatagramPacket用于处理报文，它将Byte数组、目标地址、目标端口等数据包装成报文或者将报文拆卸成Byte数组。客户端：客户端是一个Java Application程序，客户通过Socket 建立与服务器的连接。

3、主要用到InetAddress, DatagramSocket, DatagramPacket三个类三个类。界面设计：客户端UI设计：Chat Boxes有五个输入框，包括本机端口，服务器端口，本机IP地址，服务器IP地址输入以及消息输入框，依次为Personal port，Server port，Nickname和Server IP以及send按钮左旁的输入框，且在输入的消息中自动获取本机时间，然后和发送消息一起打包发到服务器，服务器接收后发到客户端。服务器IP不为空。 Server UI设计：Server chat boxes有两个输入框，分别是服务器端口（Server port）和客户端

4、端口（Personal port）和一个连接按钮（Connect）；.代码:（按照下面的格式创建相应的java文件，将代码粘贴复制即可）1. Sendmessage,javapackage chatboxes;import java.io.Serializable;import .InetAddress;public class Sendmessage implements Serializable/* * */private static final long serialVersionUID = 1L;private InetAddress addr;private InetAddress

5、 destaddr;private String name;private String msg;public Sendmessage(InetAddress addr, InetAddress destaddr, String name, String msg) this.addr = addr;this.destaddr = destaddr;this.name = name;this.msg = msg;public InetAddress getAddr() return addr;public InetAddress getDestaddr() return destaddr;pub

6、lic String getName() return name;public String getMsg() return msg;2. Serverchar.javapackage chatboxes;import java.awt.BorderLayout;import java.awt.Container;import java.awt.FlowLayout;import java.awt.GridLayout;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.io.Bu

7、fferedInputStream;import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.IOException;import java.io.ObjectInputStream;import java.io.ObjectOutputStream;import .DatagramPacket;import .DatagramSocket;import .InetAddress;import .MulticastSocket;import .SocketException;i

8、mport .UnknownHostException;import java.util.ArrayList;import java.util.Collection;import java.util.Iterator;import java.util.List;import java.util.ListIterator;import javax.swing.JButton;import javax.swing.JFrame;import javax.swing.JLabel;import javax.swing.JPanel;import javax.swing.JScrollPane;imp

9、ort javax.swing.JTextArea;import javax.swing.JTextField;public class Serverchat implements Runnable, ActionListenerprivate List addList;JTextArea showArea;JLabel lbl1, lbl2;JTextField sendPortText, receivePortText;JFrame mainJframe;JButton startBtn;JScrollPane JSPane;JPanel pane1, pane2;Container co

10、n;Thread thread = null;DatagramPacket sendPack, receivePack;DatagramSocket sendSocket, receiveSocket;private int sendPort, receivePort;private byte inBuf, outBuf;private MulticastSocket multiSocket = null;public Serverchat() throws UnknownHostException addList = new ArrayList();mainJframe = new JFra

11、me(Server chat boxes);con = mainJframe.getContentPane();showArea = new JTextArea();showArea.setEditable(false);showArea.setLineWrap(true);lbl1 = new JLabel(Server port:);lbl2 = new JLabel(Personal port:);sendPortText = new JTextField();sendPortText.setColumns(5);receivePortText = new JTextField();re

12、ceivePortText.setColumns(5);startBtn = new JButton(Connect);startBtn.addActionListener(this);pane1 = new JPanel();pane1.setLayout(new GridLayout(3,2);pane1.add(lbl1);pane1.add(receivePortText);pane1.add(lbl2);pane1.add(sendPortText);pane1.add(startBtn);JSPane = new JScrollPane(showArea);pane2 = new

13、JPanel();pane2.setLayout(new FlowLayout();con.add(pane1, BorderLayout.NORTH);con.add(JSPane, BorderLayout.CENTER);con.add(pane2, BorderLayout.SOUTH);mainJframe.setSize(600,600);mainJframe.setVisible(true);mainJframe.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);showArea.append(= +=n);showArea.appen

14、d(= +=n);public static void main(String args) try new Serverchat(); catch (UnknownHostException e) / TODO Auto-generated catch blocke.printStackTrace();Overridepublic void run() Sendmessage msg;while (true) try receiveSocket.receive(receivePack);ByteArrayInputStream byteStream = new ByteArrayInputSt

15、ream(receivePack.getData();ObjectInputStream is = new ObjectInputStream(new BufferedInputStream(byteStream); Object o = is.readObject();msg = (Sendmessage) o;is.close();InetAddress test = receivePack.getAddress();if(!addList.contains(test)addList.add(test);for(InetAddress iaddr : addList)sendPack =

16、new DatagramPacket(receivePack.getData(), receivePack.getData().length, iaddr,sendPort);sendSocket.send(sendPack);showArea.append(msg.getAddr() + ：n + msg.getMsg() + n); catch (IOException el) showArea.append(el.getMessage()+n); catch (ClassNotFoundException e) / TODO Auto-generated catch blocke.pri

17、ntStackTrace();Overridepublic void actionPerformed(ActionEvent e) try if (e.getSource() = startBtn) if(sendPortText.getText().equals()sendPort = 10087;elsesendPort = Integer.parseInt(sendPortText.getText();if(receivePortText.getText().equals()receivePort = 10086;elsereceivePort = Integer.parseInt(re

18、ceivePortText.getText();inBuf = new byte16384;sendSocket = new DatagramSocket();receivePack = new DatagramPacket(inBuf, inBuf.length);receiveSocket = new DatagramSocket(receivePort);thread = new Thread(this);thread.setPriority(Thread.MIN_PRIORITY);thread.start();startBtn.setEnabled(false);else catch

19、 (SocketException e1) showArea.append(System Error+e1.getMessage()+n); catch (IOException e1) showArea.append(System Error+e1.getMessage()+n);3. UIchat.javapackage chatboxes;import java.awt.BorderLayout;import java.awt.Container;import java.awt.FlowLayout;import java.awt.GridLayout;import java.awt.e

20、vent.ActionEvent;import java.awt.event.ActionListener;import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.IOException;import java.io.ObjectInputStream;import java.io.ObjectOutputStream;import .

21、DatagramPacket;import .DatagramSocket;import .InetAddress;import .SocketException;import .UnknownHostException;import java.text.SimpleDateFormat;import java.util.Date;import javax.swing.JButton;import javax.swing.JFrame;import javax.swing.JLabel;import javax.swing.JPanel;import javax.swing.JScrollPa

22、ne;import javax.swing.JTextArea;import javax.swing.JTextField;public class UIchat implements Runnable, ActionListener JTextArea showArea;JLabel lbl1, lbl2, lbl3, lbl4;JTextField msgText, sendPortText, receivePortText, IPAddressText, name;JFrame mainJframe;JButton sendBtn, startBtn;JScrollPane JSPane

23、;JPanel pane1, pane2;Container con;Thread thread = null;DatagramPacket sendPack, receivePack;DatagramSocket sendSocket, receiveSocket;private String username;private InetAddress sendIP;private int sendPort, receivePort;private byte inBuf, outBuf;public UIchat() mainJframe = new JFrame(Chat Boxes);co

24、n = mainJframe.getContentPane();showArea = new JTextArea();showArea.setEditable(false);showArea.setLineWrap(true);lbl1 = new JLabel(Personal port:);lbl2 = new JLabel(Server port:);lbl3 = new JLabel(Server IP:);lbl4 = new JLabel(Nickname:);sendPortText = new JTextField();sendPortText.setColumns(15);r

25、eceivePortText = new JTextField();receivePortText.setColumns(15);name = new JTextField();name.setColumns(15);IPAddressText = new JTextField();IPAddressText.setColumns(15);startBtn = new JButton(Connect);startBtn.addActionListener(this);pane1 = new JPanel();pane1.setLayout(new GridLayout(5,2);pane1.a

26、dd(lbl1);pane1.add(receivePortText);pane1.add(lbl2);pane1.add(sendPortText);pane1.add(lbl3);pane1.add(IPAddressText);pane1.add(lbl4);pane1.add(name);pane1.add(startBtn);JSPane = new JScrollPane(showArea);msgText = new JTextField();msgText.setColumns(40);msgText.setEditable(false);msgText.addActionLi

27、stener(this);sendBtn = new JButton(Send);sendBtn.setEnabled(false);sendBtn.addActionListener(this);pane2 = new JPanel();pane2.setLayout(new FlowLayout();pane2.add(msgText);pane2.add(sendBtn);con.add(pane1, BorderLayout.NORTH);con.add(JSPane, BorderLayout.CENTER);con.add(pane2, BorderLayout.SOUTH);ma

28、inJframe.setSize(700, 600);mainJframe.setVisible(true);mainJframe.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);showArea.append(= +=n);showArea.append( Please Keep The Ports Of The Chat Boxes Up With The Ports Of Server chat boxesn+ *The Nickname Is The IP Of Your Personal Computer IP*n+ *The Serve

29、r IP Should Not Be Null!*n);showArea.append(= +=n);public static void main(String args) new UIchat();Overridepublic void actionPerformed(ActionEvent e) try if (e.getSource() = startBtn) inBuf = new byte16384;if(sendPortText.getText().equals()sendPort = 10086;elsesendPort = Integer.parseInt(sendPortT

30、ext.getText();if(receivePortText.getText().equals()receivePort = 10087;elsereceivePort = Integer.parseInt(receivePortText.getText();if(name.getText().equals()username = InetAddress.getLocalHost().toString();elseusername = name.getText();sendIP = InetAddress.getByName(IPAddressText.getText();sendSock

31、et = new DatagramSocket();receivePack = new DatagramPacket(inBuf, inBuf.length);receiveSocket = new DatagramSocket(receivePort);thread = new Thread(this);thread.setPriority(Thread.MIN_PRIORITY);thread.start();startBtn.setEnabled(false);sendBtn.setEnabled(true);msgText.setEditable(true);else String m

32、sg1 = msgText.getText();SimpleDateFormat format=new SimpleDateFormat(yyyy-MM-dd HH:mm:ss);String msg=format.format(new Date()+ : +msg1;Sendmessage message = new Sendmessage(InetAddress.getLocalHost(),sendIP,username,msg);ByteArrayOutputStream baos = new ByteArrayOutputStream(); ObjectOutputStream oo

33、s = null; oos = new ObjectOutputStream(baos); oos.writeObject(message); oos.flush(); outBuf = baos.toByteArray();sendPack = new DatagramPacket(outBuf, outBuf.length, sendIP,sendPort);sendSocket.send(sendPack);msgText.setText(null); catch (UnknownHostException e1) showArea.append(System Error+e1.getM

34、essage()+n); catch (SocketException e1) showArea.append(System Error+e1.getMessage()+n);showArea.append(Errors：Network congestion，Please open the second client to test machinen); catch (IOException e1) showArea.append(System Error+e1.getMessage()+n);public void run() Sendmessage msg;while (true) try

35、 receiveSocket.receive(receivePack);ByteArrayInputStream byteStream = new ByteArrayInputStream(receivePack.getData();ObjectInputStream is = new ObjectInputStream(new BufferedInputStream(byteStream);Object o = is.readObject();msg = (Sendmessage) o;is.close();showArea.append(msg.getName() + ：n + msg.g

36、etMsg() + n); catch (IOException el) showArea.append(System Error+el.getMessage()+n); catch (ClassNotFoundException e) showArea.append(System Error+e.getMessage()+n);.运行结果 启动服务器启动客户端,连接服务器: 服务器IP为192.168.0.107启动后并发送消息：本机（zhizhou）发送到另外的客户端（lin）：服务器端显示：6. 心得 通过这次课程设计让我进一步掌握了网络和Java的结合，实现了网络编程。充分了解了基于UDP编程和功能模块化的优越性，这样便于维护和修改，并且很容易找到它有可能出现的错误和漏洞。对于UDp下的聊天室设计，从一开始的一无所知，到后来知道应该学习相应的知识去解决，其中包括java中多线程的了解以及网络编程，这次课程设计让我对于java的网络通信有了更深的了解，以及对于知识的感悟，在程序的世界里，真的是学海无涯，但是仍需我们“苦作舟”，不断去追求新的进步，以及学会去解决问题的能力，这无论对于我的编程能力的提高和解决问题的能力的提高都有很大的作用，当然，在此特别感谢同学在编程上一些beg的帮忙还有百度上各位朋友的解答。专心-专注-专业