|
@@ -22,16 +22,14 @@ class RefillSender
|
|
|
public function send()
|
|
|
{
|
|
|
$time = time();
|
|
|
- Log::record("send message start:{$time}",Log::DEBUG);
|
|
|
|
|
|
- for ($i = 0; $i < 10000; $i++)
|
|
|
+ for ($i = 0; $i < 1000000; $i++)
|
|
|
{
|
|
|
$pThis = $this;
|
|
|
go(function () use($time, $i,$pThis) {
|
|
|
$pThis->push_order(1092, $time, $i);
|
|
|
});
|
|
|
}
|
|
|
- Log::record("send message end",Log::DEBUG);
|
|
|
}
|
|
|
|
|
|
private function push_order($mchid,$time,$index)
|
|
@@ -52,11 +50,16 @@ class RefillSender
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+Log::record("send message start",Log::DEBUG);
|
|
|
+
|
|
|
go(function () {
|
|
|
$sender = new RefillSender();
|
|
|
$sender->send();
|
|
|
});
|
|
|
|
|
|
+Log::record("send message end",Log::DEBUG);
|
|
|
+
|
|
|
+
|
|
|
|
|
|
|
|
|
|