问题就是 聊天过程中的消息传递问题（以前惭愧用的pomelo 里面send消息可以加回调 websocket不能- -） 如下： 1：A 发送信息给 B 2：A的信息先发送到了服务器，服务器进行数据的持久化等操作，那么此时如何做到让A知道服务器已经收到了他发给B的消息呢。我想了几种办法感觉都是不是太好，一、Clien A 发送消息的时候进行存储当前消息体的md5值 然后带着md5值发送给服务器 ，服务器持久化以及其他操作完成后回复给A的时候也带着md5值，但是这种就比较损耗性能纵观两种方案都不太好。一个性能一个不是完全可靠。1）client-A向im-server发送一个消息请求包，即msg:R 2）im-server在成功处理后，回复client-A一个消息响应包，即msg:A 3）client-A和 im-server

#### 执行workerman status命令后，会导致设置的socket超时时长失效 RT,我是在thinkphp6中使用wokerman执行异步任务，主要是发送TCP请求给三方接口，因为三方处理的比较慢，所以设置了1个小时的超时时间，也就是代码会在`socket_read()` 这里等待1小时，但是当我运行workerman`status`的命令后，会导致`socket_read`这里立即返回，导致我设置的超时时间就失效，请问这是怎么回事，该如何解决 我感觉和这个问题很像，https://www.workerman.net/q/2367 因为需要定期查看进程状态，我该如何避免这种情况发生 ``` $socket= socket_create(AF_INET, SOCK_STREAM, SOL_TCP); //如果运行workerman status 这里设置的超时时长就失效了 socket_set_option

微信支付异步返回，触发gatewayclient sendtouid 发送消息经常接收不到，也不报错，怎么回事，求大神帮忙

#### 问题描述 当用户向公众号发送文本消息时，公众号自动回复消息，麻烦帮忙看看下面代码如何改进，才能让用户收到公众号回复的消息？ ``` <?HeaderBag; use Symfony\Component\HttpFoundation\Request as SymfonyRequest; class Wechat { // 处理微信服务器推送的事件

要求Workerman版本>=3.3.0) ```** 源码地址：https://github.com/walkor/Channel Channel是一个分布式通讯组件，用于完成进程间通讯或者服务器间通讯## 特点 1、基于订阅发布模型 2、非阻塞式IO ## 原理 Channel包含Channel/Server服务端和Channel/Client客户端 Channel/Client通过connect接口连接Channel/Server并保持长连接 Channel/Client通过调用on接口告诉Channel/Server自己关注哪些事件，并注册事件回调函数（回调发生在Channel/Client所在进程中） Channel/Client通过publish接口向Channel/Server发布某个事件及事件相关的数据 Channel/Server接收事件及数据后会分发给关注这个事件的Channel/Client Channel/Client收到事件及数据后触发on接口设置的回调 Channel/Client只会收到自己关注事件并触发回调 ## 安装 `composer require

#### 问题描述 如果我使用 get() 方法，分页生效，换成 chunkMap() 分页失效。为什么？求大神指点。

#### 问题描述 你好，我使用的webman_admin,我修改了session的配置文件http_only改为false，但后台页面http_only还是true。请帮我看看 ``` return [ 'type' => 'file', // or redis or redis_cluster 'handler' => FileSessionHandler::class, 'config' => [ 'file' => [ 'save_path' => runtime_path() . '/sessions', ], 'redis' => [ 'host' => '127.0.0.1', 'port' => 6379, 'auth' => '', 'timeout' => 2, 'database' => '', 'prefix' => 'redis_session_', ], 'redis_cluster' => [ 'host' => ['127.0.0.1:7000', '127.0.0.1:7001', '127.0.0.1:7001'], 'timeout' => 2, 'auth' => '', 'prefix' => 'redis_session_', ] ], 'session_name' => 'PHPSID', 'auto_update_timestamp' => false, 'lifetime' => 7*24*60*60, 'cookie_lifetime' => 365*24*60*60, 'cookie_path' => '/', 'domain' => '', 'http_only' => false, 'secure' => false, 'same_site' => '', 'gc_probability' => [1, 1000], ]; ```

请问gateway分布式部署后$client_id->close()不起效,有什么快捷的解决办法吗？

