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.创建对象ServerSocker
ServerSocket 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();
}
