tcp连接工具_基于Swoole如何搭建TCP服务,你掌握了吗?

本节将会讲解以下3个问题:

  • 通过Swoole如何搭建TCP服务?
  • 通过Swoole如何搭建TCP客户端?
  • 通过Swoole搭建的TCP服务,更深入理解Swoole的事件驱动模式

通过Swoole可以快速创建一个TCP服务,新建一个文件命名为 tcp_server.php,代码如下:

487bae3050bfab31e14da41f42e57eb3.png

tcp_server.php

在命令行执行如下命令就可以开启TCP服务:

php tcp_server.php

运行完命令后就可以通过 netstat 工具查看服务是否启动成功,如果已经在监听9501端口了,这时就可以使用 telnet/netcat 工具来连接服务器了。

telnet 127.0.0.1 9501helloServer: hello

netstat工具使用方法:netstat -an | grep 9501

代码逻辑分析:

通过以上代码就可以创建一个TCP服务,监听的端口是9501。它的逻辑很简单,当客户端$socket通过网络发送一个hello字符串时,服务器端会回复一个Server:hello字符串。

Server是异步服务器,所以是通过监听事件的方式来编写程序的。当对应的事件发生时,底层会主动回调指定的函数。如当有限的TCP连接金额入时,会执行 onConnect 事件回调,当某个连接向服务器发送数据时会回调 onReceive 函数。

注意事项:

  • 服务器可以同时被成千上万个客户端连接,$fd 就是客户端连接的唯一标识符
  • Receive 事件的回调函数中 $from_id 为线程ID
  • 调用 $srver->send() 方法向客户端连接发送数据,参数就是 $fd 柯达护短标识符
  • 调用 $server->close() 方法可以强制关闭某个客户端连接
  • 客户端可能会主动断开连接,此时会触发 onClose 事件回调

无法连接到服务器的简单检测手段:

  • 在linux下,使用 netstat -an | grep 端口,查看端口是否已经被打开处于Listening状态
  • 上一步确认后,再检查防火墙问题
  • 注意服务器所用的IP地址,如果是127.0.0.1回环地址,则客户端只能使用127.0.0.1才能连接上
  • 用的阿里云服务器或者腾讯云服务器,需要在安全权限组进行设置开发的端口

TCP服务已经启动,下面我们要用Swoole搭建TCP客户端来连接TCP服务。新建一个文件,命名为 tcp_client.php,代码如下:

523df192435a11e2deb9260ea76f748d.png

tcp_client.php

上面代码创建了一个TCP的同步客户端,此客户端用于连接 server.php 开启的TCP服务。向服务端发送一个 hello world 字符串,服务器会返回一个 Server:hello world 字符串。

在命令行运行如下命令就可以连接TCP服务:

php tcp_client.phpServer:hello world

这个客户端是同步阻塞的,connect/send/recv 会等待IO完成后再返回。同步阻塞操作并不消耗CPU资源。当IO操作未完成时,当前进程会自动转入 sleep 模式。当IO完成后,操作系统会唤醒当前进程,继续向下执行代码。

流程如下:

  • TCP需要进行3次握手,所以connect至少需要3次网络传输过程
  • 在发送少量数据时,$client->send 都是可以立即返回的。发送大量数据时,socket 缓冲区可能会塞满,send 操作会阻塞。
  • recv 操作会阻塞等待服务器返回数据,recv 耗时等于服务器处理时间+网络传输耗时之和。

TCP客户端还有一种异步非阻塞的实现形式。使用异步模式时,connect 会理解返回 true。但实际上连接并未建立。这时不能在 connect 后立即使用 send 发送数据,需要先通过isConnected() 判断是否连接成功。当连接成功后,系统会自动回调 onConnect 函数。这时才可以使用 send 函数向服务器发送数据。

通过上面的代码我们就实现了TCP服务端和客户端,当服务端和客户端建立TCP连接后,如何维持连接不断开呢?下面我们将介绍一下基于Swoole搭建的TCP服务器心跳维持方案。

正常情况下客户端中断TCP连接时,会发送一个FIN包,进行4次断开握手来通知服务器。但一些异常情况下,如客户端突然断电断网或者网络异常,服务器可能无法得知客户端已断开连接。尤其是移动网络,TCP连接非常不稳定,所以需要一套机制来保证服务器和客户端之间的连接的有效性。

Swoole扩展本身内置了这种机制,开发者只需要配置一个参数即可启用。Swool在每次收到客户端数据会记录一个时间戳,当客户端在一定时间内未向服务器端发送数据,那服务器会自动切断连接。

配置方法如下:

793b1c031b94fb52b47fd5bffeb630f6.png

