- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
我花了将近 2 天的时间在谷歌上搜索和搜索,试图找出我的设置有什么问题。我所有的服务都在一个 Docker 容器中运行,所有服务都正确连接(我已经测试过了)
我在连接到 Redis 的 Node.JS 上有一个最小的 Socket IO 服务器:
require('longjohn');
require('dotenv').load({silent: true});
process.env = process.env || {};
var PORT = process.env.SOCKET_PORT || 4567;
var io = require('socket.io').listen(PORT);
var redis = require('socket.io-redis');
io.adapter(redis({
host: process.env.REDIS_HOST || 'redis',
port: process.env.REDIS_PORT || 6379
}));
io.on('connection', function (socket) {
console.log(`New connection!`);
}
当我在 Redis 上监控这段代码时,我得到:
1520713149.833184 [0 172.20.0.8:40858] "info"
1520713149.833631 [0 172.20.0.8:40860] "info"
1520713149.834154 [0 172.20.0.8:40862] "info"
1520713149.839510 [0 172.20.0.8:40860] "subscribe" "socket.io#/#"
1520713149.840678 [0 172.20.0.8:40862] "subscribe" "socket.io-sync#request#/#"
然后是一个连接并发送到 Redis 的 php 应用程序
<?php
require(__DIR__.'/vendor/autoload.php');
$client = new Predis\Client([
'scheme' => 'tcp',
'host' => 'redis',
'port' => 6379,
]);
$client->connect();
$emitter = new SocketIO\Emitter($client);
$emitter->emit('event', 'payload str');
在 Redis 上:
"PUBLISH" "socket.io#emitter" "\x92\x83\xa4type\x02\xa4data\x92\xa5event\xabpayload str\xa3nsp\xa1/\x82\xa5rooms\x90\xa5flags\x90"
所以看起来所有的东西都来到了 REDIS,但是 socket io 服务器因为未知原因没有得到事件。
我在考虑不同的 channel socket.io#emitter
、socket.io#/#
和 socket.io-sync#request#/#
两者都使用。但是在我阅读的所有文章中,他们都没有使用或更改它们。
所以可能是包版本不匹配?但是下面这个版本都是我同事用的。。。(这个问题我问他们了,还在找)
在 PHP 上,我将 composer 与:
{
"require": {
"rase/socket.io-emitter": "^0.7.0",
"predis/predis": "^1.0"
}
}
在 Socket IO 服务器上,npm 有:
{
"dependencies": {
"dotenv": "~1.2.0",
"longjohn": "~0.2.9",
"socket.io": "~1.3.7",
"socket.io-redis": "^1.1",
}
}
如果有人有想法,我将不胜感激;)
编辑:我的同事使用 Vagrant,我尝试看看是否有什么不同,是的,socket.io 服务器订阅的 channel 有所不同。它是 psubscribe""socket.io#*
而不是 socket.io#/#
但他们没有触及任何相关内容并且两者的来源相同(docker和流浪者)有点疯狂吧?..
最佳答案
好吧,把问题和解决方案分开。这里的问题就出在我对socket IO和Redis的理解和经验不足上。
当客户端通过 Redis 发出时,我希望有一个新的连接。事实上,并非如此,新连接只会来自连接到 IO 套接字的客户端。我使用 DEBUG=* 查看服务器上发生的一切,确实是的,套接字 IO 从 REDIS 获取信息。我是错误的,缺乏经验只关注 channel 名称。
我希望它能对 Socket IO 和 Redis 的新学徒有所帮助 :)
关于php - 带 REDIS 的套接字 IO。服务器收不到 channel 消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49214303/
我很好奇为什么以下不起作用。一般select用default:防止死锁,但在这种情况下不是: package main import "fmt" func main () { a := mak
我一生都无法弄清楚如何切换图像排序。图像以 (x,x,3) 格式读取,theano 要求它是 (3,x,x) 格式。我尝试更改顺序numpy.array([img[:,:,i] for i in ra
我正在向 libnl 发送单个 SSID 和频率进行扫描,但我得到了多个扫描结果以及我请求的 SSID 和频率,但我需要单个扫描结果(仅适用于请求的 SSID),如何实现这一点。请帮助我,我也发送了我
我是 Golang 的新手,但正在努力理解这门伟大的语言!请帮帮我.. 我有 2 个 channel 。 “进”和“出” channel in, out := make(chan Work),
例如我有这段代码: package main import ( "fmt" ) func main() { c1 := make(chan interface{}) close
我们使用以下调用来获取经过身份验证的用户的 ChannelID,它适用于大多数情况。一些 YouTube 用户将他们的 channel 连接到 Google+ 信息页,但在这种情况下,我们的一位用户无
case 'sinfo': const sinfo = new Discord.MessageEmbed() .addField('Server Name 🔎 :', message.guild.n
我需要让所有 channel 来创建一个 bunker 命令,这使得所有 channel 都是只读的。 最佳答案 他们变了Client.servers至 Client.guilds在 newer ve
为什么当第二个值通过另一个 go routine 发送并且没有收到发送的第一个值时, channel c 没有缓冲? package main import "fmt" func sum(s []in
据我所知,内置的 split 会将一个 3 channel Mat 拆分为三个 1 channel Mat。结果,这三个 Mat 只是具有一些不同强度的灰度。 我的意图是获得三个 3 channel
如何检测当前的 RAM 配置?我需要询问 Windows RAM 当前是在单 channel 、双 channel 还是四 channel 中运行。 我搜索了很多,并没有在这个网站或其他网站上找到任何
我需要拆分一个多 channel wav 文件并将每个 channel 编码为 mp3 文件。 我知道 gtresamer 的 deinterleave 插件,但我不确定如何将它用于 wav 文件以及
关闭。这个问题需要details or clarity .它目前不接受答案。 想要改进这个问题吗? 通过 editing this post 添加详细信息并澄清问题. 关闭 8 年前。 Improve
我正在尝试运行 Hyperledger Fabric 网络,它由单个订购者、单个对等节点和一个 cli 组成。为了学习启动 Hyperledger Fabric 网络的过程,从创建与加密相关的工件到将
我在 Laravel 中使用事件广播。我正在使用基于角色的通知访问权限。我有用于广播的自定义 auth guard。当用户连接到 channel 时,客户端将具有内部权限的 access_token
我正在编写一个使用 Elixir Channels 来处理实时事件的应用程序。我知道每个客户端将打开 1 个套接字,并且可以在其上多路复用多个 channel 。所以我的应用程序是一个聊天应用程序,其
我有一些 .wav 文件,我想转换它们的频率 (fs) 和 channel 数 (nchannels)。我在jupyter笔记本python3.6上使用ffmpeg。我使用了以下命令并且它有效。 cm
我有一个视频渲染器,它需要两个 H265 流(YUV420),我需要烘焙它们以使它们中的一个与另一个形成 alpha 蒙版。这一切都已解决并且效果很好,但是如果我按照此处的说明进行操作: ffmpeg
我运行此命令以便能够将 udp 直播流传输到可使用正在构建的移动应用程序播放的 http 直播流。 它只是一个只有音频流的流。 ffmpeg -i udp://@localhost:1111 -map
我在我的 discord.js 机器人中创建了 nuke 命令,它创建了具有相同名称、权限、主题等的 channel ,并删除了“原始” channel 。但是有一个问题,如何使 channel 与“
我是一名优秀的程序员,十分优秀!