黑马程序员技术交流社区

标题: 黑马程序员-Java基础-UDP网络传输协议-聊天室 [打印本页]
作者: QQheima    时间: 2015-6-13 22:46
标题: 黑马程序员-Java基础-UDP网络传输协议-聊天室
UDP传输协议的特点
1、面向无连接
2、非安全传输协议
3、数据包大小必须在64K以内
4、传输速度快
以下给出网络聊天室的代码

发送端：
/**
* 需求：通过UDP传输协议方式，将一段文字数据发送出去。
* 思路：
* 1、建立udpsocket服务。
* 2、提供数据，并将数据封装到数据包中。
* 3、通过socket服务的发送功能，将数据包发送出去。
* 4、关闭资源。
* @param args
*/

  1. import java.net.*;
  2. import java.io.*;

  4. class UdpSend{
  5.         public static void main(String[] args) throws Exception {
  6.                 //1、建立UDP服务
  7.                 DatagramSocket dgs = new DatagramSocket(8888);
  8.                
  9.                 //2、提供数据源，并打包封装
  10.                 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
  11.                 String line = null;
  12.                 while((line=br.readLine())!=null){
  13.                         byte[] buf = line.getBytes();
  14.                         DatagramPacket dgp = new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.23.255"),10000);
  15.                        
  16.                         //发送数据
  17.                         dgs.send(dgp);
  18.                 }
  19.                
  20.                 //关闭资源
  21.                 br.close();
  22.                 dgs.close();
  23.         }
  24. }
复制代码



接收端：
/**
* 需求：
* 定义一个应用程序，用于接受UDP协议传输来的数据并处理。
*
* 思路：
* 1、定义UdpSocket服务
* 2、定义一个数据包，用来存储接收到的字节数据
*                 因为数据包对象中有更多功能，可以提取字节数据中的不同数据信息。
* 3、通过socket服务receive方法将收到的数据存入已定义好的数据包中
* 4、通过数据包对象的特有功能，将这些不同的数据取出，打印在控制台上。
* 5、关闭资源连接
* @author Administrator
*
*/

  1. import java.net.*;
  2. import java.io.*;

  4. public class UdpReceived{
  5.         public static void main(String[] args)throws Exception{
  6.                 //1、建立UDP服务，创建socket对象
  7.                 DatagramSocket dgs = new DatagramSocket(10000);
  8.                
  9.                 //2、创建字符数组，用于存储接收的数据
  10.                 byte[] buf = new byte[1024];
  11.                 DatagramPacket dgp = new DatagramPacket(buf,buf.length);
  12.                
  13.                 while(true){
  14.                         //3、通过socket服务获取数据
  15.                         dgs.receive(dgp);
  16.                        
  17.                         //4、通过数据包获取数据
  18.                         String addr = dgp.getAddress().getHostAddress();
  19.                         int port = dgp.getPort();
  20.                        
  21.                         String con = new String(dgp.getData(),0,dgp.getLength());
  22.                         //String con = new String(buf,0,dgp.getLength());
  23.                        
  24.                         //5、打印数据，关闭资源
  25.                         System.out.println(addr+":"+port+"----"+con);
  26.                 }
  27.         }
  28. }
复制代码







欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2