Socket:
简单地说Socket就相当于是一家快递公司包括:
寄件人:
1.包裹放快递盒里(数据打包:DatagramSocket)
2.运输快递(发送数据)
3.付钱回家(释放资源)
收件人:
1.收到包裹(接受数据)
2.打开包裹(解析数据)
UDP和Socket:
基于UDP协议的sokect实现发送数据:
package Text;import java.io.IOException;
import java.net.*;public class Test01UDP {public static void main(String[] args) throws IOException {//发送数据//1.创建DatagramSocket对象//细节://绑定端口:通过这个端口往外发送//空参:所有可用的端口号中随机一个进行使用//有参:指定端口号进行绑定DatagramSocket datagramSocket = new DatagramSocket();//2.打包数据String str = "好帅啊小哥哥";//把数据放数组里面byte[] bytes = str.getBytes();//确定发送地址InetAddress address = InetAddress.getByName("127.0.0.1");//端口号的作用是指定数据报包要发送到的目标端口。不是我的发送端口int port = 10086;DatagramPacket datagramPacket = new DatagramPacket(bytes,bytes.length,address,port);//发送数据datagramSocket.send(datagramPacket);datagramSocket.close();}
}
接收数据:
注意:一定要先运行接收方, 在 UDP 通信中,接收方需要在指定的端口上监听和等待数据包。如果接收方没有启动并且没有监听该端口,发送方发送的数据包将无法到达任何地方,因为没有程序在接收这些数据包。
public static void main(String[] args) throws IOException {//创建快递公司对象DatagramSocket ds = new DatagramSocket(10086);//接收数据包byte[] bytes = new byte[1024];DatagramPacket dp = new DatagramPacket(bytes,bytes.length);//这个recive是一个阻塞方法,它会等到接收后才会继续运行ds.receive(dp);//3.解析数据包byte[] data = dp.getData();int len = dp.getLength();InetAddress address = dp.getAddress();int port = dp.getPort();System.out.println("接收到数据"+new String(data,0,len));System.out.println("该数据是从"+address+"这台电脑中的"+port+"这个端口发出的");//4.释放资源,关闭快递公司ds.close();}
}
UDP聊天室:循环的发送字
当输入886的时候就结束会话,否则就一直可以发送,并且支持多人
注意:
我没找到那个允许运行多次的选项,在编辑设置里面,所以只能发送方不能重复运行
直到发送的数字为886结束。
每次调用 ds.receive(dp)
时,DatagramSocket
会将接收到的数据写入到 dp
的 bytes
数组中。所以不用把这个byte数组也放到循环中
发送端:
package Chatting;import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;public class Test01UDP {public static void main(String[] args) throws IOException {//发送数据//1.创建DatagramSocket对象//细节://绑定端口:通过这个端口往外发送//空参:所有可用的端口号中随机一个进行使用//有参:指定端口号进行绑定DatagramSocket datagramSocket = new DatagramSocket();//2.打包数据Scanner scanner = new Scanner(System.in);while (true){System.out.println("请输入您要说的话");String str = scanner.nextLine();if ("886".equals(str)){break;}//把数据放数组里面byte[] bytes = str.getBytes();//确定发送地址InetAddress address = InetAddress.getByName("127.0.0.1");//端口号的作用是指定数据报包要发送到的目标端口。不是我的发送端口int port = 10086;DatagramPacket datagramPacket = new DatagramPacket(bytes,bytes.length,address,port);//发送数据datagramSocket.send(datagramPacket);}datagramSocket.close();}
}
接收端:
package Chatting;import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;public class Test02Recive {public static void main(String[] args) throws IOException {//创建快递公司对象DatagramSocket ds = new DatagramSocket(10086);//接收数据包byte[] bytes = new byte[1024];DatagramPacket dp = new DatagramPacket(bytes,bytes.length);while (true){//这个recive是一个阻塞方法,它会等到接收后才会继续运行ds.receive(dp);//3.解析数据包byte[] data = dp.getData();int len = dp.getLength();InetAddress address = dp.getAddress();int port = dp.getPort();System.out.println("接收到数据"+new String(data,0,len));System.out.println("该数据是从"+address+"这台电脑中的"+port+"这个端口发出的");}}
}
UDP的三种通信方式:
1.单播
2.组播
组播地址:224.0.0.0-239.255.255.255
其中224.0.0.0-224.0.255为预留的组播地址
3.广播
广播地址:255.255.255.255
TCP的通信:
TCP通信协议是一种可靠的网络协议,它在通信的两端各建立一个Socket对象,通信之前要保证连接已建立。
通过Socket产生I/O流来进行网络通信。
发送端:
public static void main(String[] args) throws IOException {//发送端,发送数据//1.创建Socket对象//细节:在创建对象的同时会连接服务器//如果连不上,代码会报错Socket socket = new Socket("127.0.0.1",10001);//可以从连接通道中获取输出流OutputStream outputStream = socket.getOutputStream();//写出数据outputStream.write("chenmengyu".getBytes());//释放资源outputStream.close();socket.close();}
接收端:
public static void main(String[] args) throws IOException {//TCP协议,接收数据//1.创建对象ServerSockerServerSocket ss = new ServerSocket(10001);//2.监听客户端的连接Socket s = ss.accept();//3.从连接通道中获取输入流读取数据InputStream inputStream = s.getInputStream();int b;while ((b = inputStream.read())!=-1){System.out.println((char)b);}//4.释放资源s.close();ss.close();}