Spring Reactive Redis:如果发布者或订阅者不在同一台机器上运行，PubSub将无法工作
Spring Reactive Redis是基于Spring框架的一种响应式编程模型下的Redis客户端库。它是为了支持响应式编程风格而设计的，能够利用Redis发布-订阅（PubSub）功能实现消息的发布和订阅。
在传统的Redis PubSub模式中，发布者和订阅者通常是在同一台机器上运行的，因为PubSub使用的是Redis内置的订阅机制。但是在某些情况下，发布者和订阅者可能分布在不同的机器上，这时候传统的PubSub无法正常工作。
而Spring Reactive Redis通过引入响应式编程模型，解决了传统PubSub无法跨机器运行的问题。它利用了Reactor库提供的异步和非阻塞的特性，能够在异步场景下处理大量并发的消息发布和订阅操作。通过使用响应式流处理，Spring Reactive Redis允许发布者和订阅者在不同的机器上运行，并能够实时地进行消息的发布和订阅。
Spring Reactive Redis的优势包括：
- 响应式编程模型：利用Reactor库提供的异步和非阻塞特性，实现高效的消息处理。
- 异步并发处理：能够处理大量并发的消息发布和订阅操作，提高系统的吞吐量和性能。
- 跨机器运行：支持发布者和订阅者在不同的机器上运行，解决了传统PubSub无法跨机器运行的问题。
Spring Reactive Redis适用于需要在异步场景下进行消息发布和订阅的应用场景，例如实时聊天应用、实时数据分析和监控系统等。
关于Spring Reactive Redis的相关产品推荐，您可以了解腾讯云的云数据库 Redis 版（TencentDB for Redis），它是腾讯云提供的高性能、高可用的分布式内存数据库服务，支持主从复制、读写分离、持久化等功能。您可以通过以下链接了解更多详情： https://cloud.tencent.com/product/trdb
请注意，以上内容仅供参考，具体的技术选型和产品选择还需根据实际需求和情况进行评估和决策。
相关·内容
1回答
我使用Redis PubSub消息传递系统用Python语言编写了以下代码。
发布方：
import redis
def func1(m):
queue = redis.StrictRedis(host='localhost', port=6379, db=0)
channel = queue.pubsub()
queue.publish("message", m)
if __name__=='__main__':
while True:
m = raw_input('Enter message: &
浏览 2提问于2017-04-28得票数 4
我正在学习Spring Reactive，并有以下基本的reactive演示代码。
import org.springframework.web.reactive.function.client.WebClient;
// other imports etc
@Slf4j
class WebClientTests {
private static String baseUrl = "http://localhost:8080";
private static WebClient client = WebClient.create(baseUrl);
@Test
浏览 2提问于2021-06-07得票数 1
我们希望在spring boot集群环境中实现websocket。我们使用JWT进行身份验证。我知道我们可以使用ActiveMQ或RabbitMQ作为stomp代理。但是我们已经在使用redis了，我们能不能使用redis，因为我们不想增加维护另一个消息服务的额外开销？
浏览 3提问于2017-08-28得票数 3
1回答
我正在使用docker和redis来了解docker中的多容器是如何工作的。我正在使用下面的简单flask应用程序，它有一个发布和订阅code.However，我看不到订阅者收到的任何消息 import redis
from flask import Flask
app = Flask(__name__)
client = redis.Redis(host="redis-server", decode_responses=True)
def event_handler(msg):
print("Handler", msg, flush=True
浏览 48提问于2020-08-26得票数 0
回答已采纳
1回答
我有一个实时的and应用程序，客户端接收来自多个Redis PubSub通道的更新，它是用和redis-py构建的。
我正在查看中的示例。当客户端为一个频道发送订阅消息时，它会产生一个新的“绿色”。然后，绿包订阅Redis PubSub频道并阻塞，直到收到消息为止。
class GameNamespace(BaseNamespace):
def listener(self, chan):
red = redis.StrictRedis(REDIS_HOST)
red = red.pubsub()
red.subsc
浏览 1提问于2012-04-19得票数 3
当我们启动Google PubSub客户端时，我们遇到了非常高的延迟。消息在客户端初始化后的几分钟内不会到达。
当查看Google Cloud控制台时，我们确实可以看到google.pubsub.v1.Subscriber.StreamingPull调用具有非常高的延迟(大约8分钟)：
这是预期的行为吗？如果不是，导致此问题的原因是什么？
诚挚的问候
浏览 0提问于2018-10-15得票数 4
1回答
我有四个不同的Redis订阅设置在Azure。我还有四个App，每个服务都使用一个Redis订阅。四个App /Redis订阅用于相同的代码库，但环境不同。我用的是测试、分期、东海岸和西海岸的生活环境。
在每个应用程序服务中运行的代码完全相同。
我有一个使用ASP.NET的StackExchange.Redis核心Web项目。在我的Web项目中，我连接到Azure中设置的Redis订阅，它对应于App的环境。作为Web项目启动过程的一部分，我打开了四个PubSub通道。
对于测试、分阶段和西海岸活动环境，创建了四个PubSub通道并正常工作。我可以通过Azure连接到Redis控制台，并运行P
浏览 1提问于2018-04-26得票数 0
回答已采纳
我正在使用Spring Webflux + Reactive Redis，我的目标是使用Redis作为文件缓存。 我一开始试着用~100MB的ByteBuffer设置一个密钥，但没有起作用。我与调试器进行了两次检查，以确保文件确实被读取到内存中，而且确实是这样。我想“也许Redis不喜欢”大“字符串？”所以我试着用下面的代码，仍然没有骰子。我认为这可能是ACL相关的问题，但我检查了一下，默认用户可以访问所有内容。“也许Spring不能访问Redis?”没有，我在redis-cli中检查了监视器输出，GET命令接收正常，但没有SET命令的迹象。有什么建议吗？ 这是我的控制器： @Request
浏览 27提问于2021-01-12得票数 0
回答已采纳
堆栈: Nodes.js: v4.5.0，Redis: 3.2.100，Node-redis: 2.6.2 ()
我试图使用"pubsub“命令来查找频道的订阅数量。
PUBSUB <subcommand> ... args ...
找不到节点-redis API中可用的"pubsub“命令。在node.js环境中，请帮我获取频道的红线订阅数。
浏览 4提问于2016-10-19得票数 1
回答已采纳
5月1日快乐，
我正在做一个简单的POC来利用PusSub的死信主题特性。我将订阅配置为在20次最大传递尝试之后将邮件重新发布到一个单独的死信主题(下面是使用的订阅拉码和示例消息)。
注意:我使用云控制台配置了订阅。
Problem/challenge:即使尝试了36次传递，测试消息仍然没有被重新发布到死信主题。根据文档，我将假设我的测试消息将被重新发布到死信主题，并且不应该在20次尝试之后传递。我遗漏了什么？
请求订阅代码
const {PubSub} = require('@google-cloud/pubsub');
var moment = require(
浏览 3提问于2021-05-01得票数 1
1回答
到目前为止，我一直在这样做：
import (
_redis "gopkg.in/redis.v3"
"strconv"
"time"
)
type Redis struct {
Connector *_redis.Client
PubSub *_redis.PubSub
}
var redis *Redis = nil
func NewRedis() bool {
if redis == nil {
redis = new(Redis)
redi
浏览 2提问于2015-08-31得票数 1
回答已采纳
1回答
我有一个问题，想要解决以下问题的体系结构：
我有一个web应用程序(生产者)，它可以根据请求接收一些数据。我也有许多进程(消费者)应该处理这些数据。1请求生成1批数据，仅由1个使用者进行处理。
我目前的解决方案是接收数据，用Redis将其缓存在内存中，通过消息通道发送一条消息，即当使用者在同一通道上侦听数据时，数据已经写入，然后数据由使用者处理。这里的问题是，--我需要阻止多个消费者使用相同的数据。那么，我如何才能告知其他消费者，我已经开始从事这项工作？
生产者代码(烧瓶端点)：
data = request.get_json()
db = redis.Redis(connec
浏览 0提问于2018-08-07得票数 0
回答已采纳
1回答
我创建了一个简单的Django通道使用者，它连接到Redis通道并从这个通道接收一些数据，我想将这些数据发送到前端。
使用者能够连接到使用者并接收数据；问题是，如果我试图在使用者运行时加载页面，页面将在加载时被卡住。我确信这是因为与Redis通道的连接是一个阻塞操作，或者可能是线程的问题。我对这个概念很陌生，所以我决定提出一个问题。
这是我的消费者：
class EchoConsumer(AsyncConsumer):
async def websocket_connect(self, event):
self.send({
'
浏览 3提问于2020-04-09得票数 1
回答已采纳
1回答
我有一个python程序如下
import json
import threading
import redis
CHANNELS_PREFIX = 'client'
class Listener(threading.Thread):
STOP = 1
CONTINUE = 0
def __init__(self, r):
threading.Thread.__init__(self)
self.redis = r
self.pubsub = self.redis.pubsub()
浏览 0提问于2019-04-23得票数 1
回答已采纳
我是redis的新手，我正在使用spring data redis来实现一些任务队列特性。既然我想做一些故障转移检查，有没有办法像命令"pubsub numsub“那样获取特定通道的订阅者数量。非常感谢
浏览 71提问于2021-08-02得票数 1
1回答
我试图在Go中使用Redis PubSub，以便能够传递/发布消息，并在订阅期间检索它。
我已经能够正确地设置代码的发布和订阅/ PubSub部分。下面是我的密码。我希望在订阅期间检索的(string)消息是test message.，但是，我的代码的输出给出了通道、种类和计数，并且没有显示预期的消息(test message)。
在Go中使用Redis发布/订阅后，我如何才能获得预期的消息(**test message**)？，我觉得我已经接近了，但是我可能在这里错过了一件小事情。我对Redis很陌生。谢谢你的帮助。
以下是我的代码：
package main
import (
&
浏览 3提问于2021-08-18得票数 0
回答已采纳
2回答
假设有一个redis客户机订阅通道c1，另一个redis客户端将“数据”发布到通道c1。
此时，当订阅"c1“的客户端获得数据(通过调用pubsub.listen()或pubsub.get_message())或通过redis服务器直接订阅通道c1时，发布的数据是否在redis服务器中挂起？
换句话说，当redis客户端调用pubsub.getMessage()或pubsub.listen()时，redis客户端是向redis服务器发送请求以获取数据，还是只从本地套接字缓冲区获取数据？
当我阅读一些文档时，它是说pubsub.get_message()在内部使用select模块作为套接
浏览 6提问于2015-12-29得票数 0
回答已采纳
根据这里：
当发布者向队列发送消息时，不应填充时间戳字段。因此，这让我认为，每当PubSub从发布者那里获得消息时，它都会自动附加一个时间戳。
这是正确的吗？
浏览 0提问于2018-03-11得票数 6
如何在redis的pubsub和阻塞操作之间进行选择？
Redis提供了像BLPOP这样的阻塞操作，它会阻塞操作，直到可以从列表中弹出一个元素。为什么我不应该使用它来实现PUBSUB的功能。PUBSUB允许您定义比基本列表更高级别结构的通道。如果我的用例很简单，没有多个通道，我可以使用基本的阻塞操作吗？
浏览 0提问于2014-04-26得票数 6
我有一个简单的python函数，在这里，我只需要从公共主题中获取输入，然后打印出来。
import base64,json
def hello_pubsub(event, context):
"""Triggered from a message on a Cloud Pub/Sub topic.
Args:
event (dict): Event payload.
context (google.cloud.functions.Context): Metadata for the event.
"&
浏览 2提问于2020-09-23得票数 2
回答已采纳
我无法将文档保存到couchbase。
这是我的代码库。我在码头经营库奇基地。
我使用查询在DB中手动添加了一个文档。
repo.findAll()可以正常工作，但是repo.save(person)不能工作。
有人能帮我一下吗？
Person.java
@Document
@Getter
@Setter
@AllArgsConstructor
public class Person {
@Id
private String id;
@Field
@NotNull
private String firstName;
@Field
@
浏览 0提问于2018-03-10得票数 1
回答已采纳
import redis
import threading
class Listener(threading.Thread):
def __init__(self, r, channel):
threading.Thread.__init__(self)
self.redis = r
self.pubsub = self.redis.pubsub()
self.pubsub.subscribe(channel)
def run(self):
for item in self.pubsub.listen():
浏览 3提问于2013-11-24得票数 2
一旦您从Publisher收到数据，是否可以回复消息。它必须是一个直接的答复，一旦出版商发布了一条消息。我在使用谷歌PubSub服务。
Publisher/Sender (PHP)：
$sendToOps =[];
$sendToOps['MESSAGE'] = "my message";
$topicName = env('GOOGLE_CLOUD_TO_OPS_TOPIC');
$pubSub = new PubSubClient();
$topic = $pubSub->topic($topicName);
$ret = $to
浏览 2提问于2020-12-10得票数 0
回答已采纳
我需要在同一台机器上的两个应用程序之间共享一些队列，一个是Tornado，它偶尔会向队列中添加消息，另一个是从cron运行的python脚本，它在每次迭代中都会添加新消息。有没有人能给我推荐这个模块？(使用redis可以解决这个问题吗?我尽量避免使用mysql )
浏览 0提问于2013-08-04得票数 0
1回答
谷歌PubSub是否适用于低容量(10 msg/秒)但任务关键的消息传递，其中保证在任何固定的时间段内及时传递每条消息？
或者，它是否非常适合高吞吐量，在这种情况下，个别消息可能会偶尔丢失或无限期延迟？
编辑:重新表述这个问题: PubSub中的任何特定消息，无论产生的消息量如何，都可以无限期延迟，这是真的吗？
浏览 6提问于2017-01-24得票数 3
1回答
我正在编写一个应用程序，其中一个进程应该将数据发送到多个订阅通道。这个过程事先不知道频道(因为客户端订阅了不同的主题)，所以我需要查询所有活动的订阅，以了解要获取和发送哪些数据。我找到了Redis命令：
127.0.0.1:6379> pubsub channels
但是: 1.它总是返回一个空的list。2.我在Jedis或Spring实现中找不到Java的等价物。
浏览 3提问于2015-11-18得票数 1
我无法让Actuator与Spring Boot v2.0.0.M2和Netty一起工作。在build.gradle中使用以下依赖项
compile "org.springframework.boot:spring-boot-starter-actuator"
compile "org.springframework.boot:spring-boot-starter-data-redis-reactive"
compile "org.springframework.boot:spring-boot-starter-webflux&
浏览 14提问于2017-07-26得票数 1
回答已采纳
我不认为pubsub有可能使用我的JID订阅，但有时会匿名发布，就像在MUC中一样。我慢慢地但肯定地意识到pubsub并不像它实际应该的那样灵活..太糟糕了..。
浏览 0提问于2012-05-17得票数 0
我正在设置一个主题，并试图授予gmail向该主题发送电子邮件通知的权限，但API调用抛出了“用户未被授权执行此操作”。当我从尝试时，我得到了相同的错误。顺便说一句，我最近开始看到这个问题。它以前工作得很好。
POST https://pubsub.googleapis.com/v1/projects/macro-xxxxx-xxx/topics/exxxxx-inxxx:setIamPolicy?key={YOUR_API_KEY}
{
"policy": {
"bindings": [
{
"role
浏览 3提问于2016-03-12得票数 6
1回答
在spring-data-redis-reactive中，写入操作返回redis执行结果，这使得链接运算符变得非常困难。以Redis in Action第一章中的reddit为例。我试图像这样重新实施：
@Service
public class ArticleService {
private final ReactiveStringRedisTemplate redisTemplate;
private final long voteScore = 432L;
public ArticleService(ReactiveStringRedisTemplate
浏览 2提问于2020-04-17得票数 0
回答已采纳
1回答
我一直有问题，配置卡夫卡和Redis一起在拉拉维尔。
我能够运行Redis来使用内存数据库.所以Redis工作得很好。
$redis = app()->make('redis');
return $redis->get('name1'); // it runs fine returning value of "name1"
我能够在我的windows系统中配置Kafka，在这里我可以在终端中生成和消费消息。
成功地将Rdkafka配置为php客户端库和扩展。
我在Laravel为卡夫卡使用的软件包是"superbalist/l
浏览 0提问于2018-12-17得票数 0
我们知道命令会阻塞Redis服务器，所以需要使用*SCAN命令。
据我所知，Redis服务器可以处理很多pubsub连接。那么，如果我在这样的服务器上调用命令，在执行此命令期间，它是否可以处理pubsub连接或其他命令？
浏览 13提问于2016-07-15得票数 0
我有一个用Node.js编写的基本Web，它将一个对象作为一个HSET写入一个Redis缓存。两人都在码头集装箱里运行。
我有一个Python脚本运行在同一个VM上，它需要查看Redis缓存，然后在出现新的HSET或对HSET中的字段进行更改时运行一些代码。
我遇到了Redis /Sub，但我不确定这是否真的是正确的使用方式。
为了进行测试，我创建了两个Python脚本。第一个订阅消息传递系统：
import redis
import json
print ("Redis Subscriber")
redis_conn = redis.Redis(
host=
浏览 15提问于2022-11-15得票数 0
回答已采纳
3回答
在过去的9个月里，我一直在做一个CQRS项目(我的第一个项目)，这是一个沉重的学习曲线。我目前在我的写模型中使用JOliver的优秀的EventStore，在我的读模型中使用PostGresSql。
我的读数据库和写数据库都在同一台机器上，这意味着当对写数据库进行更改时，在同一同步调用中也会对读模型进行更改。
当我在学习CQRS时，我觉得这是最好的方式，因为我没有使用MassTransit、NServiceBus等消息队列/服务总线框架的经验。
我现在已经准备好了我的大部分架构，可以引入消息队列框架了。
今天，我遇到了Redis MQ，它是ServiceStack的一部分，因为我们已经将Ser
浏览 2提问于2012-12-10得票数 5
回答已采纳
EdgeX默认使用Redis PubSub作为其消息传递总线()。
我已经在本地启动了Redis服务器。
我已经运行了Core数据和/或设备服务，我认为默认配置为使用Redis Pub/Sub。
我有一个虚拟设备服务，它将数据发布到edgex/events/#主题()。
最后，我已经将我的应用程序服务配置为订阅主题edgex/events/#，如示例所示。
[Trigger.EdgexMessageBus]
Type = "redis" # message bus type (i.e "redis`, `mqtt` or
浏览 6提问于2022-08-22得票数 0
回答已采纳
2回答
描述
I有一个卡夫卡连接分布式模式的pubSubSource连接器，它只是简单地从PubSub订阅中读取并写入一个Kafka主题。问题是，即使我要向GCP PubSub发布一条消息，我也要在我的Kafka主题中写两次这个消息。。
如何繁殖
部署Kafka和Kafka连接
创建具有以下pubSubSource配置的连接器：
内容类型: application/json“-d”{“名称”："pubSubSource"，"config"：{ "org.apache.kafka.connect.json.JsonConverter"，"key.c
浏览 1提问于2021-02-24得票数 1
回答已采纳
我需要帮助来解决gcp pub/sus的问题。我有一个进程，它向pubsub发送100条带有过滤器的消息，另一个应用程序(在spring boot中)接收这些消息。当spring boot应用程序从pubsub (而不是pull)接收消息时，处理100条消息，但进入进程时，接收更多消息，在不同的时间接收不同数量的消息，任意时间接收120条，另外140条，其他超过200条。我没有找到任何解决方案，这是我的代码：
@Bean
@ServiceActivator(inputChannel = "pubsubInputChannel")
public Messa
浏览 0提问于2019-06-11得票数 3
要订阅哨兵故障转移，通道的名称是什么，以及如何检测到需要刷新订阅函数中的主程序？
我有一个使用Redis实现高可用性和故障转移的多节点Redis设置。
我需要设置一个Pub/Sub到Redis，以检测Redis何时失败并且系统已经选择了一个新的Master。
_sentinel = redis.sentinel.Sentinel([(app.config["REDIS_HOSTNAME"],app.config["REDIS_SENTINEL_PORT"])])
_master = _sentinel.master_for(app.config["RED
浏览 1提问于2016-12-02得票数 1
堆栈:Ruby2.3.1，Rack，瘦
简单的websocket服务器：
require 'redis'
require 'em-hiredis'
require 'faye/websocket'
require 'json'
ws_channel = {}
App = lambda do |env|
$redis ||= EM::Hiredis.connect('redis://127.0.0.1:6379')
if Faye::WebSocket.websocket?(env)
ws = Faye::We
浏览 3提问于2017-02-27得票数 1
回答已采纳
我有一些代码，基本上是做这个psudocode()
registerCamera(id) {
createRedisPubChannel("Camera_"+id)
}
cameraDisconnect() {
removeRedisSubChannel("Camera_"+id)
}
然后我通过那个通道和那个摄像头沟通，这样我就可以有多个引擎了。
我还可以构造代码，这样就不需要为每个摄像机创建一个频道了。我可以创建一个名为"cameraComms“的频道，并确保每条消息都包含一个照相机id。
我想知道这两种设计模式都有什
浏览 1提问于2016-06-21得票数 0
回答已采纳
我正在测试redis-py：。
我很难弄清楚如何调用redis命令PUBSUB channels并获得输出。
浏览 39提问于2019-10-25得票数 0
回答已采纳
1回答
我需要将发行者的身份与PubSub主题联系起来。
例如，如果用户发布消息，我需要捕获用户ID。
如果服务帐户发布消息，则需要捕获服务帐户。
浏览 2提问于2022-07-14得票数 0
我正在尝试使用python订阅redis中的keyspace事件。我希望在调用.psubscribe()之后不要使用.listen()的for循环。这个是可能的吗？ 我已经用KEA启用了所有的键空间事件。 def subscribe(self, key, handler):
# this function never gets called, if I don't add the for-loop with listen() below
def event_handler(msg):
print('Handler
浏览 72提问于2019-03-12得票数 9
1回答
为什么我没有收到我的订阅更新？
、、、、
我正在尝试设置GraphQL Subscriptions，但它似乎连接到后端，但它并没有推动任何更新。
在前端，我正在使用Nuxt 2，这就是我试图让它工作的方式：
这是我的测试查询
export const pendingInquiresSubscription = () => {
return gql`
subscription PendingInquires {
countPendingInquires {
amount
}
}`
}
页面组件上的smartQue
浏览 14提问于2021-12-20得票数 1
我是redis的新手，我注意到所有的在线服务都有不同数量的连接，这取决于价格。我还想知道一个实时聊天应用程序需要多少内存才能不需要存储聊天数据。
例如，一项服务提供25MB和10个免费连接。
我正在构建一个聊天应用程序，我正在使用nodejs/mongodb/socketio。当应用程序加载时，我创建到数据库的连接，就这样。是否有多个连接在后台发生？如果两个人同时连接到我的应用程序，并调用一些需要数据库连接的函数，这是否意味着正在使用两个连接？这是我以前甚至没有考虑过的事情。
更具体地说，考虑到我的应用程序正在使用socketio，而我正在考虑使用redis，那么redis连接的数量是否与we
浏览 1提问于2014-06-11得票数 0
1回答
在我们的PubSub / C# / .Net6 WebAPI项目中，它只触发一个订阅者，而不是在开发人员机器上运行时触发所有订阅者。在开发人员机器上，我们在Docker下运行，并将Dapr配置为使用pubsub.redis作为pubsub。在我们的活动服务器上，我们在K8s下运行，并使用Azure作为pubsub，这很好地工作，将消息分发给所有订阅者，这表明代码是正确的；这表明这与配置有关。
在开发人员机器上，我可以在日志中看到它调用订阅，响应包含不同主题订阅的列表和注册以处理主题的端点。
当消息发布时，它只由其中一个订阅者处理。获取消息的服务似乎各不相同，有时报表服务将处理它，另一些时候客户
浏览 11提问于2022-09-15得票数 0
回答已采纳
1回答
我需要在特定通道中的一台计算机(Setter)上发布消息，并在其他计算机(处理程序)上获取消息。问题是每个处理程序都应该处理唯一的消息。
正如我在中所看到的，没有标准的方法可以从通道弹出消息，也许我试图以错误的方式使用它？
下面是处理程序的代码：
import redis
r=redis.Redis()
pubsub = r.pubsub()
pubsub.subscribe('test_channel')
for item in self.pubsub.listen():
...
以下是setter的代码：
import redis
r = redis.
浏览 1提问于2017-11-20得票数 0
回答已采纳
1回答
我有一个云函数，它将消息发布到PubSub，并触发云运行来执行归档文件过程。当有大文件时，我的cloud Run python代码需要一些时间来处理数据，它看起来像是PubSub在20秒(默认确认截止时间)后重试消息，这将从我的Cloud run触发另一个实例。我已经将确认截止时间增加到600秒，并重新部署了所有内容，但它在20秒后仍在重试消息。我遗漏了什么吗？ 云函数发布消息代码： # Publishes a message
try:
publish_future = publisher.publish(topic_path, data=message_bytes)
浏览 17提问于2021-07-02得票数 2
回答已采纳
当我在两个不同的服务器上部署redis服务器和spring服务器，并试图通过我的应用程序连接到spring服务器时，我遇到了这个问题。
应用程序详细信息：
我们有移动应用程序，发布gps坐标到spring服务器使用stomp。在spring服务器中，我们创建jedis pubsub连接，并将这些gps数据发布到我们的web应用程序，web用户订阅这些jedis pubsub连接。
库版本：
stomp:1.7.1
绝地武士: 2.8.1
spring: 4.3.0
工作场景：
*在本地部署spring服务器，在远程生产服务器部署redis服务器。
*在远程服务器上部署spring服务器，在部署
浏览 0提问于2017-05-18得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
云直播活动推荐
腾讯云开发者
