我们有一个消息发送应用程序,要发送消息,它需要为每条消息触发一个 url。
我们有一个带有消息的数据库,一个应用程序守护程序从数据库中挑选前 100 条消息,触发循环中的 url 并从数据库中删除消息。这是一个连续的过程,选择 100 个,发送和删除。
我正在使用 CURL 来访问网址,但我无法达到很高的速度。
请为我提供任何替代过程来触发至少 1000 个 url 秒。
注意:我不需要等待来自 url 的响应
提前致谢。
我建议您使用PHP 套接字编写自己的触发方法。页面上甚至还有一些示例代码看起来可以满足您的需求:
/* Get the port for the WWW service. */
$service_port = getservbyname('www', 'tcp');
/* Get the IP address for the target host. */
$address = gethostbyname('www.example.com');
/* Create a TCP/IP socket. */
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) {
echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
} else {
echo "OK.\n";
}
echo "Attempting to connect to '$address' on port '$service_port'...";
$result = socket_connect($socket, $address, $service_port);
if ($result === false) {
echo "socket_connect() failed.\nReason: ($result) " . socket_strerror(socket_last_error($socket)) . "\n";
} else {
echo "OK.\n";
}
$in = "HEAD / HTTP/1.1\r\n";
$in .= "Host: www.example.com\r\n";
$in .= "Connection: Close\r\n\r\n";
$out = '';
echo "Sending HTTP HEAD request...";
socket_write($socket, $in, strlen($in));
echo "OK.\n";
每秒 1000 个 URL... 嗯,祝你好运。您可能希望同时运行多个守护进程副本,同时加载任务队列的不同部分,以获得所需的并行性。