如何将数据从客户端发送到redis，然后再发送到laravel

Posted 2023-04-18

【中文标题】如何将数据从客户端发送到redis，然后再发送到laravel

【英文标题】：How to send data from client to redis and then after to laravel

【发布时间】：2018-03-13 15:10:52

【问题描述】：

我正在使用 laravel 和 redis 进行实时聊天。我可以从我的 laravel 触发事件并将该数据接收到客户端。

我的问题是如何从客户端发送一些东西，然后将其接收到 redis 并将其传递给 laravel

例如，我如何检查用户是否已阅读聊天消息。

代码：

var express = require('express');
var app     = express();
var server  = require('http').createServer(app);
var io      = require( 'socket.io' ).listen( server );
var redis = require('redis');
var port = process.env.PORT || 8888;
server.listen(port,'x.x.x.x');

io.on('connection', function (socket) 
   console.log("Connected");
);
var redisClient = redis.createClient();
redisClient.psubscribe(['get_message','read_message']);
redisClient.on("pmessage", function(channel, pattern, message) 
    console.log(channel); // i can see get_message on this line in console but not read_message
);

//Also tried this
io.on('read_message', function (socket) 
   console.log(socket);
);
//Also this
redisClient.on('read_message', function (socket) 
   console.log(socket);
);

redisClient.on('disconnect', function() 
    console.log("Disconnected");
    redisClient.quit();
);

注意：我正在从 ios 应用程序发出数据。

【问题讨论】：

您应该使用 AJAX 请求进行异步客户端到服务器更新

你最后看我的笔记了吗？

是的，我做到了，为什么您无法从您的客户端向您的服务器发送请求？

【参考方案1】：

Redis 是一个键/值存储引擎。您应该将其视为数据库。

客户端向接收此请求并决定如何处理它的网络服务器发送请求。对于需要服务器端处理的请求，它将将该请求传递给服务器端“引擎”进行处理，在您的情况下，可能是 php-FPM，然后将其传递给 PHP 守护程序，然后执行请求。

Redis 无法以这种方式解释请求。因此，您必须使用 Laravel 拦截请求，然后将其发送到 Redis。反之亦然。

如果你想让 Laravel 从 Redis 获取信息，你会想要使用 Redis' pub/sub feature。然后，您可以让 Laravel 订阅 Redis 更新，获取更新并根据需要持久化或处理数据。

phpredis lib 支持发布/订阅功能。

这是一个使用该库的 PHP 实现示例。 https://xmeng.wordpress.com/2011/11/14/pubsub-in-redis-using-php/

【参考方案2】：

您可以利用 Laravel 中的广播来实现同样的目的。您还可以使用耳语在多个客户端之间进行广播。还有一个基于 redis 的广播器。

首先你需要在composer中包含它的包。

composer require pusher/pusher-php-server "~3.0"

在 app/broadcasting.php 中配置凭据

'options' => [
'cluster' => 'eu',
'encrypted' => true
],

您还需要配置广播队列。

发送广播

event(new ShippingStatusUpdated($update)); //Broadcasts to everyone, avail to working scope as well
broadcast(new ShippingStatusUpdated($update));//Broadcasts only to others

接收广播

为 echo 实例化套接字 ID [作为 X-Socket-ID 包含在标头中]

var socketId = Echo.socketId();

确保您已安装 echo

npm install --save laravel-echo pusher-js

创建回显实例

import Echo from "laravel-echo"

window.Echo = new Echo(
    broadcaster: 'pusher',
    key: 'your-pusher-key'
);

监听事件

Echo.channel('orders')
    .listen('OrderShipped', (e) => 
        console.log(e.order.name);
    );

将事件广播给其他连接的客户端，而完全不影响您的 Laravel 应用程序

Echo.channel('chat')
    .whisper('typing', 
        name: this.user.name
    );

Laravel Broadcast Documentation

【参考方案3】：

我认为这个教程是你想要的：

Laravel 5 and Socket.io Tutorial

它包含客户端和服务器端的教程

对于 ios

你可以使用：Socket.IO-Client-Swift

也检查一下：Socket.IO on iOS