UDP 协议与 TCP 协议属同一层的网络协议,相比 TCP 协议而言,UDP 协议则轻巧了许多,UDP 协议是一个高效且不可信的传输协议,因为 UDP 协议只管发送数据,无法得知数据是否传输成功。当数据传输环境特别可靠(如内网环境)或者数据丢失部分也可以接受,并且无法容忍延时。则推荐使用 UDP 协议。
接下来我们演示一下如何用 ThinkPHP5 和 Swoole 来构架一个 UDP 服务器
创建 ThinkPHP5 自定义命令行
1.创建命令行类
-
创建application/console/UdpServer.php文件
~~~
<?php
namespace app\Console;
use think\console\Command;
use think\console\Input;
use think\console\Output;
class UdpServer extends Command
{
protected $server;
// 命令行配置函数
protected function configure()
{
// setName 设置命令行名称
// setDescription 设置命令行描述
$this->setName('udp:start')->setDescription('Start UDP Server!');
}
// 设置命令返回信息
protected function execute(Input $input, Output $output)
{
$this->server = new \swoole_server("127.0.0.1", 9502, SWOOLE_PROCESS, SWOOLE_SOCK_UDP);
// 设置 server 运行前各项参数
$this->server->set([
'worker_num' => 4,
'daemonize' => false,
]);
// 注册回调函数
$this->server->on('Start', [$this, 'onStart']);
$this->server->on('Packet', [$this, 'onPacket']);
$this->server->on('Close', [$this, 'onClose']);
// 启动服务器
$this->server->start();
}
// 主进程启动时回调函数
public function onStart(\swoole_server $server)
{
echo "Start\n";
}
// 接受数据回调
public function onPacket(\swoole_server $server, $data, $clientInfo)
{
$server->sendto($clientInfo['address'], $clientInfo['port'], "Server " . $data);
var_dump($data);
var_dump($clientInfo);
}
// 关闭连时回调函数
public function onClose(\swoole_server $server, $fd, $from_id)
{
echo "Close\n";
}
}
~~~
UDP 服务器和 TCP 服务器 不同,UDP 协议没有连接的概念。启动服务器后,客户端无需连接,所以 UDP 服务器没有 Connect 回调函数,直接可以向服务器监听的 9502 端口发送数据包。需要注意的是 UDP 服务器接受数据的事件为 onPacket,TCP 服务器接受数据的事件为 onReceive。
2.修改配置文件
-
文件所在 application/command.php
~~~
<?php
return [
'app\console\UdpServer',
];
~~~
接下来就可以通过命令行来启动 UDP 服务器
$ > `php think udp:start`
确保 UDP 服务器正常启动后,我们简单改造一下之前的同步 TCP 客户端,来用 Swoole 自己实现一个 UDP 客户端来想 UDP 服务器发送数据
~~~
<?php
// 实例化同步阻塞 UDP 客户端
$client = new \swoole_client(SWOOLE_SOCK_UDP, SWOOLE_SOCK_SYNC);
// 建立连接,连接失败时停止程序
$client->connect('127.0.0.1', 9502) or die("connect failed\n");
// 向 UDP 服务器发送数据
$client->send('111');
echo "ok";
~~~
把 TCP 客户端修改成 UDP 客户端只需要把SWOOLE_SOCK_TCP修改为SWOOLE_SOCK_UDP,并且删除掉返回接受数据函数即可
在浏览器中访问后得到ok后,确定向服务器发送数据成功,接下来我们查看服务器返回结果
返回结果中正确的返回了,客户端向服务器发送的内容,同时显示出客户端的相关信息
- PHP7新特性
- 优雅的写代码
- 常见的代码优化
- 常用的工具类
- PHP原生生成EXCEL
- PHP地理位置计算
- PHP获取服务器状态
- 驼峰转下划线
- 百度地图两点坐标距离计算
- 判断是否是url
- PHP常见header头
- 邮件发送类
- 阿拉伯数字转化为大写
- 获取汉字首个拼音
- 根据身份证号获取星座
- 生成验证码类
- 生成唯一ID
- 身份证验证类
- PHP中文转拼音
- Nginx配置文件
- curl获取网页内容
- 快递查询api
- 上传图片类
- 股票类
- 找回密码类
- 字符串助手函数
- 校验数据规则
- PHP获取收集相关信息
- 字符串截取助手函数
- 网页中提取关键字
- 检测浏览器语言
- 微信相关类
- 微信获取access_token
- 获取用户基本信息
- 代码规范
- 编程规范(psr-1,2)
- 编程规范(原作者的建议)
- 经验
- 常用函数地址
- 函数集合
- 一些常识
- MYSQL相关知识
- 常用sql
- mysql事务隔离级别
- Read uncommitted
- Read committed
- Repeatable read
- Serializable
- 高性能MYSQL读书笔记
- 第一章MYSQL的架构
- mysql逻辑架构
- redis相关知识
- 1.安装redis
- 3.php操作redis
- 队列
- 悲观锁
- 乐观锁
- 发布
- 订阅
- redis实战-文章投票
- 设计模式
- 创建模型实例
- 单例模式
- 工厂模式
- AnimalInterface.php
- Chicken.php
- Factory.php
- Farm.php
- Pig
- SampleFactory.php
- Zoo
- 抽象工厂模式
- AnimalFactory
- Factory
- FarmInterface
- Income
- PandaZoo
- PeonyZoo
- PigFarm
- PlantFactory
- RiceFarm
- ZooInterface
- 原型模式
- 建造者模式
- 结构型模式实例
- 桥接模式
- 享元模式
- 外观模式
- 适配器模式
- 装饰器模式
- 组合模式
- 代理模式哦
- 过滤器模式
- 行为型模式实例
- 模板模式
- 策略模式
- 状态模式
- 观察者模式
- 责任链模式
- 访问者模式
- 解释器模式
- 空对象模式
- 中介者模式
- 迭代器模式
- 命令模式
- 备忘录模式
- 网络知识
- 互联网协议概述
- nginx简易交互过程
- HTTP知识
- LINUX相关知识
- swoole学习
- 1.初识swoole
- 2.WebSocket PHP 即时通讯开发
- 3.异步多进程的 CURL
- 4.异步非阻塞多进程的 Http 服务器
- 5.TCP 服务器
- 5.1同步 TCP 客户端
- 5.2异步 TCP 客户端
- 6.UDP 服务器
- 7.异步多任务处理
- 8.毫秒定时器
- 9.高并发投票
- ThinkPHP5学习
- 命令行操作
- 所有命令行中用到的基类
- 1.base
- 2.WorkerBase
- 3.TimeWorkerBase
- 4.CycleWorkerBase
- 5.WorkerCommandBase
- 6.WorkerHookBase
- 1.基础命令实现
- 2.建立Linux上的守护源码
- 3.发送模板消息
- 4.基于命令行实现自己的队列模式
- 5.发送定时短信
- thinkphp5使用sentry
- sentry通知,记录日志
- 高级查询
- Kafka相关
- 1.安装
- 2.为php打扩展
- 3.kafka实现
- 一些工具搭建
- sentry日志收集系统搭建
- walle搭建
- php实现定时任务
- 检测文件变化