您的位置:首页 > 理论基础 > 计算机网络

初识Java TCP/IP Socket-UDP网络编程知识

2016-07-26 00:43 811 查看
Java 通过 DatagramPacket 类和 DatagramSocket 类来使用 UDP 套接字,客户端和服务器端都通过DatagramSocket 的 send()方法和 receive()方法来发送和接收数据,用 DatagramPacket 来包装需要发送或者接收到的数据。发送信息时,Java 创建一个包含待发送信息的 DatagramPacket 实例,并将其作为参数传递给DatagramSocket实例的send()方法;接收信息时,Java 程序首先创建一个 DatagramPacket 实例,该实例预先分配了一些空间,并将接收到的信息存放在该空间中,然后把该实例作为参数传递给 DatagramSocket 实例的 receive()方法。

UDP 客户端要经过下面三步操作:

创建一个 DatagramSocket 实例,可以有选择对本地地址和端口号进行设置,如果设置了端口号,则客户端会在该端口号上监听从服务器端发送来的数据;

使用 DatagramSocket 实例的 send()和 receive()方法来发送和接收 DatagramPacket 实例,进行通信;

通信完成后,调用 DatagramSocket 实例的 close()方法来关闭该套接字。

UDP服务端要经过下面三步操作:

创建一个 DatagramSocket 实例,指定本地端口号,并可以有选择地指定本地地址,此时,服务器已经准备好从任何客户端接收数据报文;

使用 DatagramSocket 实例的 receive()方法接收一个 DatagramPacket 实例,当 receive()方法返回时,数据报文就包含了客户端的地址,这样就知道了回复信息应该发送到什么地方;

使用 DatagramSocket 实例的 send()方法向服务器端返回 DatagramPacket 实例。

-

package UDP;

import java.io.IOException;
import java.net.*;

/**
* Created with IntelliJ IDEA.
* User: YEN
* Date: 2016/7/26
* Time: 00:30
*/

//客户端
public class Client {
public static void main(String[] args) throws IOException {

/*向服务端发送数据*/

//1.定义服务器的地址、端口号、数据
InetAddress inetAddress=InetAddress.getByName("localhost");
int port=10000;
String str="这是客户端要发送给服务端的数据:This is test";
byte[] data=str.getBytes();
//2.创建数据报,包含发送的数据信息
DatagramPacket packet=new DatagramPacket(data,data.length,inetAddress,port);
//3.创建DatagramSocket对象
DatagramSocket socket=new DatagramSocket();
socket.send(packet);

/*接收服务端响应的数据*/
//1.创建数据报,用于接收服务器端响应的数据
byte[] data1=new byte[1024];
DatagramPacket packet1=new DatagramPacket(data1,data1.length);
//2.接收服务器响应的数据
socket.receive(packet1);
//3.读取数据
String value=new String(data1,0,packet1.getLength());
System.out.println("这里是客户端,收到的服务器信息为:"+value);

//4.关闭资源
socket.close();

}
}


package UDP;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

/**
* Created with IntelliJ IDEA.
* User: YEN
* Date: 2016/7/26
* Time: 00:30
*/
public class Server {
public static void main(String[] args) throws IOException {
/*接收客户端发送的数据*/
//1.创建服务器端DatagramSocket,指定端口
DatagramSocket socket=new DatagramSocket(10000);
//2.创建数据报,用于接收客户端发送的数据
byte[] data =new byte[1024];//创建字节数组,指定接收的数据包的大小
DatagramPacket packet=new DatagramPacket(data, data.length);
//3.接收客户端发送的数据
System.out.println("****服务器端已经启动,等待客户端发送数据");
socket.receive(packet);//此方法在接收到数据报之前会一直阻塞
//4.读取数据
String value=new String(data, 0, packet.getLength());
System.out.println("这里是服务器,收到ke客户端的消息为:"+value);
}
}


内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: