套接字是java提供一套进行网络通信的API---TCP/UDP;
ISO七层模型
物理层 、数据链路层 、传输层-IP、 网络层-UDP/TCP 、会话层 、 表示层、 应用层 ---HTTP FTP POP3 SMTP...
IP地址:在网络中标识计算机地址的---IPv4---用四组整数(0-255)标识一个IP地址---123.125.43.11---IPv6
端口号: 用于指定接收或者发送消息的端口---0-65535---0-1024被计算机内部占用
UDP
基于流的,不需要建立连接,不可靠,会对数据进行封包,每个包是64k大小,传输效率是比较高。例如直播
java提供了一套套接字用于UDP通信:
1.InetSocketAddress("IP地址",端口号):表示IP地址和端口号;
2.DatgramSocket():用来发送和接收数据包的套接字;
3.DatagramPacket(byte[] buf, int length, SocketAddress address):用来对数据封包,以便传输;
发送端基本步骤:
1.创建发送数据套接字对象;
2.创建目的地的IP地址和发送端口;
3.将数据封包;
4.发送(send(DatagramPacket dp)方法);
5.关闭套接字(close());
接收端基本步骤:
1.创建接收数据的套接字对象并绑定接收数据的端口;
2.创建数据封包用来储存数据;
3.接收数据(receive(DatagramPacket dp));
4.关闭套接字(close());
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.util.Scanner; public class UDPChatDemo { public static void main(String[] args) { new Thread(new Sender()).start();
new Thread(new Receiver()).start();
} } // 发送端
class Sender implements Runnable { @SuppressWarnings("resource")
@Override
public void run() { try {
// 准备套接字对象
DatagramSocket ds = new DatagramSocket(); // 创建一个地址对象
InetSocketAddress isa = new InetSocketAddress("localhost", 9527); // 从控制台来获取数据
Scanner s = new Scanner(System.in); while (true) {
String msg = s.nextLine(); // 将数据封包
DatagramPacket dp = new DatagramPacket(msg.getBytes(), msg.getBytes().length, isa); // 发送数据
ds.send(dp); // 判断这个语句是否是exit
if (msg == "exit" || msg != null && msg.equals("exit")) {
break;
}
} } catch (Exception e) {
e.printStackTrace();
} } } class Receiver implements Runnable { @SuppressWarnings("resource")
@Override
public void run() { try {
// 准备套接字对象,绑定端口号
DatagramSocket ds = new DatagramSocket(9527); // 准备数据包
DatagramPacket dp = new DatagramPacket(new byte[1024], 1024); while (true) { // 接收数据
ds.receive(dp); // 获取数据
String msg = new String(dp.getData(), 0, dp.getLength());
if (msg == "exit" || msg != null && msg.equals("exit")) {
break;
} // 获取地址
System.out.print(dp.getAddress() + ":");
System.out.println(msg);
} } catch (Exception e) {
e.printStackTrace();
} } }
TCP
基于流的,需要建立连接,经过了三次握手,理论上不限制数据的大小,传输速率比较低。例如文件的传输
java提供的套接字:
Socket:客户端套接字
ServerSocket:服务器端套接字
客户端基本步骤:
1.创建客户端套接字对象;
2.发起连接,并绑定连接地址;
3.获取输出流,写出数据;
4.通知服务器端数据写出完毕;
5.关闭套接字
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.Socket; public class TCPClientDemo2 { public static void main(String[] args) throws Exception { // 创建客户端的套接字
Socket s = new Socket(); // 发起连接,绑定端口号
s.connect(new InetSocketAddress("localhost", 8980)); // 获取输出流
OutputStream out = s.getOutputStream(); // 写出数据
out.write("我来啦啦啦~~~".getBytes()); // 关闭输出流
s.shutdownOutput(); // 获取输入流
InputStream in = s.getInputStream(); // 读取数据
byte[] bs = new byte[1024];
int len = -1;
while ((len = in.read(bs)) != -1) {
System.out.println(new String(bs, 0, len));
} // 通知服务器端数据已经读取完毕
s.shutdownInput(); // 关闭套接字
s.close(); } }
服务器端基本步骤:
1. 创建服务器端套接字,绑定端口号
2. 接受连接,获取到一个Socket对象
3. 获取输入流,读取数据
4. 通知客户端数据读取完毕
5. 关闭套接字
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket; public class TCPServerDemo { public static void main(String[] args) throws Exception { // 创建一个服务器端套接字对象---绑定端口号
ServerSocket ss = new ServerSocket(9999); // 接受连接
Socket s = ss.accept(); // 获取一个输入流
InputStream is = s.getInputStream(); // 读取数据
byte[] bs = new byte[1024];
int len = -1;
while ((len = is.read(bs)) != -1) {
System.out.println(new String(bs, 0, len));
} // 通知客户端数据读取完毕
s.shutdownInput(); // 关闭套接字
s.close();
ss.close(); } }
注意:receive/connect/accept/read/write都会产生阻塞