资讯

精准传达 • 有效沟通

从品牌网站建设到网络营销策划,从策略到执行的一站式服务

12.7-全栈Java笔记:Java网络编程(五)-创新互联

UDP通讯的实现

创新互联公司是专业的三江侗网站建设公司,三江侗接单;提供成都网站制作、成都网站建设,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行三江侗网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!

1.DatagramSocket:用于发送或接收数据包

当服务器要向客户端发送数据时,需要在服务器端产生一个DatagramSocket对象,在客户端产生一个DatagramSocket对象。服务器端的DatagramSocket将DatagramPacket发送到网络上,然后被客户端的DatagramSocket接收。

DatagramSocket有两种构造函数。一种是无需任何参数的,常用于客户端。另一种需要指定端口,常用于服务器。

常用方法:send、receive、 close

2.DatagramPacket:数据容器(封包)的作用

常用方法:构造函数、getAddrress(获取发送或接收方计算机的IP地址)、getData(获取发送或接收的数据)、setData(设置发送的数据)

3.UDP通信编程基本步骤:

a)创建客户端的DatagramSocket,创建时,定义客户端的监听端口

b)创建服务器端的DatagramSocket,创建时,定义服务器端的监听端口

c)在服务器端定义DatagramPacket对象,封装待发送的数据包。

d)服务器端将数据包发送出去

e)客户端接收数据包

【示例1】客户端与服务器端单向通信之客户端

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetSocketAddress;

public class Client {

    public static void main(String[] args) throws  Exception {

       byte[] b = "aaaa".getBytes();

       //必须告诉数据包要发到哪里去

      DatagramPacket dp = new DatagramPacket(b,b.length,new  InetSocketAddress("localhost",8999));

       //我本身占用9000端口向外面机器发数据包

      DatagramSocket ds = new DatagramSocket(9000);

      ds.send(dp);

      ds.close();

   }

}

【示例2】客户端与服务器端单向通信之服务器端

import java.net.DatagramPacket;

import java.net.DatagramSocket;

public class Server {

    public static void main(String[] args) throws  Exception {

      DatagramSocket ds = new DatagramSocket(8999);

       byte[] b = new byte[1024];

      DatagramPacket dp = new DatagramPacket(b,b.length);

      ds.receive(dp);  //阻塞式方法

      String string = new  String(dp.getData(),0,dp.getLength());   //dp.getLength()返回实际收到的数据的字节数

      System.out.println(string);

      ds.close();

   }

}

通过ByteArrayInputStream、ByteArrayOutputStream可以传递基本类型数据。

【示例3】客户端

public class Client {

    public static void main(String[] args) throws  Exception {

       long n = 2000L;

       ByteArrayOutputStream bos = new ByteArrayOutputStream();

      DataOutputStream  dos = new  DataOutputStream(bos);

      dos.writeLong(n);

      byte[] b = bos.toByteArray();

      //必须告诉数据包要发到哪里去

      DatagramPacket dp = new DatagramPacket(b,b.length,new  InetSocketAddress("localhost",8999));

      //我本身占用9000端口向外面机器发数据包

      DatagramSocket ds = new DatagramSocket(9000);

      ds.send(dp);

      ds.close();

   }

}

【示例4】服务器端

public class Server {

    public static void main(String[] args) throws  Exception {

      DatagramSocket ds = new DatagramSocket(8999);

       byte[] b = new byte[1024];

      DatagramPacket dp = new DatagramPacket(b,b.length);

      ds.receive(dp);  //阻塞式方法

       ByteArrayInputStream  bis = new  ByteArrayInputStream(dp.getData());

      DataInputStream  dis = new  DataInputStream(bis);

      System.out.println(dis.readLong());

      ds.close();

}

}

通过ByteArrayInputStream、ByteArrayOutputStream可以传递对象。

【示例5】Person类(客户端与服务器端都需要存在Person类)

class Person implements Serializable{

    int age;

   String name;

    public Person(int age, String name) {

       super();

       this.age = age;

       this.name = name;

   }

}

【示例6】客户端

public class Client {

    public static void main(String[] args) throws  Exception {

      Person person = new Person(20,"aa");

       ByteArrayOutputStream  bos = new  ByteArrayOutputStream();

      ObjectOutputStream  oos = new  ObjectOutputStream(bos);

      oos.writeObject(person);

      byte[] b = bos.toByteArray();

      //必须告诉数据包要发到哪里去

      DatagramPacket dp = new DatagramPacket(b,b.length,new  InetSocketAddress("localhost",8999));

      //我本身占用9000端口向外面机器发数据包

      DatagramSocket ds = new DatagramSocket(9000);

      ds.send(dp);

      ds.close();

   }

}

【示例7】服务器端

public class Server {

    public static void main(String[] args) throws  Exception {

      DatagramSocket ds = new DatagramSocket(8999);

       byte[] b = new byte[1024];

      DatagramPacket dp = new DatagramPacket(b,b.length);

      ds.receive(dp); //阻塞式方法

       ByteArrayInputStream  bis = new  ByteArrayInputStream(dp.getData());

      ObjectInputStream  ois = new  ObjectInputStream(bis);

      Person  person = (Person) ois.readObject();

      System.out.println(person.name);

      ds.close();

   }

}


「全栈Java笔记」是一部能帮大家从零到一成长为全栈Java工程师系列笔记。笔者江湖人称 Mr. G,10年Java研发经验,曾在神州数码、航天院某所研发中心从事软件设计及研发工作,从小白逐渐做到工程师、高级工程师、架构师。精通Java平台软件开发,精通JAVAEE,熟悉各种流行开发框架。

 笔记包含从浅入深的六大部分:

 A-Java入门阶段

 B-数据库从入门到精通

 C-手刃移动前端和Web前端

 D-J2EE从了解到实战

 E-Java高级框架精解

 F-Linux和Hadoop


另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


名称栏目:12.7-全栈Java笔记:Java网络编程(五)-创新互联
标题URL:http://cdkjz.cn/article/cdppdd.html
多年建站经验

多一份参考,总有益处

联系快上网,免费获得专属《策划方案》及报价

咨询相关问题或预约面谈,可以通过以下方式与我们联系

大客户专线   成都:13518219792   座机:028-86922220