草庐IT

stream_socket_sendto

全部标签

laravel - 我正在使用带有 redis 和 socket.io 的 laravel echo。存在和私有(private) channel 失败

我正在使用带有redis和socket.io的laravelecho。存在和私有(private)channel失败我正在为我的服务器使用这个包laravel-echo-server当我使用公共(public)channel时一切正常,但是当我使用私有(private)channel时,在laravel-echo-server中记录了以下错误Clientcannotbeauthenticated,gotHTTPstatus503⚠[7:16:00PM]-155BcZ4cC_ieweeWAAADcouldnotbeauthenticatedtopresence-chat-messageE

node.js - socket.io-redis 不断抛出 NOAUTH 错误

我正在尝试连接到受密码保护的redis服务器,但由于某种原因,我不断收到错误消息:events.js:141扔呃;//未处理的“错误”事件^ReplyError:就绪检查失败:需要NOAUTH身份验证。在parseError(/home/ubuntu/TekIT/ITapp/node_modules/redis-parser/lib/parser.js:193:12)在parseType(/home/ubuntu/TekIT/ITapp/node_modules/redis-parser/lib/parser.js:303:14)我知道密码是正确的,因为我在redis-cli中尝试过它

laravel-5 - 使用 laravel、Socket 和 Redis 动态更改 channel

!!!服务器-套接字如何动态更改channel例如,当我使用/fire/1广播时,我只想发送到/room/1。目前它发送到/room/1、/room/2、/room/3等。因为这里默认情况下,服务器上的所有内容都订阅了“test-channel”。我就是想不通。varserver=require('http').Server();vario=require('socket.io')(server);varRedis=require('ioredis');varredis=newRedis();io.on('connection',function(socket){console.log

apache-kafka - Spark Streaming scala 性能极慢

我有以下代码:-caseclassevent(imei:String,date:String,gpsdt:String,dt:String,id:String)caseclasshistoryevent(imei:String,date:String,gpsdt:String)objectkafkatesting{defmain(args:Array[String]){valclients=newRedisClientPool("192.168.0.40",6379)valconf=newSparkConf().setAppName("KafkaReceiver").set("spar

laravel - 使用 Laravel Echo、laravel-echo-server 和 socket.io 进行广播不起作用

我已经通过自己的实现成功地使用Laravel设置了websockets。但是,经过数小时的尝试和阅读我能找到的每一篇文档后,我确实需要进一步的帮助。"laravel-echo":"^1.5.2","socket.io-client":"^2.2.0",这是我的.env文件详细信息BROADCAST_DRIVER=redisCACHE_DRIVER=fileQUEUE_CONNECTION=redisSESSION_DRIVER=fileSESSION_LIFETIME=120laravel-echo-server.json"database":"redis","databaseConf

caching - 从 Twitter Streaming API 和 RESTful API 获取的数据是否需要缓存?

1.我正在使用TwitterStreamingAPI获取一些带有特定主题标签的推文。我想从每条推文中提取一些元数据,并使用它们来更新一些本地数据结构。有时很多推文会在短时间内出现在我的电脑上。我不确定处理速度是否比推文流的速度快。我想保证所有的推文都能被成功接收,并且每条推文都可以进行。所以我想问一下我是否必须添加一些结构来缓存我收到的推文?如果是,你能给结构或工具的建议吗?缓冲区、线程池或一些缓存软件,如memecached或redis?2.我还想使用Twitter搜索API,这是一个RESTfulapi,来获取一些推文。我会在一次查询中得到100条推文。在这种情况下是否有必要缓存推

php - 自定义 socket.io 的断开连接事件

我有一个基于套接字、redispub/sub和运行在LAMP堆栈(YII框架)上的Node的通知系统,我正面临一个问题。用户登录后,在每次刷新页面时,socket-io都会触发“断开连接”事件。有什么方法可以将登录状态从PHP传递到用户已登录的套接字,因此不应在页面刷新时触发断开连接事件?同时,当网络断开时,socket的默认行为应该保持原样。 最佳答案 disconnect事件是一个基本级别的通知:每次套接字连接断开时都会触发它,刷新页面会断开连接,就像关闭浏览器窗口一样。您可以在Yii和socket.io之间传递session信

javascript - 同步多个 Socket.io 客户端

我正在构建一个应用程序,它在前端使用Angular.js,在后端使用Express上的Socket.IO和Redis。套接字的基本用法是允许一种类型的用户将项目推送到由第二种类型的用户组使用的列表。一个简单的例子:学生可以将消息推送到类(class)列表中,只有本类的老师可以看到该列表。我正在尝试在不同时间连接的多位教师之间同步列表,列表存储在Redis存储中,我想知道同步客户端的正确方法是否:一个。在每次更新时发送列表-省去了必须在客户端中管理同步和潜在的不匹配的需要。B.仅在连接时发送列表并对连续事件应用增量更新。我确信这在过去已经得到解决,因为它似乎是套接字通信的一个非常基本的问

sockets - Laravel Forge 队列 worker

我使用Forge进行部署并设置了一个worker来处理Redis队列。每封电子邮件都在我的应用程序中排队,如果我尝试在“支持”页面中发送电子邮件,它会起作用。尽管如此,如果我尝试注册一个帐户,整个过程都有效,但不会发送激活电子邮件。Thisismylog,它似乎无法连接到mysql来存储失败的作业(即使数据库连接有效,因为我的注册帐户已正确存储)但它不提供有关作业失败的信息。此外,我的测试环境和本地环境都可以发送激活电子邮件。怎么了? 最佳答案 我通过重启队列工作器解决了。 关于sock

node.js - 'adapter' 中没有方法 'io'(node.js、heroku、RedisCloud、socket.io)

在Heroku上使用RedisCloud和node.js允许(future)扩展到多个dyno。按照以下步骤让Redis工作:https://devcenter.heroku.com/articles/rediscloud#using-redis-from-node-js例如,下面带有注释“Prints'bar'”的行确实​​将“bar”写入控制台。然后按照此添加用于缩放的socket.io-redis:https://github.com/Automattic/socket.io-redis上面应该允许我使用类似下面的东西:io.adapter(redis({host:'localh