Socket 套接字/插座
在网络编程中所有的数据传递都是依赖于Socke来完成的，要求进行通信的两台计算机都要安装有Socket
不同的传输协议有不同的Socket
协议：
就是规定了签订协议的双方，必须遵从的事情
UDP的特点：
1. 把数据封装成一个数据包，面向无连接 就像（广播站 和 收音机）
2. UDP数据包大小限制在64KB以内
3. 因为是无连接，所以是不靠谱
4. 因为是无连接，所以传输速度快
5. UDP不区分服务端和客户端，只有发送端和接收端
UDP下的Socket使用:
DatagramSocket (); 获取UDP的Socket
DatagramPackage(byte[] buf, int length, InetAddress address, int port); UDP传输的数据包
buf:要打包的数据，要求数据类型是byte类型数组
length: 要打包数据的字节个数
address：发送目标地址的IP对象
port: 端口号
首先先写一下UDP下的发送端
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
public class UDPSender {
public static void main(String[] args) throws IOException {
//1. 建立UDP服务，打开UDP协议下的Socket，发送端Socket创建不需要任何参数
DatagramSocket socket = new DatagramSocket();
//2. 准备数据
String data = "今天冬至，大家记得吃饺子~~~";
//3. 数据打包
DatagramPacket packet = new DatagramPacket(data.getBytes(),
data.getBytes().lengt, InetAddress.getLocalHost(),8848);
//4. 通过Socket发送数据
socket.send(packet);
//5. 关闭资源
socket.close();
}
}
UDP接收端:
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
public class UDPReceive {
public static void main(String[] args) throws IOException {
//1. 建立UDP服务，监听端口
DatagramSocket socket = new DatagramSocket(8848);
//2. 准备空数据包，接收数据
byte[] buf = new byte[1024];
//利用byte数据创建空数据包
DatagramPacket packet = new DatagramPacket(buf, buf.length);
//3. 调用UDP服务，使用Socket接收数据
socket.receive(packet);
//4. 从数据包中获取Socket接收到的数据
//所有的数据都会被保存在byte数组中，然后可以通过调用UDP数据 包 的getLength方法，获取到
//接收到的数据字节长度
System.out.println(new String(buf, 0, packet.getLength()));
//5 关闭资源
socket.close();
}
}
TCP特点：
1. TCP是完全基于IO流进行数据传输的，面向连接 就像（qq 迅雷下载）
2. TCP进行数据传递没有显示数据包的大小
3. TCP面向连接，必须通过三次握手之后才能保证数据的传输通道是完整的
4. TCP面向连接，速度较慢
5. TCP是区分客户端和服务器
TCP协议下的Socket：
Socket(服务器IP地址对象, 服务器软件对应的端口号); 创建TCP协议下的客户端，并且申请连接服务器
ServerSocket() 服务器的"socket" 开始服务器服务，准备捕获Socket
因为tcp是不分发送接收端的所以创建客户端和服务端
TCP客户端
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress; import java.net.Socket;
public class TCPClient {
public static void main(String[] args) throws IOException {
//1. 建立客户端Socket，申请连接服务器
Socket socket = new Socket(InetAddress.getLocalHost(), 8000);
//2. 发送数据给服务器，需要获取Socket的输出流对象
OutputStream os = socket.getOutputStream();
// 使用OutputStream方法发送数据到服务器，也就是输出数据
os.write("你好，服务器".getBytes());
//3. 获取Socket的InputStream
InputStream is = socket.getInputStream();
byte[] buf = new byte[1024];
int length = is.read(buf);
System.out.println("服务器说:" + new String(buf, 0, length));
socket.close();
}
}
TCP服务端
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Demo1Server {
public static void main(String[] args) throws IOException {
//1. 使用ServerSocket开始TCP服务器，监听指定端口，准备捕获从客户端申请Socket连接
ServerSocket serverSocket = new ServerSocket(8000);
//2. 接受客户端连接，得到客户端的Socket对象
Socket socket = serverSocket.accept();
//3. 获取从客户端得到的Socket对象的输入流
InputStream is = socket.getInputStream();
byte[] buf = new byte[1024];
int length = is.read(buf);
System.out.println("客户端说:" + new String(buf, 0, length));
//4. 获取Socket的输出流对象，给客户端发送数据
OutputStream os = socket.getOutputStream();
os.write("你好，客户端".getBytes());
//关闭ServerSocket。就是关闭TCP协议下的服务器程序
serverSocket.close();
}
}
网友评论