我有两个同一个java应用程序的实例，它们使用spring和rabbitmq。实例向队列发送消息，但我无法预测哪个实例将使用它(如预期的那样)。
我更新了java应用程序。由于某些原因，旧版本和新版本之间不兼容:新版本不能使用来自旧版本的消息，反之亦然。
我们不能在部署新版本的同时中断服务，因此不能同时停止这两个实例。我们必须停止实例A，用更新重新启动实例A，然后停止B并使用更新重新启动它。
当我有A的新实例和B的旧实例时，如果消息是由B生成的，A就不能按预期的方式使用它们。
为了解决这个问题，我们的想法是在rabbitmq消息中添加一个标头。我创建了一个定制的rabbitmq模板：
@Ove
浏览 1提问于2017-01-12得票数 0
回答已采纳
1回答
我需要一种方法来管理连接到托管弹性搜索提供商，以加快我的网站上的搜索。我们在Heroku上运行Django，使用的是Found Python附加组件和ElasticSearch ElasticSearch库。
使用pyes建立到ElasticSearch的连接的标准方法是将提供者URL传递给ES对象，如下所示：
(1) connection = ES(my_elasticsearch_url)
Pyes在后台使用ES对象建立到我的ElasticSearch提供程序的开放HTTP连接，因此我可以像这样运行搜索：
(2) results = connection.search(some_query
浏览 1提问于2012-08-25得票数 4
回答已采纳
1回答
我在RMQ中遇到了回调队列功能。而且还挺花哨的。整个想法是，我创建了一个消息队列(queue1)，它的回调队列(Queue1_cb)和它的dlq(queue1_dlq)。我正在用两个节点实现HA功能。
当我部署应用程序的两个实例(在Spring 中有一个发送方和一个接收方应用程序)时，问题就出现了。两者都在监听同一个HA集群。情况如下。
发件人向RMQ发布消息。
接收应用程序会消耗信息。接收应用程序必须调用第三方API，这是基于套接字的API及其异步的，所以我不能在相同的连接中得到响应。因此，我存储通道& message 的对象，这是我需要对消息进行加密的。(请注意，在收到第
浏览 2提问于2018-08-27得票数 0
回答已采纳
当前，在多个EC2实例上运行多个作业(shell脚本)。EC2s不是相互链接的。任务由cron在一个固定的时间运行。
我应该使用什么服务/配置来确认作业A已经在EC2上完成并在另一个EC2上运行作业B？
(如果EC2上的作业A未完成，则不会执行另一个EC2上的作业B。)
如果你也能给我一些可供参考的页面，那将是有帮助的。
浏览 3提问于2021-07-14得票数 1
回答已采纳
嗨，我正在做一个项目，可能正在使用Heroku上的RoR，它为另一个运行C++服务器的EC2实例提供RoR服务。我知道有从Heroku ()访问EC2实例的资料，但我还没有看到相反的资料。
我想知道，如果两个实例都托管在美国东部地区，是否有办法从EC2 C++服务器向Heroku服务发出低延迟请求？(在上面的链接中提到的内容正好相反。)
我确信在C++实例和Heroku之间使用普通的HTTP请求是可行的，但我想知道是否有更好的解决方案。谢谢!
浏览 0提问于2012-06-08得票数 0
回答已采纳
我们希望使用resque来对一堆作业进行排队，并由工作人员来处理它们。当作业等待处理时，我们想知道它们在队列中的位置(作为它们必须等待多长时间的指示器)。我们如何找到作业在队列中的位置？
提前谢谢。
浏览 0提问于2012-09-30得票数 1
回答已采纳
我正在尝试确定集群我的ServiceMix 3.3.1/Camel2.1/AMQ5.3应用程序的选项。我正在执行大容量的消息处理，我需要集群来实现高可用性和水平可伸缩性。
下面是我的应用程序的基本功能...HTTP->QUEUE->PROCESS->DATABASE->TOPIC
from("jetty:") .to("activemq:inboundQueue")；
from("activemq:inboundQueue?maxConcurrentConsumers=50") .process(decode()) .pr
浏览 3提问于2010-02-09得票数 11
回答已采纳
1回答
我有两个关于狂犬病消费者(接受者)的问题：
我如何定义(静态地从队列中)注册到某个队列的使用者是什么，以便如果有一个使用者下线，消息仍然会在该使用者再次上升之后被传递，或者有其他方法来实现这一点？
消费者如何连接到一个仍未创建的队列，在rabbitmq教程中，我可以在生产者之前给消费者打电话，它仍然能工作，有人能解释一下这是如何工作的吗？
谢谢
浏览 1提问于2016-06-23得票数 0
回答已采纳
我有以下代码的变体：
package com.test.package;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class TestClass {
public static class MyRunnable implements Runnable
浏览 3提问于2014-07-08得票数 5
回答已采纳
4回答
我在azure中有一个简单的工作角色，负责在SQL azure数据库上进行一些数据处理。工作人员基本上是每隔2分钟将数据从第三方数据源添加到我的数据库中。当我有两个角色实例时，这显然是不必要的加倍。我希望有2个实例的冗余和99.95正常运行时间，但不希望它们同时处理，因为它们只会重复相同的作业。有没有我遗漏的标准模式？我知道我可以在数据库中设置标志，但我希望有另一种更容易或更好的方法来管理它。谢谢
浏览 1提问于2011-01-14得票数 9
回答已采纳
1回答
在Amazon AWS中使用Auto Scaling时，我无法确定如何保护我的ECS任务实例。我有一个长时间运行的任务，可以根据需要向外扩展，但我希望将正在运行的任务实例标记为“不可破坏”。我找到了几个关于实例保护的资源，例如：
(因为我使用的是python) API文档在这里：
此方法需要一个InstanceId，因此我尝试使用如下命令获取当前容器的实例id：
卷曲
但是，此方法仅返回运行任务的EC2计算机的实例id。所以我的问题是:有没有办法获得docker任务实例的实例id (如果它存在的话)？如果没有，是否有其他方法可以防止Auto Scaling终止仍在运行的任务？我是否必须编写
浏览 0提问于2017-02-20得票数 0
1回答
我有两个web服务，其中一个在磁盘上创建资源供另一个读取和处理。资源可能会发生不规则的更改，因此我希望在更新资源时通知使用者服务，而不是轮询和保存文件时间戳或重新启动服务。
问题是，我打算复制消费者。使用Docker，您可以组成一组服务，并复制特定的服务以实现冗余或性能。但是，这些副本位于外部世界的公共地址后面，负载均衡器决定在哪里传递特定请求。对于我的使用，每个副本将需要通知一旦一个资源被更新，以便它反过来可以保持最新。初始加载和处理成本很高，因此经常重新加载是一个错误的选择。
在Docker中，是否有一种方式将请求广播或复制到所有类型的容器？或者仅仅针对每一个运行中的容器？
如果不是因为掩
浏览 0提问于2019-02-22得票数 2
我想从公共网络复制一个文件，例如:使用AWS Lambda的s3://mypublicstorage.example.com/porn/tca-333.mp4：到我的s3存储桶中。
问题是，视频可能会很大，比如2~ 10 GB。如果我使用像superagent这样的请求库来获取它，那么所有的数据可能都会存储在RAM中，因此这是不够的。
AWS Lambda本身只有500ish MB磁盘iirc的限制。AWS Lambda到底有没有可能完成这项任务？
我当前的代码或多或少类似于：
request.get(srcUrl).then(resp => S3.putObject({Body: re
浏览 0提问于2017-12-03得票数 1
1回答
我使用下面的测试来评估吞吐量时间。当我运行本地one-node集群时，吞吐量时间约为90k消息/秒。一旦我将另一个本地节点添加到集群中，吞吐量就会下降到~5k消息/秒。我会想念任何重要的吐露吗？我配置hazelcast来跳过节点间的数据复制，所以速度应该是相同的，不管有多少节点，对吗？
我使用Hazelcast 3.11，配置如下：
<?xml version="1.0" encoding="UTF-8"?>
<hazelcast xsi:schemaLocation=
"http://www.hazelcast.com/schem
浏览 0提问于2019-06-15得票数 1
我有两种节点类型。一个Server和一个Client。当前将有一个或多个Server或Client正在运行。
使用MassTransit和RabbitMQ时，我在尝试描述的RPC模式时超时。
Server和Client的代码非常简单，便于测试。
Server的代码
class Program
{
static void Main(string[] args)
{
var serviceBus = ServiceBusFactory.New(sbc =>
{
sbc.UseRabbitMq();
浏览 0提问于2015-07-05得票数 0
1回答
我们正在尝试使用CCDT文件和JMS配置连接到IBMMQ。我们能够连接到它，但这里有一个问题：
由于我们使用spring来使用CCDT文件设置连接工厂，所以在应用程序启动时只初始化一次，但不幸的是，它一次只选择一个队列管理器，也就是说，它将所有消息发送到同一个队列管理器，并且没有负载平衡。
尽管我观察到，如果我在每个请求之前手动设置CCDT文件，那么它能够负载平衡队列管理器，理想情况下，当我将URL设置为CCDT文件时，队列管理器看起来就决定了。这是错误的做法。我的期望是用CCDT文件初始化连接工厂，然后这个配置将能够自己负载平衡。
你能帮我吗？
浏览 1提问于2018-01-23得票数 3
回答已采纳
我需要为我的爬虫“序列化”一个包含domanis名称(Strings(对象))的大型BlockingQueue( 10_000) --例如，如果我停止它，或者它会意外发生--这将有助于不爬行已经完成的操作。做这件事最好的方法是什么？在NET中，我已经将二进制序列化用于这样的任务(例如，protobuf )(它更快、更序列化，信息可视化对于理解-so并不重要，而不是必需的XML )。但是如何在java中做到这一点呢？你可能是样本的推荐人吗？
浏览 0提问于2014-09-08得票数 4
回答已采纳
1回答
我在AWS Cloud9环境中有一个带有代码的Cloud9文件。
当文件上传到特定的S3桶时，我想运行这段代码。
但是，我似乎只能使用AWS函数拥有触发器。我不知道如何在AWS Cloud9函数中添加触发器.
我在.py环境中的Cloud9文件中的简单代码是：
import boto3
import os
import sys
s3 = boto3.client('s3')
s3.download_file('our-awesome-first-test-bucket', 'test_text.txt', 'test_text_sav
浏览 2提问于2022-03-26得票数 -1
2回答
我们需要关于这个队列迁移主题的建议。
有两个JMS提供者(PROVIDER和NEWPROVIDER )连接到EMX的两个实例。每个人都有一些队列。现在，我们希望在EMX端将所有队列从提供程序移动到NEWPROVIDER。在WebSphere管理控制台，最小的工作量解决方案是将提供者的URL和身份验证更改为与NEWPROVIDER相同。
我没有看到任何直接的问题，因为它可能只影响连接池，最大连接等，但不一定要改变生产。
问题：这种方法有什么问题吗?或者我们应该删除并重新创建NEWPROVIDER下的所有队列。
为了更快地理解这一变化，我创建了一个图表。蓝色显示当前状态，红色显示更改和状态。
我们
浏览 1提问于2016-07-28得票数 3
回答已采纳
2回答
我想做一个类，只要它的一个实例是活动的，就会保持一个线程( worker )运行，当有人在它上面调用一个方法- performTaskWithData:(NSData*)data -时，它应该在它的worker线程中处理这些数据。
如果在操作发生时发送额外的数据，那么这个新的数据/操作应该排队，直到前一个处理完成。
我需要这个helper类的每个实例持有一个单一的工作线程(即同一个线程应该处理所有的处理)。
我该怎么做呢？
NSRunLoop？是否同步访问正在传递的数据块？
浏览 0提问于2011-06-30得票数 1
回答已采纳
我对volley库中的等待请求功能有一个问题。调试将我带到了java.util中的AbstractQueue类，其中有一个元素正在被添加(根据方法中的一些值，表示已成功添加到队列中)，同时没有被添加(根据队列中的0个元素，它们的值不变)。adding方法是同步的。到目前为止，你可以在下面找到详细的情况描述和我的研究。如果你能看一看，如果你知道发生了什么，我将非常感谢你。
我尝试在出现任何类型的错误时(例如，当没有连接或服务器名称不正确时)自动重试请求。请求的错误处理程序将请求添加回我的应用程序的静态单例RequestQueue。
RetriableRequestWraper.java
m_re
浏览 1提问于2015-12-22得票数 5
1回答
我有一个Java线程，它调用basicConsume(String queueName,...)从RabbitMQ服务器获取消息。
一个单独的线程可以同时在多个队列上阻塞吗?例如，在consume(List<String> queues,...)中，它从任何一个队列中返回第一个可用的项？
我看过，但没有找到任何方法来做到这一点。
浏览 6提问于2013-07-03得票数 0
回答已采纳
我正在从事一个项目，如果代理(Redis)队列始终高于预定的阈值大小，并在队列大小下降时杀死新的框，则需要推出新的芹菜服务器。我有脚本要负责介绍新的盒子，并确保正确的配置运行在它们上。我计划在频繁(15分钟)间隔后，通过redis-cli检查队列，如果大小更大，那么阈值会缩短检查(例如3分钟)之间的时间间隔，检查两次，然后推出新的框，并遵循相同的方法杀死新服务器。
我对芹菜很陌生，如果我能得到一些关于这种方法的建议，那就太好了。
谢谢
浏览 0提问于2013-04-12得票数 2
回答已采纳
我正在尝试在我的应用程序中实现一个上传队列。我将把我的RKRequest放入RKRequestQueue并调用[queue start]。但是，我们都知道，网络连接是不会永远持续下去的。我现在正在使用RKReachabilityObserver来确定何时挂起和恢复我的队列，它工作得很好(至少现在是这样，但是我听说RestKit中的可达性代码有一些问题)。这使我可以停止发送新数据，直到网络再次可用。但当网络连接断开时，所有活动的RKRequest都会发出- (void)request:(RKRequest *)request didFailLoadWithError:(NSError *)err
浏览 0提问于2012-04-10得票数 3
回答已采纳
private Queue<FrameObjectElement> _queueObject = new
Queue<FrameObjectElement>();
private static Queue<FrameObjectElement> _queueItem = new
Queue<FrameObjectElement>();
private static int permitEntryCount = 0;
private int allowThreadEntry = 0;
如上面所示，我有两个队列变量。
public Camera
浏览 7提问于2012-11-02得票数 4
回答已采纳
我想使用Windows Workflow Foundation 4.5并通过web api触发工作流。MS将终止对AppFabric的支持后，我的主机选项有哪些？我是应该使用Windows Workflow Foundation，还是应该考虑使用第三方解决方案？
这是内部部署的，我没有能力使用azure。我做了一些工作流程，看起来WWF并不难用，但不清楚如何托管它。我可以在没有AppFabric的情况下在web api项目中托管吗？
我主要关心的是，如果IIS应用程序池使用WorkflowApplication回收，或者服务器崩溃，是否能够恢复工作流。我没有使用WCF，我计划在web中使用Wo
浏览 23提问于2017-12-20得票数 1
我们有一个rails应用程序运行在连接到RDS postgres数据库的AWS EB容器中，我们希望能够在连接到同一数据库的专用EC2实例上运行一些相当密集的rake批处理过程。
我的问题是：-我们如何创建和启动这些特定于rake的实例，然后在进程运行后销毁它们？-您如何获得终端输出来调试任何问题？
谢谢!
浏览 3提问于2015-07-19得票数 1
2回答
我试着一个接一个地运行线程。我知道我可以按顺序执行这些操作，但重点是这样命令就不会阻止UI。
但是，在我提出的实现中，我不能使用std::thread，因为我不能将线程作为参数传递。
我还有别的办法可以做到吗？
这是我目前的实现：
#include <mutex>
#include <thread>
#include <queue>
class ThreadQueue {
std::queue <std::thread> threads;
std::mutex mutex_add;
std::mutex mutex_r
浏览 2提问于2016-06-15得票数 0
回答已采纳
在这里，看到我的优先级ThreadPoolExecutor -它工作很好，但问题是，它没有创建新的线程，如果实现了数量的с资源池е线程。
import java.util.Comparator;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.FutureTask;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.RejectedE
浏览 3提问于2014-04-24得票数 0
回答已采纳
我正在构建一个解决方案，其中我们将一个( service -fabric)无状态服务部署到K个实例。此服务的任务是一些工作负载(如查询)，我希望在它们之间尽可能平均地分配工作负载-并且我想使这成为一个动态解决方案，这意味着如果我决定明天从K个实例转移到N个实例，我希望工作负载拆分发生在现在将负载自动分配到N个实例的方式上。我没有为此服务指定任何分区。
举个例子：
假设我想查询一个数据库来检索特定的记录块。我有5个节点。我希望这5个节点检索不同记录集的1/5。这可以通过一些查询逻辑来实现，比如(row_id %N == K)，其中N是实例的总数，K是唯一的instance_number。
我希望
浏览 3提问于2018-12-19得票数 0
使用EC2机器的ECS可以使用服务发现吗？亚马逊网络服务的文档说了所有关于Fargate的内容，有没有人用ALB，EC2 ECS集群，服务发现做过。
浏览 3提问于2021-03-12得票数 0
2回答
例如，我希望有一个微服务发送通知(电子邮件，短信，推送通知)。对于很少的用户来说，一切都很好。经过一段时间，我们的应用程序有很多用户，所以，这个微服务没有管理，并发送电子邮件一小时后。
那么，如何处理这种情况呢？部署另一个微服务实例，但是如何处理只有一个微服务处理一个电子邮件和用户不接收多个电子邮件？
浏览 1提问于2017-05-23得票数 0
回答已采纳
2回答
是否有一种完全自动删除SQS队列的方法。我有一个解决方案，其中一个服务器在启动时创建一个SQS并订阅SNS主题。
但是，可能会出现服务器崩溃并无法恢复的情况。在这种情况下，我将用另一个服务器替换服务器，它将在启动时创建自己的队列。现在不再使用前面的队列了。
是否有一种方法可以让队列在我执行并显式删除的情况下自动删除(比如，如果队列保持空5天，它就会自动删除或其他选项)？
浏览 1提问于2018-01-12得票数 10
回答已采纳
1回答
摘要
我使用两个控制台应用程序(Stage-estimate，Stage-step)完成了我的处理，每个应用程序处理磁盘上的文件，文件被组织到文件夹中。每个文件夹代表一个处理步骤，当估计所有文件时，该步骤被视为已完成。
例如，我们位于Step 0，文件夹0包含以下文件：
文件夹0包含：
000.data
001.data
002.data
...
999.data
我们有data文件，现在我们需要估计它们，我们运行Stage-estimate应用程序1000次，结果是以下目录结构：
文件夹0包含：
000.data
000.estimate
001.data
001.estimate
002.
浏览 1提问于2015-06-23得票数 0
回答已采纳
我们需要Azure的API来存储通过HTTP发送给它的消息(代理)，以防我的系统(云服务)不可用或DB忙。要改变确切的信息发送是不容易的。在Azure做这样的经纪人有什么办法？
服务总线队列看起来很有趣，但据我所知，它需要。
另一个WebRole应该是一个解决方案，但它需要时间来实现。
一些工具的虚拟机(MSMQ?)似乎是一种方式，但它需要维护。
你认为如何？
浏览 6提问于2016-07-26得票数 0
回答已采纳
我有以下设置：
集群中的四个MQ队列管理器(QM1 (完全回购)、QM2 (完全回购)、QM3 (部分回购)、QM4 (部分回购))
所有集群发送/接收信道具有相同的等级和优先级。
每个队列管理器都有一个非集群别名队列(ALIAS.TO.CLQ)。
ALIAS.TO.CLQ有一个基本对象ALIAS.TO.FLOW，它是一个集群别名队列。
ALIAS.TO.FLOW有一个基本对象L.TO.FLOW，它是一个本地队列。
四个队列管理器中的每一个都配置为CLWLUSEQ(ANY)。
集群别名队列具有DEFBIND of NOT FIXED。消息是由IIB (MQ输出节点)
浏览 0提问于2018-12-06得票数 1
回答已采纳
2回答
在上传时启动AWS实例
、、、
我想在一个小的AWS实例(例如t2.micro)上托管一个网站，每当用户上传要处理的数据时，它就会启动一个更大的实例(例如m5.2xlarge)。我还希望在处理完成后关闭更大的实例。是否有AWS服务或其他解决办法可以做到这一点？较大的实例只会每隔几天触发一次。
浏览 3提问于2020-12-26得票数 0
回答已采纳
2回答
对于我的应用程序收到的每一个请求，它都会为许多app发送大量的URL获取请求，我希望并行地发送和处理它们的响应。
它的计算并不重，只是等待外部API的响应所需的时间。
什么是最好的，为什么使用使它平行？线？任务队列？
甚至，我还考虑将HTTP从主servlet发送到应用程序中的其他servlet。
浏览 2提问于2013-08-12得票数 1
回答已采纳
因此，假设您有一个允许用户请求作业应用程序。例如(假设)：用户上传视频。在RDBMs中创建了一个条目，其中包含blob上的视频的URL，并且状态被设置为"Pending“。
有一个循环的时间触发函数and，它每10秒左右执行一次，它从RDBMS获取10个未决作业，并执行一些压缩等操作。
这里的问题是，只要请求的数量保持在每10秒10-30个视频，我们就应该没问题。但是如果请求的数量突然增加..比方说每10秒200个请求，这意味着将有许多作业等待，用户将不得不等待比平时多10倍的时间才能看到状态变化。如何在这样的场景下自动向外扩展函数类app？它必须是手动的吗？
浏览 0提问于2020-07-01得票数 1
因此，我在生产者/消费者类型的应用程序中使用固定大小的BlockingQueue ArrayBlockingQueue，但我希望用户能够动态更改队列大小。问题是没有允许在创建后更改容量的BlockingQueue实现。以前有没有人遇到过这个？有什么想法吗？
浏览 0提问于2011-07-07得票数 10
2回答
我正在使用AWS EC2实例进行生物信息学工作。我有一个数量(~1000)的大文件，应该用EC2实例上的脚本来处理，结果应该上传回S3桶。我希望将作业(文件)分发给许多EC2实例，优先从现货价格开始。
我需要的是一个简单的排队系统(可能是AWS、SQS或其他什么)，它可以将作业分发给实例，并在实例失败时重新启动作业(因为现货价格过高或其他原因)。我已经研究过AWS示例，但它们太高级了，通常涉及自动缩放和复杂的消息生成应用程序。
有人能从概念上指出如何以最简单的方式最好地解决这个问题吗？这个AWS SQS的简单应用有什么例子吗？应该如何启动一组实例，然后如何判断如何侦听队列？
对于每个输入文件，
浏览 4提问于2015-03-04得票数 2
回答已采纳
1回答
我正在考虑一种在Rebus中管理失败消息的方法。在我的第二级重试策略中，我希望将消息和异常详细信息保存到数据库中，以便稍后可以查看错误详细信息，并决定是将消息重新发送到要重新处理还是忽略并删除。
在处理程序中，我捕获的细节如下：
public async Task Handle(IFailed<StudentCreated> failedMessage)
{
//Logic to Defer Message with rebus_defer_count not shown
DictionarySerializer dictionarySeria
浏览 0提问于2019-09-09得票数 2
我有两个控制台应用程序使用Rebus。它们都引用了定义消息(命令和事件)的程序集。控制台应用程序"A“发送命令并侦听用于日志记录的事件(例如:发送CreateTCommand和侦听TCreatedEvent)。控制台应用程序"B“(实际上是ASP.NET核心应用程序)侦听并处理命令(例如: saga由CreateTCommand发起，聚合被创建并引发TCreatedEvent)。在app "B“进程中的另一个DLL中，有一个用于TCreatedEvent的处理程序。
因此，我有一个由app "A“发送的创建命令和两个创建事件的处理程序，一个在app "A
浏览 3提问于2016-11-18得票数 2
我读到过，利用动态应用程序服务计划的Azure函数将在没有任何东西可用时缩减到零实例。在这种情况下，如果您使用队列触发器(存储或服务总线)，是否会在将某些内容推入队列时创建一个实例，或者您是否需要保持至少一个实例在运行，以便“侦听”或从队列中弹出某些内容？
浏览 16提问于2016-08-23得票数 2
回答已采纳
我试图在csv文件中可用的多个数据集上运行多个算法。因此，我希望扩展ec2实例，这样所有实例都可以在不同的数据集中并行运行。我试图找到一种方法来扩展ec2实例，并将不同的数据集(.csv)粘贴到每个实例中。注意:我不想实现排队系统并使用数据库。
浏览 0提问于2017-05-26得票数 1
回答已采纳
3回答
我有以下的理论问题。
我希望能够在Azure应用程序中创建每个角色的多个实例。至少2，以确保它是工作的24/7 (或接近24/7)。
这对于侦听数据的客户端前端和角色来说很容易。
对于处理数据并将结果保存在blobs /表存储中的工作角色来说，这也很容易，假设每个工作者角色都处理自己的数据集来创建单个结果。
但是我对这个应用程序的“中间”有个问题。
在最简单的情况下，如果我能够创建一个Azure存储“不同”队列(没有两个消息是相同的)，那么它就很容易了。但据我所知，这是无法做到的，特别是因为你一次只能下载32条消息。
所以，我需要某种控制角色.我认为。这个角色将确保工人角色不会互相干扰。
但是
浏览 0提问于2012-03-28得票数 3
回答已采纳
1回答
在弹力豆柄中运行cron作业
、、、、
因此，我在Django ElasticBean秸秆应用程序中有一个功能，它的工作方式如下：
下载文件
解析文件，使用文件中的数据运行对API的一些调用
用新数据更新EB实例的数据库
在测试实例中，我刚刚设置了一个本地cron作业。我刚刚在Django应用程序的特定URL上调用了wget，它将运行命令。
我的问题是如何在一个多实例弹性豆柄应用程序中处理这个问题。只有我的EB应用程序的一个实例应该运行这个命令。我希望避免数据库上的竞争条件和来自多个实例的对外部API的冗余调用。也就是说，只有一个实例应该写入数据库。
然而，在谷歌上搜索设置cron职位是件很尴尬的事，特别是如果你
浏览 0提问于2016-07-22得票数 7
回答已采纳
1回答
C#用同一类的多个实例处理数据束
、、、、
我们让web应用程序作为工作角色C#.NET在Azure云中运行。这个应用程序的一部分是破译不同对象中的大量短字符串(每个请求大约有2000条)。我们想使它尽可能快，我们需要管理多线程以正确的方式。
我们实现它的方式是，每个对象创建新的类实例，新线程来解密该字符串。但花了太多时间。
如果我们只构造一个类的实例并通过它运行所有数据，那么它会更快，而不是为每个对象一次又一次地构造它。
问题是，如何改进这一点。我们想做这样的事，但不知道怎么做：
我们希望创建要解密的数据池。
为每个内核创建一个线程的同一个类的多个实例(理想情况下，每个CPU核心一个)。
有某种机制向这些实例提供数据。
浏览 3提问于2015-11-02得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
