上面我们了解TCP就是三次握手!!!
下面我们就详细介绍一下UDP,就是进行发包(TCP协议类似于就是打电话,你必须进行连接才能进行传输,但是UDP类似于发消息,连不连接我都是可以的!!!)【从这里我们就可以知道一个小细节,就是在上面编写TCP的时候我们是需要先对服务端开启,然后才开始客户端进行,但是udp是无所谓的,我不管目标那边什么状态,我都会进行发送的,所以先开也是没事的】
下面我们进行详细的代码体现:
其实核心就是就是两步:
1.创建连接DatagramSocket
2.发送包datagramSocket.send();
3.然后就是顺理成章对其进行写包,详细下面代码进行介绍!
package demo03;import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;public class UdpClientDemo01 {public static void main(String[] args) throws Exception {//建立连接SocketDatagramSocket datagramSocket = new DatagramSocket();//创建包的内容String msg = "你好服务器!!";InetAddress localhost = InetAddress.getByName("localhost");int port = 9090;//创建包DatagramPacket datagramPacket = new DatagramPacket(msg.getBytes(),0,msg.getBytes().length,localhost,port);//发包datagramSocket.send(datagramPacket);//关闭资源datagramSocket.close();}
}
那么就开始写怎么进行接受包:
1.你需要对上述端口进行创建
2.接受数据包
package demo03;import java.net.DatagramPacket;
import java.net.DatagramSocket;public class UdpServerDemo01 {public static void main(String[] args) throws Exception {//开放端口DatagramSocket datagramSocket = new DatagramSocket(9090);//怎么对数据包接收//创建一个容器byte[] buffer = new byte[1024];DatagramPacket datagramPacket = new DatagramPacket(buffer, 0, buffer.length);//接受数据包datagramSocket.receive(datagramPacket);//对其数据包的内容进行发送System.out.println(datagramPacket.getAddress());System.out.println(new String(datagramPacket.getData(),0, datagramPacket.getLength()));//关闭资源datagramSocket.close();}
}
为了更加深刻的了解UDP这个机制,我们来写一个循环聊天!(哈哈在此声明我一个很爱我的女朋友)【好好的聊天就因为我爱你结束了话题】
package demo04;import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
import java.util.Scanner;public class UDPClient {public static void main(String[] args) throws Exception {//首先我需要创建连接DatagramSocket datagramSocket = new DatagramSocket();//添加一个循环while (true){//模拟聊天环境//创建一个输入流InputStreamReader inputStreamReader = new InputStreamReader(System.in);//加上一个buffer缓冲区BufferedReader bufferedReader = new BufferedReader(inputStreamReader);//创建包byte[] datas = bufferedReader.readLine().getBytes();DatagramPacket datagramPacket = new DatagramPacket(datas,0,datas.length,new InetSocketAddress("localhost",9999));//发送包datagramSocket.send(datagramPacket);if (new String(datas).equals("我爱你")){break;}}//关闭资源datagramSocket.close();}
}
package demo04;import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;public class UDPServer {public static void main(String[] args) throws Exception {//创建端口DatagramSocket datagramSocket = new DatagramSocket(9999);//循环while (true){//创建容器byte[] contains = new byte[1024];DatagramPacket datagramPacket = new DatagramPacket(contains, 0, contains.length);//接受数据datagramSocket.receive(datagramPacket);//打印数据System.out.println("内容的地址:" + datagramPacket.getAddress().getHostName());System.out.println("内容:" + new String(datagramPacket.getData(),0,datagramPacket.getLength()));if (new String(datagramPacket.getData(),0,datagramPacket.getLength()).equals("我爱你")){break;}}//关闭资源datagramSocket.close();}
}