Socket，即套接字，是一个对 TCP/IP 协议进行封装的编程调用接口（API）。
- 位于传输层，是网络上的两个程序通过一个双向的通信连接实现数据交换的一种进程通信方式之一。
- 成对出现，一对套接字。
Android与服务器的通信方式主要有两种，一是Http通信，一是Socket通信。两者的最大差异在于，Http连接使用的是“请求—响应方式”，即在请求时建立连接通道，当客户端向服务器发送请求后，服务器端才能向客户端返回数据。而Socket通信则是在双方建立起连接后就可以直接进行数据的传输，在连接时可实现信息的主动推送，而不需要每次由客户端向服务器发送请求。
简单来说，Socket提供了程序内部与外界通信的端口并为通信双方的提供了数据传输通道。
分类
TCP/IP协议族中，Socket主要分为流套接字（StreamSocket）和数据报套接字（DatagramSocket）：
- 流套接字将TCP作为其端对端协议，提供可信赖的字节流服务。
- 数据报套接字使用UDP协议，提供数据打包发送服务。
Socket在JAVA中的简单实现
以TCP为例。
使用步骤
客户端
- 创建Socket对象，指定成对的服务端IP地址和端口号。
- 通过Socket获取输出流，写入数据发给服务端。
- 通过Socket获取输入流，接受服务端的发送的数据。
- 关闭资源close。
服务端
- 创建ServerSocket对象，并指定端口号，其端口号必须与客户端一致。
- 通过ServerSocket对象，获取客户端的Socket实例（ServerSocket.accept()方法）。
- 通过Socket获取输入流，接受客户端发来的消息。
- 通过Socket获取输出流，写入数据向客户端发送数据作为回应。
- 关闭资源close。
Socket在Android中
基于TCP协议
- 服务器端首先声明一个ServerSocket对象并指定监听的端口号。调用ServerSocket的accept()方法接收客户端的数据。accept()方法在没有数据进行接收时处于阻塞状态。
// 创建一个ServerSocket对象，指定端口为7777
ServerSocket serverSocket = new ServerSocket(7777);
// 调用ServerSocket的accept()方法，接受客户端所发送的请求
// 如果客户端没有发送数据，那么该线程就停滞不继续
Socket socket = serverSocket.accept();
- 一旦接收到数据，通过InputStream读取接收的数据。
// 从Socket当中得到InputStream对象
InputStream inputStream = socket.getInputStream();
byte buffer[] = new byte[1024 * 4];
int temp = 0;
// 从InputStream当中读取客户端所发送的数据
while ((temp = inputStream.read(buffer)) != -1) {
System.out.println(new String(buffer, 0, temp));
}
- 客户端创建一个Socket对象，指定服务端的IP和端口号，通过InputSream读取数据，获取服务器发出的数据。
// 创建一个Socket对象，并指定服务端的IP及端口号
Socket socket = new Socket(ip, 7777);
// 创建一个InputStream用户读取要发送的文件
InputStream inputStream = new FileInputStream("xxx");
- 最后将要发送的数据写入到OutputStream，即可进行TCP协议的Socket数据传输。
// 获取Socket的OutputStream对象用于发送数据。
OutputStream outputStream = socket.getOutputStream();
// 创建一个byte类型的buffer字节数组，用于存放读取的本地文件
byte buffer[] = new byte[4 * 1024];
int temp = 0;
// 循环读取文件
while ((temp = inputStream.read(buffer)) != -1) {
// 把数据写入到OuputStream对象中
outputStream.write(buffer, 0, temp);
}
// 发送读取的数据到服务端
outputStream.flush();
基于UDP协议
- 服务器端首先创建一个DatagramSocket对象，并指定监听的端口号。创建一个空的DatagramSocket对象用于接收数据（byte[] data=new byte[1024]; DatagramSocket socket=new DatagramSocket(data, data.length)），使用DatagramSocket的receive()方法接收客户端发送的数据。receive()与ServerSocket.accept()类似，在没有数据进行接收时处于阻塞状态。
DatagramSocket socket;
try {
// 创建DatagramSocket对象并指定一个端口号，
// 注意：如果客户端需要接收服务器的返回数据, 还需要使用这个端口号来receive
socket = new DatagramSocket(1985);
// 使用InetAddress(Inet4Address).getByName把IP地址转换为网络地址
InetAddress serverAddress = InetAddress.getByName("192.168.1.32");
// Inet4Address serverAddress = (Inet4Address) Inet4Address.getByName("192.168.1.32");
// 设置要发送的报文
String str = "[2143213;21343fjks;213]";
// 把字符串str字符串转换为字节数组
byte data[] = str.getBytes();
// 创建一个DatagramPacket对象，用于发送数据。
// 参数一：要发送的数据，参数二：数据的长度，参数三：服务端的网络地址，参数四：服务器端端口号
DatagramPacket packet = new DatagramPacket(data, data.length, serverAddress, 10025);
// 把数据发送到服务端。
socket.send(packet);
} catch (SocketException e) {
e.printStackTrace();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
- 客户端也创建一个DatagramSocket对象，并指定端口。创建一个InetAddress对象，该对象类似于一个网络的发送地址（InetAddress ia=InetAddress.getByName(ip)），定义要发送的字符串，创建一个DatagramPacket对象，并指定要将该数据包发送到网络的哪个IP及端口号，最后使用DatagramSocket的send()方法发送数据。（String str="hello"; byte[] data=str.getByte(); DatagramPacket packet=new DatagramPacket(data, data.length, serveraddress, port); socket.send(packet);）
DatagramSocket socket;
try {
// 实例化的端口号要和发送时的socket一致，否则收不到data
socket = new DatagramSocket(1985);
byte data[] = new byte[4 * 1024];
// 参数一:要接受的data，参数二：data的长度
DatagramPacket packet = new DatagramPacket(data, data.length);
socket.receive(packet);
// 把接收到的data转换为String字符串
String result = new String(packet.getData(), packet.getOffset(), packet.getLength());
// 不使用了记得要关闭
socket.close();
System.out.println("the number of reveived Socket is :" + flag
+ "udpData:" + result);
} catch (SocketException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
网友评论