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();
}
}