Cet article est basé sur l'analyse et l'écriture du code du module de diffusion de la version Laravel 5.4
Recommandé : "tutoriel laravel"
Introduction ;
La diffusion signifie que l'expéditeur envoie un message, et chaque destinataire qui s'abonne à la chaîne peut recevoir le message à temps ; par exemple, l'étudiant A écrit un article et l'étudiant B commente sous l'article ; et les commentaires de l'étudiant A sur la page Vous pouvez recevoir des notifications indiquant qu'un article a été commenté sans rafraîchir. Cela signifie essentiellement que l'étudiant A a reçu un message diffusé. Ce message diffusé est déclenché par l'action du commentaire de l'étudiant B ; 🎜> est diffusé tout au long de la diffusion. Dans le comportement, il existe un concept important appelé chaîne. Les types de chaînes sont
● chaîne publique publique
● chaîne privée privée
● Présence du canal d'existence Si le terminal mobile s'abonne au canal public, cela déclenchera directement le succès lors du processus d'abonnement du canal privé privé et de la présence du canal d'existence, une vérification de l'autorisation sera envoyée au serveur pour voir s'il a la permission de s'abonner au canal ; le canal privé privé La différence avec le canal d'existence est que le canal privé privé peut recevoir des messages envoyés par d'autres membres, tandis que le canal d'existence peut également recevoir des informations lorsque l'utilisateur rejoint et quitte La diffusion convient aux scénarios suivants (cette petite partie est extraite de la diffusion d'un événement Laravel basée sur le pilote Pusher (partie 1)) : ● Notification ou signalLa notification est l'exemple le plus simple et le plus couramment utilisé. Les signaux peuvent également être considérés comme une forme de notification, sauf qu'ils n'ont pas d'interface utilisateur. ● Flux d'activité Les flux d'activité (flux) sont au cœur des réseaux sociaux. Par exemple, pour les likes et les commentaires dans WeChat Moments, A peut voir les likes de B en temps réel et B peut voir les commentaires de A en temps réel. Quantity ChatAffichage en temps réel des informations de chat
Composition du module
Démo
Log driver
Configuration
Fichier .env modifier ou ajouter une ligne : BROADCAST_DRIVER =log;
Diffusion
Appelez directement
$manager = app(Illuminate\Broadcasting\BroadcastManager::class); $driver = $manager->connection(); // 第一个参数是频道名，第二个参数是事件名，第三个参数是广播内容 $driver->broadcast(['channel_1', 'channel_2'], 'login', ['message' => 'hello world']);
[2017-08-18 20:45:49] local.INFO: Broadcasting [login] on channels [channel_1, channel_2] with payload:
{
"message": "hello world"
}Écoute de la diffusion d'un événement
Cette méthode d'appel est celle lorsqu'un événement qui implémente ShouldBroadcast est déclenchée, une opération de diffusion sera effectuée (en même temps, il existe également une interface appelée ShouldBroadcastNow. La différence avec l'interface ShouldBroadcast est que lorsque les événements qui implémentent l'interface ShouldBroadcastNow sont mis dans la file d'attente, ils seront mis dans la file d'attente appelée sync)
Par exemple, La première étape, l'événement IlluminateAuthEventsLogin est un événement qui sera déclenché une fois que l'utilisateur s'est connecté avec succès. Il est légèrement modifié pour lui permettre de le faire. implémentez la fonction de diffusion ;class Login implements ShouldBroadcast {
......
// 定义事件被触发时，广播频道；此处定义名为 first-channel 的私有频道
public function broadcastOn() {
return [
new PrivateChannel('first-channel'),
];
}
// 自定义广播名称；如果方法未定义，默认以类名为事件名，此处的默认值是 Illuminate\Auth\Events\Login
public function broadcastAs() {
return 'login';
}
}protected $listen = [
......
'Illuminate\Auth\Events\Login' => [
'App\Listeners\UserLogin',
],
];class UserLogin {
public function __construct() {}
public function handle(Login $event){
\Log::info('Do UserLogin Listener: I was Login');
}
}event(new Illuminate\Auth\Events\Login($user, true));
broadcast(new Illuminate\Auth\Events\Login($user, true));
$manager = app(Illuminate\Broadcasting\BroadcastManager::class); $manager->event(new Illuminate\Auth\Events\Login($user, true));
$manager = app(Illuminate\Broadcasting\BroadcastManager::class); $manager->queue(new Illuminate\Auth\Events\Login($user, true));
Pilote Pusher
Pusher est un service tiers envoyé par le serveur Lors de la diffusion, une requête sera envoyée à Pusher, puis les données seront échangées via la longue connexion maintenue par Pusher et le navigateur ou le terminal mobile ;
Configuration
Enregistrez les utilisateurs via les informations du site officiel de Pusher, obtenez votre propre ensemble d'informations clés et modifiez la configuration .env. file;
BROADCAST_DRIVER=pusher PUSHER_APP_ID=xxxxxxxxxxxxxxxxxxxxxx PUSHER_APP_KEY=xxxxxxxxxxxxxxxxxxxxxx PUSHER_APP_SECRET=xxxxxxxxxxxxxxxxxxxxxx
Préparation
Surveillance des événements
La surveillance des événements backend utilise toujours l'exemple de connexion du "log-driven" " partie ;
Front-end
La page front-end introduit le code suivant :
<script src="https://js.pusher.com/4.1/pusher.min.js"></script>
<script>
// 打开 Pusher 的调试日志
Pusher.logToConsole = true;
// 定义 Pusher 变量
var pusher = new Pusher('PUSHER_APP_KEY的值', {
cluster: 'ap1',
encrypted: true
});
// 定义频道，绑定事件
var channel = pusher.subscribe('private-first-channel');
channel.bind('login', function(data) {
alert(data);
});
</script>Définition des autorisations des chaînes
Les autorisations des chaînes sont définies dans routes/channels.php ceci L'auteur ; définit la fonction de rappel d'autorisation pour le canal du premier canal :
Broadcast::channel('first-channel', function ($user) {
return (int) $user->id === 1;
});Diffusion
Diffusion directe
$manager = app(Illuminate\Broadcasting\BroadcastManager::class); $driver = $manager->connection(); // socket 参数是广播私有频道时排除的 socket， 每个浏览器端或者移动端在建立 websocket 时都会被分配一个 socket_id $driver->broadcast(['private-first-channel'], 'login', ['user' => ['name' => 'hello'], 'socket' => '5395.4377611']);
Diffusion indirecte
Se référer à la diffusion indirecte mentionnée dans " Méthode "Log Driven" ;Si vous souhaitez envoyer une diffusion exclusive (c'est-à-dire qu'aucun message de diffusion ne sera reçu sauf pour le client qui le demande actuellement), vous avez besoin des conditions suivantes :
1 L'événement utilise le trait IlluminateBroadcastingInteractsWithSockets ;
2. L'en-tête de requête envoyé par le front-end doit contenir des informations X-Socket-ID
3. L'événement déclenche la diffusion (new IlluminateAuthEventsLogin($user, true))-> toAutres();
Pilote Redis
Configuration
Fichier .env Modifier ou ajouter une ligne : BROADCAST_DRIVER=redis;
Broadcast
Le principe est de déployer également un serveur Socket.IO sur le backend Le framework Laravel publiera les messages sur le serveur Socket.IO, et le Socket. Le serveur .IO maintiendra une communication à long terme avec le navigateur ou le terminal mobile ;
L'auteur n'a pas encore fait de démonstration de cette partie, et il existe de nombreux documents d'introduction en ligne. il sera beaucoup plus facile de se lancer dans cette partie de l'action
;Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!
Introduction aux composants Laravel
Introduction au middleware Laravel
Quels sont les modèles de conception utilisés par Laravel ?
Lequel est le plus simple, thinkphp ou laravel ?
Tutoriel Laravel
Tutoriel d'auto-apprentissage Java base zéro
Que faire avec la carte vidéo
Comment optimiser les performances de Tomcat
![[Web front-end] Démarrage rapide de Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
