作者热门文章
- r - 以节省内存的方式增长 data.frame
- ruby-on-rails - ruby/ruby on rails 内存泄漏检测
- android - 无法解析导入android.support.v7.app
- UNIX 域套接字与共享内存(映射文件)
我正在做一个需要实时广播经纬度的项目
我有类似下面的内容
namespace App\Events;
use App\Events\Event;
use Illuminate\Queue\SerializesModels;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use Illuminate\Support\Facades\Redis;
class TrackersBroadcast extends Event implements ShouldBroadcast
{
public $lat, $lng,$imei,$date_time
use SerializesModels;
/**
* Create a new event instance.
*
* @return void
*/
public function __construct(
$lat,
$lng,
$imei,
$date_time
)
{
$this->lat = $lat;
$this->lng = $lng;
$this->imei = $imei;
$this->date_time = $date_time;
}
/**
* Get the channels the event should be broadcast on.
*
* @return array
*/
public function broadcastOn()
{
return ['tracker-channel'];
}
}
在某些情况下我需要触发实时电子邮件,所以我决定像下面这样实现 laravel 消息队列
namespace App\Jobs;
use App\Jobs\Job;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Mail;
class SendAlertEmail extends Job implements ShouldQueue
{
use InteractsWithQueue, SerializesModels;
public $data;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct($data)
{
$this->data=$data;
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
//
Mail::send('emails.test', ['testVar' => $this->data], function($message) {
$message->from('no-reply@sample.com', 'Website Name');
$message->to('developer@gmail.com')->subject('A simple test');
});
}
}
每当我运行 php artisan queue:listen database
时,它也会对我的广播事件进行排队。我不想排队广播事件。如何做到这一点?
最佳答案
因为如果你扩展 ShouldBroadcast
接口(interface),Laravel 事件广播默认排队。如果您不想让事件广播排队,您应该扩展 ShouldBroadcastNow
接口(interface)。
use Illuminate\Contracts\Broadcasting\ShouldBroadcastNow;
class TrackersBroadcast implements ShouldBroadcastNow
{
......
}
所以这意味着您的事件广播将使用同步队列驱动程序。
关于php - 为什么 BroadCastEvent 在 Laravel 中排队?如何阻止它?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41390753/
这是我的代码: await shardingManager.broadcastEval(`this.guilds.get('352896116812939264')`); 上面的 eval 返回的是:
我在机器人中实现分片时遇到问题 这将返回正确的结果: await (async () => { return "test3"; }).call() 但是一旦我像这样分割它: client.sh
我正在做一个需要实时广播经纬度的项目 我有类似下面的内容 namespace App\Events; use App\Events\Event; use Illuminate\Queue\Serial
我是一名优秀的程序员,十分优秀!