网络编程
TCP程序
1.ServerSocket 搭建服务器 2.Socket 搭建客户端 两方使用socket(套接字 , 通信端点) 进行交流
ServerSocket
用于创建服务器 . 创建完毕后, 会绑定一个端口号. 每连接一个客户端 , 服务器就会得到一个新的Socket对象, 用于跟客户端进行通信
构造方法
ServerSocket(int port); 创建一个基于TCP/IP协议的服务器 , 并绑定指定的端口号. 注意: 参数port的范围是: 0-65535 (建议1025-65535)
常用方法
Socket accept(); 等待客户端连接 此方法会导致线程的阻塞! 直到一个新的客户端连接成功, return Socket对象后, 线程在继续执行 void close(); 释放占用的端口号 , 关闭服务器.
public static void main(String[] args) throws IOException {???
//搭建???
ServerSocket server = new ServerSocket(55565);???
//等待客户端连接??? 只有连接了才会继续
Socket socket = server.accept();???
System.out.println("服务器连接了");
}
Sokect
是两台计算机之间通信的端点 , 是网络驱动提供给应用程序编程的一种接口 一套标准, 一种机制
构造方法
Socket(String ip,int port) 创建一个套接字, 并连接指定ip和端口号的 服务器. 参数1. 服务器的ip地址 参数2. 服务器软件的端口号…
Socket client = new Socket("127.0.0.1",55565);
常用方法
-
OutputStream getOutputStream(); 返回的是 , 指向通信的另一端点的输出流 -
InputStream getInputStream(); 返回的是 , 指向通信的另一端点的输入流
- 注意:
在网络编程时, 获取输入输出流的操作 ,对于客户端与服务器来说是相对的 客户端与服务器获取流的顺序必须是相反的:
例如: 客户端先得到了输入流 , 那服务器必须先获取输出流
实例
服务器代码
public static void main(String[] args) throws IOException {??
//搭建???
ServerSocket server = new ServerSocket(55565);??
//等待客户端连接???
Socket socket = server.accept();???
System.out.println("服务器连接了");???
OutputStream os = socket.getOutputStream();??
PrintStream ps = new PrintStream(os);???
ps.println("欢迎你连接到服务器");???
InputStream is = socket.getInputStream();???
BufferedReader br = new BufferedReader(new InputStreamReader(is));???
String text = br.readLine();???
System.out.println("从客户端收到了:"+text);}
客户端代码
public static void main(String[] args) throws IOException {??
Socket client = new Socket("127.0.0.1",55565);???
InputStream is = client.getInputStream();???
BufferedReader br = new BufferedReader(new InputStreamReader(is));???
String text = br.readLine();???
System.out.println("从服务器接收到了:"+text);???
OutputStream os = client.getOutputStream();???
PrintStream ps = new PrintStream(os);???
ps.println("服务器你好");}
显示内容
- 服务器:
服务器连接了 从客户端收到了:服务器你好 - 客户端:
从服务器接收到了:欢迎你连接到服务器
在服务器中加入多线程
ServerSocket server = new ServerSocket(55565);
//等待客户端连接
while(true){???
Socket socket = server.accept();???
new Thread(){???????
@Override???????
public void run(){??????
try {???????????????
InputStream is = socket.getInputStream();???
OutputStream os = socket.getOutputStream();???????
} catch (IOException e) {??
e.printStackTrace();???????????
}???????
}???
}.start();???
Thread.sleep(1000);???
System.out.println("一个客户端连接了");}
UDP协议(数据报)程序(了解)
数据报套接字: DatagramSocket
用于发送 与 接收数据包的Socket
- DatagramSocket(int port);
- 参数: 端口号
- close() : 关闭套接字
- send(DatagramPacket dp) 将一个数据包dp 发送出去
- receive(DatagramPacket dp) 接收一个数据包, 并存储到参数dp中.
数据包 DatagramPacket
用于发送或接收数据时, 盛放数据的对象!
构造方法:
1.用于发送数据时, 组装数据的 构造方法. DatagramPacket(byte[] bytes,int startIndex,int len,InetAddress ip,int port);
- InetAddress ip = InetAddress.getByName(“192.168.102.228”);
- 参数5. 当前这个数据包, 准备发送到目标计算机的哪个端口号.
2.用于接收数据时, 存储数据的 构造方法. 创建的是 不包含数据的数据包, 用于在接收到数据后, 存储数据 ! DatagramPacket(byte[] bytes,int len)
- 参数1. 用于存储数据的 数组
- 参数2. 允许存储的最大长度
- 常用方法:
byte[] getData() 用于获取数据包中的有效字节数组 int getLength 用于获取数据包中的有效数据的长度.
InetAddress 描述IP地址的类
InetAddress 用于描述IP
InetAddress ip = InetAddress.getByName(“192.168.102.228”);
- 在UDP协议中. 通过数据包DatagramPacket的getAddress方法, 可以得到数据包来自哪个ip
- 在TCP协议中, 通过套接字Socket的getInetAddress方法, 可以得到套接字连接的ip地址.
- 常用方法:
1.String getHostAddress() ip地址字符串 2.String getHostName() 计算机名称, 当名称无法获取时, 获取的为ip地址.
|