12.7-全栈Java笔记:Java网络编程

Posted 2020-09-27

UDP通讯的实现

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 

本文出自 “12931675” 博客，请务必保留此出处http://12941675.blog.51cto.com/12931675/1946251