问题描述 如图,消费失败到达最大重试次数会放到失败队列 修复问题后,失败队列的数据会重新自动被消费掉吗?还是需要写另外的失败队列消费程序,若需要,是在哪里配置失败队列的消费类...
问题描述 使用webman做微服务,分布式事务该如何处理? 为此你搜索到了哪些方案及不适用的原因 了解到了rpc和nacos,但是不是分布式事务也是微服务难以处理的一环呢?各位大佬也没提到过。 https://www.workerman.net/q/8412 ...
bug描述 webman 使用嵌套路由后部分路由不会通过中间件 程序代码或配置 路由配置 Route::group('/api', function () { Route::any('/test1', function () { return 'test1'; }); Route::group('/group', function () { Route::any...
问题描述 入队mysql记录 insertData(['time' => time(),'status' => 0,'num' => 0]); 消费mysql更新 这里的代码注释掉了 但是依旧修改了mysql中的 status 和 num //updateData(['id' => $data['queue_id']],['status' => 1,'num' => 1]); 入队...
问题描述 如题, 为此你搜索到了哪些方案及不适用的原因 最近想开发一个小东西。犯了选择困难症。想问一下nodejs和webman谁的性能会更好一点?...
本地的两个宝塔环境 IP1:192.168.2.100 IP2:192.168.2.101 连接的时候还是报这个错误,那个大神帮忙看下 stream_socket_server(): unable to connect to tcp://192.168.2.100:1238 (Cannot assign requested address)...
此贴自动阵亡 先感谢社区各位朋友热心的帮助,上个帖子关于消费券的问题给了我很大的启发。 上一个帖子:https://www.workerman.net/q/8581 目前我在小范围用webman做应用,观察,等都成熟了(我自己技术使用)再切换,就和大神(@nitron)说的一样,线上项目要谨慎,还是先从硬件和流程改进吧。 今天做了一个小的程序,刚发布,刚才看控制台的status ,如下图 我这个是默认的启动,我看p...
webman是不是不适合做依赖第三方接口的实时应用,比如某服务,需要依赖第三方的接口去查询用户信息,如果第三方接口的响应时间需要5秒(假设),同时进来50个请求(开启4个进程监听的话),那么是不是就会导致另外的46个请求至少要等5秒之后才有响应呢?如果想用webman实现这个业务类型应用是否有解决方案?...
配置文件 'default' => [ 'host' => 'redis://127.0.0.1:6379', 'options' => [ 'auth' => '', // 密码,可选参数 'db' => 10, // 数据库 'max_attempts' ...
[ error ] [2]file_get_contents(/www/wwwroot/beita.niukekj.top/vendor/workerman/workerman/../_www_wwwroot_beita.niukekj.top_think.pid): failed to open stream: No such file or directory[/www/wwwroot/beita.niukekj...
下面这段代码是基于laravel框架的,主要监听SQL查询,并记录下整条sql日志; 在webman中应该放到哪里呢? 请大佬帮忙看下哈。 DB::listen(function ($query) { $sql = $query->sql; $bindings = []; if ($query->bindings) { foreach ($query->bin...
$start = microtime(true); $num = 1000; $step = 10000; $count = $step * $num; for ($i = 0; $i < $num; $i++) { $items = []; for ($j = 0; $j < ...
最近要和大数据部门合作,处理下他们的kafka-topic的数据,打算用webman的自定义进程实现,找了几个包, nmred/kafka-php // 这个包里面有amphp ,在start的时候会多启动一个进程去消费,担心在webman的自定义进程中没法很好的管理, 所以打算放弃。 longlang/phpkafka // 这个包可在fpm和swoole下使用,但是还没出正式版,放弃了。 目前是这两个包 下载量比...