上面的设置就是每5秒侦测一次心跳,一个TCP连接如果在10秒内未向服务器发送数据,连接将会被切断。

通过以上案例我们对Swoole的事件驱动模型有了一定的了解。下面我们将详细介绍Swoole的回调事件。

事件执行顺序

  • 所有事件回调均在 $server->start 后发生
  • 服务器关闭程序终止时最后一次事件是 onShutdown
  • 服务器启动成功后,onStart /onManagerStart / onWorkerStart 会在不同的进程内并发执行
  • onReceive / onConnect / onClose 在 Worker 进程中触发
  • Worker / Task 进程启动/结束时会分别调用一次 onWorkerStart / onWorkerStop
  • onTask 事件仅在 task 进程中发生
  • onFinish 事件仅在 Worker进程中发生

事件函数介绍

  • onStart
  • onShutdown
  • onWorkerStart
  • onWorkerStop
  • onWorkerExit
  • onConnect
  • onReceive
  • onPacket
  • onClose
  • onTask
  • onFinish
  • onPipeMessage
  • onWorkerError
  • onManagerStart
  • onManagerStop

作为web开发的佼佼者PHP并不逊色其他语言,加上swoole后更加是如虎添翼!进军通信 、物联网行业开发百度地图、百度订单中心等!年后更是霸占程序员招聘语言第二名,寒冬裁员期过后正是各大企业扩大招人的时期,现在市场初级程序员泛滥,进阶中高级程序员绝对是各大企业急需的人才,这套教程适合那些1-6年的PHP开发者进阶中高级提升自己,在金九银十中找到高薪职位!

020218df3de8ae8ef2a3121159605b5c.png

领取方式:点赞关注小编后私信【资料】获取资料领取方式!

部分资料展示:

23a829a0210d2ab135755ce035dece2e.gif
19a0465e6b145998a07c67fcaf378f35.gif
61fc384ef188e21c9e9ebbdbd1c33866.png
17365a1957a49f885653f2d6f04cc5fc.png
6abbf42ffbdd91c984db2b1ca6e32316.png

领取方式:点赞关注小编后私信【资料】获取资料领取方式!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/486317.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java date the type is ambiguous_一个java ambiguous method 的问题

前段时间读一些代码,其中包含了若干复杂的implemens和extends关系,居然在调用时出现了the method *** is ambiguous for the type *** . 一直以为java中没有多继承,正常的多态怎么会造成这种问题。请看下面的场景:public class Am…

当物联网实时工作时,城市才是“智能”的

文章原载于:千家网在智能交通、数据驱动的公共安全以及平台相关和数字孪生用例相关项目强劲增长的推动下,到2025年,全球在智慧城市倡议上的支出预计将达到3270亿美元。运营转型的前景令人振奋。如果城市正确地构建了这一点,它们将…

LINQ to SQL语句(1)之Where

Where操作 适用场景:实现过滤,查询等功能。 说明:与SQL命令中的Where作用相似,都是起到范围限定也就是过滤作用的 ,而判断条件就是它后面所接的子句。 Where操作包括3种形式,分别为简单形式、关系条件形式、…

复制给节点的命令_深入理解redis主从复制原理

1.复制过程从节点执行 slaveof 命令。 从节点只是保存了 slaveof 命令中主节点的信息,并没有立即发起复制。 从节点内部的定时任务发现有主节点的信息,开始使用 socket 连接主节点。 连接建立成功后,发送 ping 命令,…

php封装webservice_四种php中webservice实现的简单架构方法及实例

一:PHP本身的SOAP所有的webservice都包括服务端(server)和客户端(client)。要使用php本身的soap首先要把该拓展安装好并且启用。下面看具体的code首先这是服务端实现:class test{function show(){return the data you request!;}}function getUserInfo($…

量子计算和量子模拟研究获进展

来源:中国科学技术大学北京时间11月19日,中国科学技术大学潘建伟、苑震生等与德国海德堡大学、意大利特伦托(Trento)大学的合作者在超冷原子量子计算和模拟研究中取得重要突破:他们开发了一种专用的量子计算机——71个…

05设计模式——抽象工厂模式

前言:以下总结来自龙哥---左潇龙博客。 总结的很到位,附上博客链接:http://www.cnblogs.com/zuoxiaolong/p/pattern6.html 抽象工厂模式算是工厂相关模式的终极形态,它与工厂方法唯一的区别就是工厂的接口里是一系列创造抽象产品的…

python嵌套列表法实现树_python – 将嵌套的括号树转换为嵌套列表

我有一个树结构文件,其中括号用于表示树.这是将代码转换为python嵌套列表的代码def foo(s):def foo_helper(level0):try:token next(tokens)except StopIteration:if level ! 0:raise Exception(missing closing paren)else:return []if token ):if level 0:raise Exception…

