网站排名优化软件有哪些,百度企业云网站建设,网站飘动,广州白云区今天最新消息目录
基本概念
发送端与接收端
请求与响应
编辑客户端与服务器
Socket套接字
分类
数据报套接字
流套接字传输模型
UDP数据报套接字编程
DatagramSocket API
DatagramPacket API
InetSocketAddress API
示例一:
示例二:
TCP流数据报套接字编程
ServerSock…目录
基本概念
发送端与接收端
请求与响应
编辑客户端与服务器
Socket套接字
分类
数据报套接字
流套接字传输模型
UDP数据报套接字编程
DatagramSocket API
DatagramPacket API
InetSocketAddress API
示例一:
示例二:
TCP流数据报套接字编程
ServerSocket API
Socket API
示例一: 网络编程指的是,网络上的主机的不同进程通过编程的方式实现网络通信.同一主机下只要满足不同进程间的通信就可以成为网络通信
基本概念
发送端与接收端
在网络通信中:
作为发送数据的进程称为发送端,发送端主机即网络通信中的源主机
作为接收数据的进程称为接收端,接收端主机即网络通信中的目的主机
注意:网络通信中的发送端与接收端都是相对的. 请求与响应
一般来说,一次网络通信中设计到两次数据传输:
第一次:A端向B端发送的请求第二次:B端向A端发送的响应
客户端与服务器
服务器:在网络通信下,提供服务的一端.(服务可以指:响应一定的要求)
客户端:获取服务的一端 Socket套接字
Socket套接字是由系统提供用于网络通信的技术,是基于TCP/IP协议的网络通信的基本操作单元.基于Socket套接字的网络程序开发就是网络编程.
分类
套接字根据传输层协议主要分成:
数据报套接字:使用传输层UDP协议(User Datagram Protocol)用户数据报协议流套接字:使用传输层TCP协议(Transmission Control Protocol)传输层控制协议原始套接字:用于自定义传输层协议 数据报套接字
数据报固定每次传输的字节,更像是写信,有来有回的. 流套接字传输模型
面对的是字节流.
打电话一般,接通后就可以无节制的传输. UDP数据报套接字编程
DatagramSocket API
构造方法
方法签名方法说明DatagramSocket()创建一个UDP数据报套接字的Socket绑定到本机任意一个随机端口 一般用于客户端DatagramSocket(int port)创建一个UDP数据报套接字的Socket绑定到本机指定的端口一般用 于服务端
常用方法
方法方法说明void receive(DatagramPacket p)从此套接字接收数据报如果没有接收到数据报该方法会阻 塞等待void send(DatagramPacket p)从此套接字发送数据报包不会阻塞等待直接发送void close()关闭此数据报套接字
DatagramPacket API
构造方法
方法签名方法说明DatagramPacket(byte[] buf, int length)构造一个DatagramPacket以用来接收数据报接收的数据保存在 字节数组第一个参数buf中接收指定长度第二个参数 lengthDatagramPacket(byte[] buf, int length, SocketAddress address)构造一个DatagramPacket以用来发送数据报发送的数据为字节 数组第一个参数buf中从0到指定长度第二个参数 length。address指定目的主机的IP和端口号
常用方法
方法签名方法说明InetAddress getAddress()从接收的数据报中获取发送端主机IP地址或从发送的数据报中获取 接收端主机IP地址int getPort()从接收的数据报中获取发送端主机的端口号或从发送的数据报中获 取接收端主机端口号byte[] getData()获取数据报中的数据
InetSocketAddress API
InetSocketAddress是ScketAddress的一个子类,用来包装IP与端口号
方法方法说明InetSocketAddress(InetAddress addr, int port)创建一个Socket地址包含IP地址和端口号 示例一:
客户端像服务器发出请求,但服务器无响应版本
服务器:
public class UdpServer {private DatagramSocket socket null;public UdpServer(int port) throws SocketException {//构造方法this.socket new DatagramSocket(port);}public void start() throws IOException {//作为启动服务器的方法while(true){//因为不知道什么时候客户端会发送请求//作为服务器,需要不停的接收客户端的请求//创建packetbyte[] bytes new byte[1024];DatagramPacket packet new DatagramPacket(bytes,bytes.length);//用bytes作为接收,使用的长度为bytes的长度System.out.println(等待接收数据中...);socket.receive(packet);//还没收到之前会进行阻塞等待//此处的版本没有作出响应//我们可以打印出收到的packet中的数据看看有什么东西System.out.println(IP: packet.getAddress().getHostAddress());System.out.println(端口号: packet.getPort());System.out.printf(文本数据为: new String(packet.getData()));System.out.println(原始数据为: Arrays.toString(packet.getData()));}}public static void main(String[] args) throws IOException {UdpServer udpServer new UdpServer(1024);udpServer.start();}
}
客户端:
方法一:
public class UdpClient {public static void main(String[] args) throws IOException {//创建SocketDatagramSocket socket new DatagramSocket();//创建一个socket,端口号为系统随机分配//构建Packetbyte[] bytes Hello World.getBytes();//字符串转换成byte再塞进数组SocketAddress address new InetSocketAddress(localhost,1024);//目的IP为本地地址,端口号为1024DatagramPacket packet new DatagramPacket(bytes,bytes.length,address);//构建packetsocket.send(packet);//发送System.out.println(发送完成);}
}
方法二:
public class UdpClient {private DatagramSocket socket null;//socketprivate String serverIp;private int serverPort;public UdpClient(String serverIp,int serverPort) throws SocketException {this.socket new DatagramSocket();this.serverIp serverIp;this.serverPort serverPort;}public void start() throws IOException {System.out.println(客户端启动);Scanner scanner new Scanner(System.in);while(true){System.out.println(输入:);String text scanner.next();if(text.equals(exit)){System.out.println(再见);break;}//需要用InetAddress将字符串钟的IP转换成地址形式//SocketAddress address new InetSocketAddress(localhost,1024);//也可以创建一个实例进行包装IP与端口号//此处的长度是字节的长度噢,注意单位DatagramPacket packet new DatagramPacket(text.getBytes(),text.getBytes().length,InetAddress.getByName(serverIp),serverPort);socket.send(packet);System.out.println(发送成功);}}public static void main(String[] args) throws IOException {UdpClient client new UdpClient(127.0.0.1,1024);client.start();}
先启动服务器后启动客户端发送.
记得打开IDEA可以同时运行两个进程的选项噢!
服务器接收到的信息为: 示例二:
做一个服务器对客户端有响应的版本
简单的英汉翻译
服务器:
public class UdpServerResponse{private DatagramSocket socket null;public UdpServerResponse(int port) throws SocketException {//构造方法this.socket new DatagramSocket(port);}public void start() throws IOException {//启动服务器while(true){byte[] bytes new byte[1024];DatagramPacket receivePacket new DatagramPacket(bytes,bytes.length);//创建包来接收System.out.println(等待接收数据中...);socket.receive(receivePacket);//接收包String request new String(receivePacket.getData(),0,receivePacket.getLength());//根据接收到的包转换成字符串String response process(request);//对请求进行分析//记得是getSocketAddress噢里面通常包含了IP与端口号DatagramPacket sendPacket new DatagramPacket(response.getBytes(),response.getBytes().length,receivePacket.getSocketAddress());socket.send(sendPacket);//对客户端作出响应System.out.println(客户端IP: receivePacket.getAddress());System.out.println(客户端端口号: receivePacket.getPort());System.out.println(收到的文本: request);System.out.println(返回的文本: response);}}public String process(String request){//解析请求,看看要做什么//这里就做一个英汉翻译吧HashMapString,String map new HashMap();map.put(人,human);map.put(猫,cat);map.put(狗,dog);return map.getOrDefault(request,查阅失败);}public static void main(String[] args) throws IOException {UdpServerResponse udpServerResponse new UdpServerResponse(1024);udpServerResponse.start();}
}
客户端:
public class UdpClientResponse {private DatagramSocket socket null;private String serverIp;private int serverPort;public UdpClientResponse(String serverIp,int serverPort) throws SocketException {this.serverIp serverIp;this.serverPort serverPort;socket new DatagramSocket();}public void start() throws IOException {System.out.println(客户端启动);Scanner scanner new Scanner(System.in);while (true) {System.out.print(输入: );String request scanner.next();if(request.equals(exit)){System.out.println(再见!);break;}//根据请求创建包DatagramPacket sendPacket new DatagramPacket(request.getBytes(),request.getBytes().length, InetAddress.getByName(127.0.0.1),1024);socket.send(sendPacket);System.out.println(发送成功);DatagramPacket receivePacket new DatagramPacket(new byte[1024],1024);//创建接收包socket.receive(receivePacket);String receive new String(receivePacket.getData(),0,receivePacket.getLength());System.out.println(receive);}}public static void main(String[] args) throws IOException {UdpClientResponse udpClientResponse new UdpClientResponse(127.0.0.1,1024);udpClientResponse.start();}
}
服务器的打印 客户端的打印 TCP流数据报套接字编程
ServerSocket API
创建TCP服务端的API
构造方法
构造方法方法说明ServerSocket(int port)创建一个服务端流套接字Socket并绑定到指定端口
方法
方法签 名方法说明Socket accept()开始监听指定端口创建时绑定的端口有客户端连接后返回一个服务端Socket 对象并基于该Socket建立与客户端的连接否则阻塞等待void close()关闭此套接字
Socket API
用来建立链接后保存对方的信息
构造方法:
方法方法说明Socket(String host, int port)创建一个客户端流套接字Socket并与对应IP的主机上对应端口的 进程建立连接
常用方法
方法签名方法说明InetAddress getInetAddress()返回套接字所连接的地址InputStream getInputStream()返回此套接字的输入流OutputStream getOutputStream()返回此套接字的输出流
在TCP协议中的连接还分为长连接与短链接.
短连接每次接收到数据并返回响应后都关闭连接即是短连接。也就是说短连接只能一次收发数据长连接不关闭连接一直保持连接状态双方不停的收发数据即是长连接。也就是说长连接可以多次收发数据
示例一:
一请求一响应
此处为长连接(把代码里的while(true)去掉就是短连接啦!只进行一次请求响应)
服务器:
对于服务器来说,每次与客户端连接后会创建一个socket来暂时存储客户端的信息数据
断开连接后,记得要将这个存储客户端数据的socket进行close释放掉
在服务器进程中,一个客户端socket会占用文件描述符的一个位置,一个服务器可能会要与成千上万个客户端进行通信,不释放就会将文件描述符的位置沾满造成泄露.
而服务器的serverSocket的生命周期与整个进程相当,且只有一个.所以可以不进行释放
使用线程池,用多线程的方式来运行服务器达到同时与多个客户端进行通信的功能.
public class TcpServer {private ServerSocket socket null;public TcpServer(int port) throws IOException {socket new ServerSocket(port);}public void start() throws IOException {//尝试链接ExecutorService threadPool Executors.newCachedThreadPool();//创建一个线程池,一个线程对应一个客户端进行通信while (true) {Socket clientSocket socket.accept();//会阻塞等待接受threadPool.submit(() - {//向线程提供任务try {processConnect(clientSocket);} catch (IOException e) {e.printStackTrace();}});}}public void processConnect(Socket clientSocket) throws IOException {System.out.println(已与客户端进行链接- clientSocket.getInetAddress() clientSocket.getPort());try(InputStream inputStream clientSocket.getInputStream();OutputStream outputStream clientSocket.getOutputStream()){while(true){Scanner scanner new Scanner(inputStream);//读PrintWriter printWriter new PrintWriter(outputStream);//写if(!scanner.hasNext()){//客户端不再传输数据就断开链接System.out.println(结束);break;}String request scanner.next();//接收请求String response process(request);//处理请求printWriter.println(response);//向客户端写回响应printWriter.flush();//记得写回后进行刷新缓冲区System.out.println(响应: clientSocket.getInetAddress() clientSocket.getPort() 文本: response);}} catch (IOException e) {e.printStackTrace();}finally {clientSocket.close();//记得要关闭}}public String process(String request){HashMapString,String map new HashMap();map.put(人,human);map.put(猫,cat);map.put(狗,dog);return map.getOrDefault(request,查阅失败);}public static void main(String[] args) throws IOException {TcpServer tcpServer new TcpServer(1024);tcpServer.start();}
}
客户端:
public class TcpClient {private Socket socket null;private String serverIp;private int serverPort;public TcpClient(String serverIp,int serverPort) throws IOException {socket new Socket(serverIp,serverPort);//客户端随机分配端口号this.serverIp serverIp;this.serverPort serverPort;}public void start(){try(InputStream inputStream socket.getInputStream();OutputStream outputStream socket.getOutputStream()) {//创建流对象进行写与读while(true){Scanner scanner new Scanner(System.in);//用来写入PrintWriter printWriter new PrintWriter(outputStream);//包装output流对象String request scanner.next();//写请求if(request.equals(exit)){System.out.println(结束与服务器连接);break;}//把请求放到流对象中写出去printWriter.println(request);printWriter.flush();//刷新缓冲区Scanner responseScanner new Scanner(inputStream);String response responseScanner.next();//读服务器的响应System.out.println(response);}} catch (IOException e) {e.printStackTrace();}}public static void main(String[] args) throws IOException {TcpClient tcpClient new TcpClient(127.0.0.1,1024);tcpClient.start();}
}
服务器打印: 客户端打印:
