搜索-workerman社区

问答jenssegers/mongodb 中如何批量插入，遇到唯一索引就忽略错误？

#### 问题描述在webman中使用`jenssegers/mongodb`包，如果集合中已经存在相同的数据，再插入相同数据就会报错。请问有其他的方法可以批量插入吗？. ``` #### 为此你搜索到了哪些方案及不适用的原因 - 查询了`jenssegers/mongodb`的文档，发现并没有针对数据的批量处理，例如在mysql中使用upsert() insertOrIngnore()等类型的方法 - 查询了mongodb手册发现，insertMany()可以增加参数ordered:false来使批量插入遇到唯一索引错误时，忽略此条，继续插入。但是`jenssegers/mongodb`包中未发现这类的写法

问答gateway-worker开启了，websocket正常连接，但前端发消息，Events的onMessage事件不执行

并且可以使用sendToAll给所有客户端，但是客户端发送消息后，服务端中业务类Events的onMessage方法没有执行。

问答发布版本安全更替方案咨询

#### 问题描述环境：阿里云 alb 、2台 ecs 项目：web http 接口目标：实现代码发版安全重启更替 #### 为此你搜索到了哪些方案及不适用的原因目前想到的方案有三种： 1alb -> nginx -> webman 设置nginx stream, 定义两个服务端口用于更替发版时，同步最新代码，启动新服务，更新stream，重启nginx, 停止旧服务 2 alb-> webman 通过调用阿里云 alb 接口，实现上、下服务（定义两个服务端口用于更替），启、停服务 3 alb -> webman 基于 reusePort + Master进程ID，上线代码时，取得并记录当前进程ID，启动新服务，基于记录的旧PID停止旧服务。

问答自定义构造函数注入之debug启动修改依赖注入类逻辑并不走热更新情况

自定义构造函数注入 3. debug模式启动 4. 配置按照手册配置如下 ``` return [ // ...$this->smtpPort = $smtp_port; } public function mail($email, $content) { // 发送邮件代码省略$email; } } ``` 6.浏览器访问发现返回值并未及时更新，只有将服务重启动才会更新 === 再反复尝试了很多次问题依旧，后发现可以采用几个办法来处理 1.自定义构造函数注入方式下修改配置如下 ``` return [ // ...

问答use引用路径的问题

目录结构使用的是《Web消息推送系统》这个项目的路径把数据库的类拷贝到workerman\lib下面 Config\Db.php 一直引用不了 PHP Fatal error:

问答服务器更新代码reload进程后，进程下的所有定时器丢失

服务器更新代码reload进程后，导致该进程下的所有定时器丢失，如何避免reload进程定时器丢失？棋牌游戏，定时器用来机器人出牌和托管等等业务。

问答WEB消息推送框架推送接口不能访问

=publish&content=%E6%B6%88%E6%81%AF%E5%86%85%E5%AE%B9&to=1486979840000 start.php 启动没有问题，但是前端收到不消息，推送接口也打不开

问答菜鸟疑问：关于websocket的服务创建问题

本身想结合TP或者YII这类常用的框架，因为框架带来的便利性还是可以节省开发的时间，但是考虑到websocket这种长连接常驻进程，会有以下几点疑问 > 1.长连接进程会不会让这类框架的的实例占用内存资源一直不释放那多个链接创建下来的进程是否占用内存很庞大？长连接进程对于mysql数据库连接如果处理连接过多？因为PHP是多进程运行的，不像JAVA这种单例多线程，而且网上也很少有php连接池的应用处理，我们该怎么处理每一个进程创建的mysql连接？如果主动释放的话，会不会在交互频繁点的地方造成数据库连接上的性能阻塞？如果有踩过坑的老铁可以分享一下你们项目架构吗？或者有比较不错的项目模式推荐，我还是想兼顾一下开发效率和性能稳定的~

问答紧急：webman如果实现同时并发访问多个第三方接口

然后判断结果，如果不正确，再等待第二快返回的，直到结果正确。然后，处理接下来的业务。

问答gateway-worker 加入群组聊天思路问题

#### 1.在什么时候或者在哪个函数使用joinGroup 建了一个群group表，主键为group;建了一个群成员表group_membser，关联group_id和用户uid 我要邀请一个用户进群我的思路:在Event.php中onWebSocketConnect方法里去执行，查询group_membser表中，当前用户所有的分组信息，然后循环调用joinGroup方法，把当前用户加进去，但总感觉怪怪的未在线时收到的消息怎么在刚上线的时候发送？

问答phpsocketIO中是否有类似于nodeJS的callback回调？

data){ socket.disconnet(); console.log("获取数据失败"); } }); ``` 想请问一下，nodeJS中得这种callback方法在phpsocketIO我目前只能想到一种就是用$socket->emit(); 向客户端发送一个失败的指令来替代callback，但这样需要修改现有的前端接收代码。有没有大神有更好的解决方案？