php 正则 中文英文,php 验证只能输入汉字、英语、数字的正则表达式

收藏了正则表达式。可以验证只能输入数字、汉字、英语。分开验证了也可以整合一起验证。但是我是拆分开好了。比较好使。可以单独的验证。经过本人测试可以使用的哦!下面就是php 验证只能输入汉字、英语、数字的代码了if(preg_match(/^[0-9]$/,$str)){echo 值能输入…

卫星发现,这里用十年逆转了千年!

以下内容影像、地形以及气象数据都来自卫星观测记录我们与这个星球如何共处并解决自身的发展问题这是我们的星球这也是我们的星球地球表面的气体流动被卫星和超级计算机所感知它们带来降雨或干旱富饶或贫瘠改变着一块又一块土地一群又一群人一个又一个时代亚洲大陆西南从印度洋…

三.SQL语句实例

1.查询A表中存在而B表中不存在的数据 1.1 描述:表A中有一tel字段,表B中有一tel字段,两个字段存储的内容部分相同,现要查询A表tel字段中有而B表tel字段中没有的数据 1.2 有三个select关键字的查询语句 select tel from A where A.t…

python实现rpc框架_使用Python实现RPC框架

前言本文将会使用Python实现一个最简单的RPC框架,玩具向,不具有实用意义,但可以让你清醒的理解RPC框架的几个组成部分,只是比看Python自带的xmlrpc清晰。本文需要一点Python socket基础。如果你对Python Socket基础方面的内容不是…

php根据分类生成网址,PHP实现无限极分类生成分类树的方法

本文实例讲述了PHP实现无限极分类生成分类树的方法。分享给大家供大家参考,具体如下:现在的分类数据库设计基本都是:每一个分类有一个id主键字段,一个pid指向父类的id,这样便可实现无限级分类,取出的数据就…

张亚勤:新范式、新架构和新模态突破传统算力,推动物理世界走向数字化

本文转自联想创投近日,在联想创投2020 CEO年会上,清华大学讲席教授、智能产业研究院院长、美国艺术与科学院院士、百度前总裁张亚勤先生带来了《未来科技趋势展望》。张亚勤表示,数字化的3.0时期已经到来,数字化的范围已从内容、社…

python魔法函数和装饰器_python魔法方法、构造函数、序列与映射、迭代器、生成器...

在Python中,所有以__双下划线包起来的方法,都统称为"魔术方法"。比如我们接触最多的__init__,魔法方法也就是具有特殊功能的方法。构造函数构造函数不同于普通方法,将在对象创建后自动调用它们。也就是在对象创建完成后…

javascript读取php,PHP如何读取由JavaScript设置的Cookie

cookie在开发中使用的非常多,但如果是使用JavaScript设置cookie然后使用PHP读取出来如何实现呢?即PHP与JavaScript下Cookie的交互使用是否可行呢?// 读取JavaScript设置的cookieheader("Content-type: text/html; charsetutf-8");i…

pycharm 无法import PIL

ubuntu 16.04 pycharm 中使用PIL,pyhon3版本报错:no module 备注:系统已安装PIL,在终端可以import 成功 解决: pycharm中在File -> Settings ->Project ->Project Interpreter ->Packge -> &#xff0…

【华为出品】智能体白皮书2020(附全文下载)

来源 | 华为、IDC、中国信通院等微信编辑 | 邱峰、罗兵微信审核 | 张祥、吴斌、数字理政究院、中通协大数据分会IDC、中国信息化百人会、中国信息通信研究院、中国人工智能产业发展联盟与华为联合编撰的《智能体白皮书》指出,在第四次工业革命爆发前的历史拐点&…

python生成配置文件config_Python configparser模块封装及构造配置文件

1.configparser模块简介使用配置文件来灵活的配置一些参数是一件很常见的事情,配置文件的解析并不复杂,在python里更是如此,在官方发布的库中就包含有做这件事情的库,那就是configParserconfigParser解析的配置文件的格式比较象in…

吴恩达【深度学习工程师】 04.卷积神经网络 第四周特殊应用(2)神经风格转换...

该笔记介绍的是《卷积神经网络》系列第四周:特殊应用(2)神经风格转换 主要内容有: 1.神经风格转换 2.卷积网络隐藏单元可视化显示 3.神经风格转换代价函数 4.内容代价函数 5.风格代价函数 *6.数据从一维到三维的推广 神经风格转换 把C(conten…