只有在on{...}回调中载入的文件平滑重启后才会自动更新，但是我怎么搞都不会自动更新，愣是没搞明白，请指点下！

workerman 运行 mqtt 服务的will(遗嘱消息), 在服务启动的时候, 会接收到其他服务的遗嘱消息。客户端设置好遗嘱以后启动, 你只要服务端订阅者一启动就会收到遗嘱消息，如果此时客户端发布者已经在线，会导致不准确的问题。 这是怎么回事呢? 应该怎么处理这种问题?

用php内置的服务器，在返回的时候加上ob_start("ob_gzhandler"); 数据成功压缩。 框架：thinkphp6 用wokerman启动的时候，一直压缩不了。求指导如何压缩返回的数据？ 

我上图

[截图](/upload/img/20220627/2762b92ba30adc.png) 实际业务过程中，出现http 请求丢失的问题，我对比了经过nginx服务器 发送到workman http 服务的收发日志，同一时刻收到的记录比发出的记录少，导致发送收到的回复超时，我怀疑是如图的问题。问题：我配置了http 服务器，收到即可回复“hello world”,但是 用curl 请求这个端口的时候，如果发送过快就会无回复，卡住。不知道什么原因 !

```php // 当客户端连接上来时，设置连接的onWebSocketConnect，即在websocket握手时的回调 $gateway->onConnect = function($connectionconnection->onWebSocketConnect = function($connection , $http_header) { // 可以在这里判断连接来源是否合法，不合法就关掉连接// onWebSocketConnect 里面$_GET $_SERVER是可用的 // var_dump($_GET); }; }; ``` 前端JS // 连接服务端token=123uji2"); // 当socket连接打开时，输入用户名 ws.onopen = onopen; // 当有消息时根据消息类型显示不同信息

我写的例子总是会触发connect方法，一旦telnet建立了连接，会不停输出1111111。如何才能保证每次建立连接，事件只触发一次呢？ ```php <?event_new(); // 创建socket $serv_socket = stream_socket_server('tcp://0.0.0.0:8000',$errno,$errstr); // 设置事件循环监听EV_PERSIST,'connect',); event_base_set($event,$base); event_add($event); event_base_loop($base); // 定义事件回调

多个终端1s上报一次数据，会出现终端关闭后，服务器还在接收数据是怎么回事？

$worker->onMessage回调事件里，我调用$connection->send 发送数据 ，如果我不主动关闭连接的话是等，数据发送完成之后自动就关了，还是必须客户端来关闭才行。

phpsocket.io 写了一个服务端 监听了几个事件 事件都是查询数据库 数据不打 web端定时请求 几十个人访问就卡住了 lievent和 内核都跳优了 难道他这种单进程，不能做耗时操作

# PHP几种回调写法 PHP里通过匿名函数写回调是最方便的，但是除了匿名函数方式的回调，PHP还有其它的回调写法。以下是PHP几种回调写法的示例。 ## 1、匿名函数回调 ```php <?以MySQL为例，在主进程初始化的MySQL连接等资源会被子进程继承，每个子进程都可以操作这个数据库连接，但是这些连接在MySQL服务端对应的是同一个连接，会发生不可预期的错误，例如```mysql gone这样还有一个好处就是支持业务代码reload。由于MyClass.php是在子进程载入的，根据reload规则业务更改MyClass.php后直接reload即可生效。= array('your\namesapce\MyClass', 'onWorkerStop'); Worker::runAll(); ``` 注意：根据PHP的运行机制，如果没用调用new 则不会调用构造函数，另外静态类的方法里面不允许使用```$this```。

如果client_id对应的客户端连接断开了，那么这个client_id也就失效了。当这个客户端再次连接到Gateway时，将会获得一个新的client_id。也就是说client_id和客户端的socket连接生命周期是一致的。 client_id一旦被使用过，将不会被再次使用，也就是说client_id是不会重复的，即使分布式部署也不会重复。## 返回值 无返回值，任何返回值都会被视为无效的 ## 注意 ``` $client_id ```是服务端自动生成的并且无法自定义。onConnect事件仅仅代表客户端与gateway完成了TCP三次握手，这时客户端还没有发来任何数据，此时除了通过```$_SERVER['REMOTE_ADDR']```获得对方ip，没有其他可以鉴别客户端的数据或者信息，所以在onConnect事件里无法确认对方是谁。