问答怎么实现流式输出？求解！

#### 为此你搜索到了哪些方案及不适用的原因这里写搜到的方案及不适用原因我需要中转，客户端请求-》服务端中转获取流式数据返回客户端。// 输出图像 imagejpeg($im); // 获得图像内容 $image = ob_get_clean(); // 发送图像

问答关于多进程监听socket的疑问！！！！！

我创建了socket监听，然后fork了5个进程，然后新连接进来的时候五个子进程是都会收到这个链接。。。应该怎么操作分配给某一个进程~ 求各路大神解答下啊啊啊啊！！

分享Docker学习笔记分享

不同开发者的系统和配置不同易导致环境差异问题，而 Docker 可通过 Dockerfile 明确指定 PHP 版本、扩展及依赖项，确保开发环境一致，提高开发效率。其次，简化部署。开发环境构建好的 Docker 镜像可直接在生产服务器运行，避免手动安装配置的繁琐，降低部署风险。最后，提供资源隔离。OPTIONS] 搜索镜像列出10个 docker pull [OPTIONS]:[TAG] 下载镜像（OPTIONS镜像名字、TAG版本号，不填默认最新版本） docker system df 查看数据占用空间docker rm [容器ID或者容器名] 删除已停止的容器 -f 强制删除容器(包括正在运行的容器) $(docker ps -a -q) 强制删除所有容器(包括正在运行的容器-谨慎使用Tag ``` docker tag [镜像名称]:[镜像版本号] [ip地址]:5000/[镜像名称]:[镜像版本号] ``` ### 修改配置文件使之支持http docker默认不允许http推送镜像

问答插件升级版本号获取问题？

[截图](/upload/img/20230622/2264941e300b6c.png) ``` 这里粘代码或配置 $from_version, $to_version 这两个函数代表什么意思？比如我要升级我开发的应用插件，从1.0.0升级到2.0.0，有个数据库表要加两个字段，1.0.0版本是没有的，我要用哪个变量判断版本？然后插入字段到数据库表 ```

问答php异步任务用哪种解决方案合适

最近有个需求是，发布一条动态，动态涉及到@多个用户，再处理完动态入库后还要一个一个通知被@用户，就想着用异步来实现，找了几个解答，不知道哪一种才适合，最主要是以后可能还会其他异步场景，就根据一个标识来区分做业务处理代码/question/1304 方案二：http://wenda.workerman.net/?/question/582 或者说，除了上面的两种方案，还有什么更好的方案吗

问答如何在onWebSocketConnect回调中，获取client_id？

需要在建立连接时根据client_id做一些业务处理，跟着源码，也打印了整个connection，没发现相关数据，在Gateway类中貌似是没办法获取client_id的？

文档事件列表

# 事件列表及数据结构 ## user.register * 含义用户注册时触发 * 数据结构 `plugin\user\app\model\User` 实例示例 ```php## ai.menu.list * 含义渲染左侧图标菜单时触发 * 数据结构 `plugin\ai\app\event\data\EventData` 实例示例 ```php <?handler是处理器类名以上参数都可以进行修改，达到介入请求处理的目的 ## ai.chat.completions.request * 含义聊天类大模型请求时触发示例 ```php，如果是数组，则代表发送错误 var_export($responseData->data); } ]; ``` 打印类似 ```php \plugin\ai\app\event例如Dall-e (Midjourney属于任务类，不会触发此事件，见下面文档) * 数据结构 `plugin\ai\app\event\data\ModelRequestData` 实例示例

文档查询构造器

该方法一次获取结果集的一小块，并将其传递给闭包函数进行处理。，第二个参数是任意一个数据库系统支持的运算符，第三个是该列要比较的值 ```php $users = Db::table('users')->where('votes', '=', 100)->get(如果你要从其他「序列」来获取 ID ，则可以将字段名称作为第二个参数传递给 insertGetId 方法。如果记录存在，则使用第二个参数中的值去更新记录。如果找不到记录，将插入一个新记录，新记录的数据是两个数组的集合。 ## 自增 & 自减这两种方法都至少接收一个参数：需要修改的列。第二个参数是可选的，用于控制列递增或递减的量： ```php Db::table('users')->increment('votes'); Db::table('users')->increment

分享快递查询插件(支持快递鸟,快递100,万维易源)