webman应用场景问题

badman 2022-06-19

webman是不是不适合做依赖第三方接口的实时应用，比如某服务，需要依赖第三方的接口去查询用户信息，如果第三方接口的响应时间需要5秒(假设)，同时进来50个请求(开启4个进程监听的话)，那么是不是就会导致另外的46个请求至少要等5秒之后才有响应呢？如果想用webman实现这个业务类型应用是否有解决方案？

 2906  11 7

11个回答

2548a 2022-06-19

fpm模式的进程一样是阻塞的,它应对的方法无法就是多开进程,相对应的,webman也可以多开,对于这种阻塞严重的,你搞个一两百进程都可以.

暂无评论

liziyu 2022-06-19

“别给生活太多假设”。
干就完了！相信webman能满足目前99%以上的web项目！

badman 2022-06-19

不是假设啊，是我的业务场景就是有这样的，第三方接口经常性的1-60秒才有响应，有时候我并发又能达到1K左右，总不可能去开1K个进程吧？
liziyu 2022-06-19

哦哦，这算是大项目了，没经历过呢！～

a178251115 2022-06-19

如果你的请求不是需要实时响应，可以考虑用定时任务，异步任务，队列之类的来做

badman 2022-06-19

是实时响应的~

six 2022-06-19

这种场景适合用workerman来做，配合workerman/http-client

badman 2022-06-19

好的我研究研究
小阳光 2022-06-19

这样也不行，只能多开进程，workerman/http-client是异步请求，无法和安卓ios等前端响应。楼主提的这个问题确实是php的短板，php一般基于进程而不是线程，如果是基于线程的话就很好解决楼主的问题，比如go的协程。
six 2022-06-19

可以的，workerman配合workerman/http-client是非阻塞请求，可以响应安卓 iOS前端
evilk 2022-06-19

协程只是能支持更多的请求而已,但不会缩短处理请求的时间,对于每个请求而言,该等5秒,还是要等5秒
小阳光 2022-06-19

前端请求服务器，服务器请求第三方接口，请求三方接口时用异步workerman/http-client，请问你什么时候响应给前端
小阳光 2022-06-19

@evilk 协程可以开很多，因为开销很小，当前协程可以等待三方接口响应后再返回给前端，不像php一样受进程数量限制，协成它确实不会缩短三方接口的请求时间，但是可以同时处理更多前端请求，一个前端请求对应一个协程
six 2022-06-20

@小阳光示例代码发在下面了。
badman 2022-06-20

非常感谢@小阳光 @
six 两位的耐心解答和探讨。
WatcherLuo 2022-06-21

在等待异步回调时难道要休眠挂起当前客户端连接吗？不然等回调时客户端连接已经断开了没法再返回数据了。

蚂蚁搬家 2022-06-19

第三方接口定时异步请求回来缓存可以吗

badman 2022-06-19

不行的，比如获取验证码，肯定是要实时返回来。
蚂蚁搬家 2022-06-19

第三方API获取验证码？？

缝合 2022-06-20

其他语言也会有线程/进程数量的限制吧。go的http的是来一个请求创建一个协程。你这种场景是高io,低运算的场景，可以和其他接口分开单独开一个服务器，然后把webman的数量调整高一点，毕竟你的这个场景大多是在等待，把运算型和io型的分开也可以

暂无评论

six 2022-06-20

这种场景适合直接workerman + workerman/http-client 来做，纯异步的，没有所谓的协程消耗，代码类似这样

require_once __DIR__ . '/vendor/autoload.php';
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
use Workerman\Worker;

$worker = new Worker('http://0.0.0.0:1234');
$worker->onMessage = function (TcpConnection $connection, Request $request) {
    $http = new Workerman\Http\Client();
    $http->get('https://example.com/', function ($response) use ($connection) {
        $connection->send((string)$response->getBody());
    }, function ($exception) use ($connection) {
        $connection->send((string)$exception);
    });
};
Worker::runAll();