当前位置: 首页 > news >正文

扬中做网站的公司竞价排名是什么

扬中做网站的公司,竞价排名是什么,学校招办网站怎么做,网站如何做a b测试目录 基本概念 发送端与接收端 请求与响应 ​编辑客户端与服务器 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)中,接收指定长度(第二个参数
length)
DatagramPacket(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){//解析请求,看看要做什么//这里就做一个英汉翻译吧HashMap<String,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){HashMap<String,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();}
}

服务器打印:

 

客户端打印:

 

 


 

http://www.hkea.cn/news/839414/

相关文章:

  • 怎么做网站系统深圳头条新闻
  • 北京网站设计公司新鸿儒seo公司的选上海百首网络
  • 百姓网二手拖拉机百度seo优化排名客服电话
  • 北京南站是丰台站吗seo优化什么意思
  • 外贸营销型建站关键词全网搜索工具
  • 有什么网站可以做扣扣头像腾讯企点app下载安装
  • 网站设计怎么做链接拉新推广怎么快速拉人
  • 怎么自己做礼品网站补肾壮阳吃什么药效果好
  • 网站用户建设的设计与实现网站推广营销运营方式
  • html5韩国网站模板seo网站优化培训班
  • 网站被iframe信息推广的方式有哪些
  • 通信技术公司网站建设app推广代理
  • 做电影网站会违法吗营销说白了就是干什么的
  • 用外链技术做视频网站关键词在线听免费
  • 做网站常用的css最近三天的新闻热点
  • 全国人大常委会副委员长登封seo公司
  • 顶岗实践网站开发推广管理
  • 九号公司网站优化效果
  • 模板网站建设方案北京seo排名收费
  • 做箱包关注哪个网站泰州seo平台
  • 如何给网站做流量站长工具seo
  • 桂林网站开发建设推广任务接单平台
  • 化妆品 网站建设案例seo超级外链工具免费
  • 网站建设的广告语seo自动工具
  • 有专门做市场分析的网站么太原关键词优化报价
  • 网站文化建设搜索引擎推广的常见形式有
  • wordpress分类目录消失泸州网站seo
  • 易云巢做网站公司seo入门到精通
  • 新津网站建设百度ai助手入口
  • 做学校网站什么文案容易上热门