4回答
从ActiveMQ触发PHP
、、、、
背景：我们当前的系统涉及两个服务(一个是用编写的，另一个是用PHP编写的)，它们通过HTTP相互通信。我们希望使用ActiveMQ (如果需要的话)从HTTP回调迁移到基于消息的体系结构。我们可能会使用在他们之间进行通信。最终，PHP服务将用Java重写，但这不是这个项目的一部分。
问题：系统如何通知ActiveMQ系统已向订阅的队列发布了新消息？在当前系统中，回调固有地调用PHP并触发它。这与基于消息的体系结构无关。
可能的解决方案：
Cron经常调用一个PHP脚本来检查新消息。真恶心。
一个长期运行的PHP进程，它循环、休眠和检查新消息。少点恶心？
ActiveMQ在发布新消息
浏览 5提问于2010-05-27得票数 6
回答已采纳
我不知道如何在不使用size()的情况下找到队列的大小，但是我们的学校让我们编写程序，我们不允许使用size()。
浏览 7提问于2022-02-21得票数 0
2回答
PHP中的消息队列
、、、
我已经开发了一个rest api，它接受一些数据并将其存储在消息队列(Redis列表)中。现在，这些数据从redis推送到MySQL数据库中。问题是客户端需要等待数据写入mysql。
我希望客户端应该等到数据写入消息队列(Redis List)，并且将数据推送到MySQL的函数应该异步执行。我该怎么做呢？我的整个代码库都是用PHP编写的，所以我更喜欢用PHP编写。
我读过这篇文章，但还没试过。
我对slave.php (链接中提到的)将如何执行感到困惑。我的意思是，当新的消息到达队列时，slave.php将如何发现这一点。
我不想使用cronjob来解决这个问题。相反，当新消息到达时，sla
浏览 6提问于2013-12-23得票数 8
回答已采纳
2回答
我有一个php脚本，其中我编写了以下代码
$client = new \Predis\Client();
$client->select(4);
$client->lpush('emailid',$x['to']);
$command = "/usr/bin/php5 -f /var/www/Symfony/src/Ens/NewBundle/Controller/cron.php";
exec( "$command > /dev/null &", $arrOutput );
return $th
浏览 7提问于2012-08-23得票数 0
回答已采纳
2回答
node.js中的作业队列
、、、、
我在node.js中寻找一个作业队列管理器，它可以由php调用。这是一个web应用程序，它需要发送电子邮件，创建pdf文件等等，我想要执行的php进程异步。
这一进程的实例：
用户请求php页面
Php调用作业队列管理器并添加一个任务。
任务在php的node.js中异步执行，最好是在稍微安静一些时执行。
任务是执行php脚本。
为什么这个“复杂”系统？
我们用php (Zend Framework)编写我们所有的web应用程序。
我们想开始学习node.js
我们需要一个异步进程(快速响应！)
“真正的”任务也应该是php脚本，利用已经编写好的php类
浏览 1提问于2011-09-12得票数 5
回答已采纳
1回答
这是我在这里的第一个问题，我希望大家都好。我不得不编写deque或双结束队列的数组实现，但是在理解前面方法的enqueue元素时遇到了一些困难，我通过稍微修改一下就可以工作了，但是我仍然很难理解逻辑：
void addAtFront(E)
{
if ( front == 0 )
front = array.length - 1;
else
front = ( front - 1 ) % array.length;
array [front] = element;
count++;
}
有人能在这里解释一下if语句中发生了什么
浏览 2提问于2015-12-22得票数 0
回答已采纳
我目前正在研究循环线索。我在学习教科书时偶然发现了这些功能。
int NextPosIdx(int pos)
{
if (pos == QUE_LEN -1)
return 0;
else
return pos +1;
}
看看算法，我首先编写了这些函数。
int NextPosIdx(Queue* pq)
{
if (pq == QUE_LEN -1)
return 0;
else
return pq +1;
}
就我个人而言，我认为我仍然缺乏对指针的理解。我能请你解释一下为什么不起作用吗？
浏览 5提问于2020-12-25得票数 0
回答已采纳
1回答
我正在使用RabbitMQ实现通知系统，并希望了解以下问题的最佳实践。
RabbitMQ服务器安装在本地主机上。
我的制片人代码：
// ... Initialize connection
$this->channel->exchange_declare('my_exchange', 'direct', false, false, false);
// Detect routing key
$parameters = $notification->getParameters();
$routing_
浏览 0提问于2018-08-16得票数 0
1回答
获取不同路由密钥的消息的用户
、、、、
c1 (in php)绑定到exchange 1、queue 1和routing key 1；c2 (在java中)绑定到exchange 1、queue 1和routing key 2，即只有路由密钥不同，但exchange和队列相同。
在php中，我们按以下方式进行绑定
$channel->queue_bind($this->queue, $this->exchange, $this->routing1);
在java中，以下内容
channel.queueBind(queue, exchange, routing2);
现在，当我们使用路由密钥2发布用于c2的消息
浏览 2提问于2015-12-03得票数 1
回答已采纳
所以我正在做一个游戏，两个人玩一个游戏，在网站上报告他们的分数，获胜者将获得积分。现在我想添加一个功能，如果一个人报告了一个结果，而对手没有在5分钟内报告他自己的结果，网站将自动信任报告结果的人。
目前，我已经用PHP和Javascript编写了一个倒计时器(我更喜欢在Javascript中进行倒计时，并在时间过去后调用PHP函数，但看起来我不能在Javascript中执行PHP代码，但如果可能的话，我想这样做)。
我同样用PHP编写了倒计时，但看起来PHP不能在后台运行，所以即使过了一段时间，它也不会更新余额。
下面是PHP的倒计时，作为我想要做的一个例子。
<?php
浏览 1提问于2020-10-28得票数 0
希望有人能给我一个打开套接字，发送命令和接收答案的最小工作示例。
在php中，我会使用以下代码：
$socket = getsock('127.0.0.1', 4028);
socket_write($socket, $cmd, strlen($cmd));
$line = readsockline($socket);
socket_close($socket);
在$line中，我将从套接字的目标接收答案。我该如何在objective-c中做到这一点(是的，我已经看过苹果的文档，但我无法找到/理解正确发送和接收命令的方法)。
谢谢您:)
浏览 2提问于2014-04-07得票数 0
以下使用AFNetworking 2.0的代码可以有效地通过互联网获取数据：
NSString *URLPath = @"http://www.raywenderlich.com/downloads/weather_sample/weather.php?format=json";
NSDictionary *parameters = nil;
[[AFHTTPRequestOperationManager manager] GET:URLPath parameters:parameters success:^(AFHTTPRequestOperation *operation
浏览 3提问于2013-09-30得票数 0
我现在正在研究一个php服务器实现，以编写一个新的实现。
以下是接受新连接的部分：
$write = [];
$except = [];
while(isset(self::$read[0])){
$changed = self::$read;
$result = socket_select($changed, $write, $except, 1);
if($result === false){
// Error handling
}elseif($result > 0){
foreach($changed as $cli
浏览 1提问于2013-09-05得票数 1
回答已采纳
1回答
我正在尝试发送带有队列的多封电子邮件(beanstalkd)。我的应用程序发送了一些电子邮件，然后我收到超时异常。
foreach ($emails as $e) {
Mail::queue('emails.invite', ["username" => Auth::user()->username, "grupa" => $naziv, "id" => $id, "email" => $e], function($message) use ($e){
浏览 0提问于2014-10-31得票数 0
1回答
我能在循环中安全地使用1000次重复的Mail::send()吗？
我的意思是，在这样的循环中使用php mail()可能有问题，因为据说它会为每个调用打开SMTP套接字，但是laravel Mail::send()呢？
更新:循环本身在队列作业中.
浏览 1提问于2015-10-07得票数 3
2回答
意外分割误差
、、、、
我编写了一个非常简单的程序，但当我试图编写队列大小(用STL创建)时，它就崩溃了。我不知道为什么，请帮帮忙。
#include <queue>
#include <vector>
#include <iostream>
#include <algorithm>
using namespace std;
int main() {
int n, i, x, cut = 0;
queue<int> que;
vector<int> vec;
cin >> n;
for (
浏览 2提问于2015-04-15得票数 0
回答已采纳
7回答
堆栈还是排队？
、、
你好，我还是个学生，对堆叠和排队有点困惑吗？第一个问题是，
他们之间的主要区别是什么？
顺便说一句，在正常排队的旁边有圆形排队，怎么样？它们是如何工作的？排队有不同的方式吗？
我正在使用php，是否有一个简单(非常简单或易于阅读)的示例代码，我可以学习(链接也可以。)?
有pop，push等(堆叠和排队)，在php中有类似的东西吗？
非常感谢您的帮忙。
浏览 3提问于2010-10-01得票数 9
回答已采纳
我在cron上运行了一个PHP脚本，它具有以下功能：
处理队列中的项如果项目已成功处理，则processQueueItem()方法返回true。如果不成功，则返回false。在while循环中重复重复50分钟。
代码还包括回显以将信息输出到我设置的日志中。
下面是代码：
<?php
require_once('/var/www/vhosts/com-ext.com/httpdocs/745_TheYGSGroup/LWC_API/com/MindFireInc/LookWhosClicking/class.LWC.php');
require_once('
浏览 2提问于2012-06-01得票数 3
回答已采纳
1回答
在这种情况下，我希望使用Java固定线程池的扩展。我有N组可运行的对象，我想要竞争资源。但是，我希望线程总数保持不变。下面是我想要的工作方式。
queues;Schedule 分配一个具有N个线程的对象，在队列m上分配M个作业。有一个指向第一个队列的指针，重复a。如果当前使用的线程数最大，则等待。b.弹出当前队列上的作业。将指针一个队列移到(或从最后一个队列移到第一个队列)。
首先，这样的东西已经存在了吗？第二，如果不是，我对编写自己的线程池感到紧张，因为我知道编写自己的线程池可能是危险的。有人能告诉我写我自己的一些好例子吗？
浏览 1提问于2011-07-13得票数 0
回答已采纳
我已经搜索了gevent的教程和文档，但似乎没有太多。我已经编写Python几年了，我也可以编写PHP + JavaScript + jQuery。
那么，我如何创建Omeglish聊天，其中一个随机的人连接，然后等待另一个人连接？我知道Omegle使用gevent，但我的站点必须同时容纳200 - 1000人。
除了服务器端，还应该有功能齐全的客户端，我认为应该用jQuery/JavaScript创建。
我需要一些编码部分的帮助。我可以很好地编写Python，但我不知道如何制作这种聊天系统，也不知道最好的Python库是什么。
这个库不一定非得是gevent，但我听说它对这样的东西很好。谢谢
浏览 0提问于2012-01-02得票数 1
回答已采纳
我正在处理一个包含消息队列概念的项目。现在这个项目是用PHP编写的，它在消息发送或邮件发送方面造成了更多的延迟。所以我建议用Perl或Python脚本开发一个消息队列。你能推荐一下PHP、Perl和Python哪个最好吗？
浏览 0提问于2011-03-30得票数 0
1回答
为了增加吞吐量，我运行了另一个php进程，但是这个方法负载了服务器这么多，有什么方法可以解决这个问题吗？ while (true)
{
$allSms = $mca->getSms(null, null, $params);
if (!$allSms)
{
sleep($sleepTime);
}
else
{
foreach ($allSms as $sms)
{
$cmdNewProcess = "/usr/bin/php " . __D
浏览 32提问于2020-07-15得票数 0
1回答
背景/问题描述
我甚至不知道该如何去寻找我想做的事。我有一个需要处理的条目队列，我希望PHP每10秒检查一次(或任何增量)，以查看队列中是否有任何内容。如果有，它应该开始处理它，但是只有当它还没有处理另一个项时(因此，当处理需要30秒时，它不会有超过一个项正在处理)。我认为我可以通过存在一个锁文件或什么东西来黑掉一个“已经处理”标志。
我可能会使用AWS作为队列，并使多个服务器并行运行
问题：
基本上，用户需要排队等待异步完成大量的工作。因此，我的问题是，您如何安排PHP来进行队列检查？我在看克朗乔布斯，但那些人似乎只能每分钟跑一次。
浏览 2提问于2013-12-03得票数 2
我正在尝试编写一个测试套接字连接的XCTest。下面是我的连接代码的大致样子：
public class MyConnection: NSObject, NSStreamDelegate {
private let queue = NSOperationQueue()
private var inputStream: NSInputStream!
private var outputStream: NSOutputStream!
public func connect() {
println("Attempting to connect")
q
浏览 1提问于2014-08-20得票数 2
回答已采纳
1回答
执行SQL查询时执行脚本
、、、
当在MySQL数据库上执行update查询时，我想执行脚本(可能是用python编写的)。查询将从我无权访问的用PHP编写的外部系统执行，因此我无法编辑源代码。MySQL服务器安装在我们的机器上。你知道我如何才能做到这一点吗，或者说这是可能的吗？
浏览 12提问于2016-08-31得票数 1
回答已采纳
我正在构建一个应用程序，其中发送的所有通知(电子邮件，短信，传真)将是异步的。应用程序将将通知写入数据库，一个批处理作业将读取这些通知并用适当的传输发送它们。
我第一次在运行cron比分钟快的方法读书，意识到这是个坏主意。
批处理脚本是用PHP编写的，我猜编写一个适当的守护进程会带来相当大的开销(尽管我愿意接受任何建议，因为PHP汽车也无限期地运行)。
我所想到的是一种解决办法：
每5秒运行PHP脚本一次
检查上一次运行是否已完成，或中止(从不2次并发批正在运行)
如果运行时间超过x分钟，则关闭脚本(以防挂起)
从系统开始(如果重新启动)
知道怎么做吗？
浏览 0提问于2012-11-26得票数 -1
请查看以下代码：
console.log("a")
process.nextTick(()=> console.log("b"));
process.nextTick(()=> console.log("c"));
当然，这将打印a，然后打印b，然后打印c。a是从与b和c不同的框架(滴答)编写的，但是b和c是从同一帧编写的吗？
是这样的吗？
编写aframe 2:写b，写c
或者是这样的：
编写aframe 2:写bframe 3:写c
谢谢!
浏览 1提问于2019-12-14得票数 0
我正在编写一个程序，在Labview中控制两个类似的设备。为了避免复制代码，我使用了子use。但是，我有一段代码，在while循环中，我在GUI上更新了一些值。我想知道是否有可能在我的subVI中使用这个循环，并让subVI在每次迭代之后发送一个输出参数。
浏览 5提问于2015-07-30得票数 5
回答已采纳
我正在尝试使用System_Daemon包和CodeIgniter的命令行界面来创建一个守护进程。这对我来说是一个新的领域，我正在努力。
这是我所拥有的:一个将消息注入到AWS SQS队列中的CI控制器(感谢提供了关于如何将AWS SDK集成到CI中的出色说明。请看这里：)。
接收队列中的消息并将其写出到日志文件，然后删除队列中的消息的CI控制器。
我希望有一个CI守护程序，它将侦听这个队列，接收消息时，他们在那里，并对消息做一些有用的事情，然后删除消息。因此，我从System_Daemon文档中的示例开始，并添加了接收程序中的CI代码。请参阅下面的代码
这是正确的做法吗？你能引导我以“正确的
浏览 0提问于2012-03-08得票数 4
回答已采纳
2回答
大规模卷曲
、、
我必须做以下工作：
我设置了一个守护进程，它每小时执行一次sms.php命令(通过调用exec('nohup sms ...‘))，然后sms.php会遍历用户数据库，同时向每个用户发送一条短信。它通过联系(通过curl)第三方消息服务来做到这一点。
因此，sms.php的结构如下：
$sql = 'SELECT * FROM users'.
$q = execute sql query
while($r = ....)
{
// url is the url to the third party service that handles sending sms
浏览 2提问于2011-12-16得票数 1
回答已采纳
我使用NSURLConnection建立到服务器的长轮询连接，有时，我想取消连接并重新构建连接。首先，我像这样编写了代码
[self.connect cancel];
self.connect = [NSURLConnection connectionWithRequest:request delegate:self];
[self.connect start];
但是我发现在这个取消和启动之后，不能再调用连接委托了。所以我使用分派
[self.connect cancel];
dispatch_async(dispatch_get_main_queue(), ^{
self.conn
浏览 3提问于2014-12-23得票数 0
我正试图在阿波罗1.6上设置一个队列，该队列将使用STOMP从PHP中写入，并由Java使用ActiveMQ开线客户端使用。
我可以用Java读写队列，可以用PHP读写消息，也可以用Java编写消息，也可以用PHP读取消息，但我不能用PHP编写消息，也不能用Java读取消息，这正是我真正想要做的。
当我使用阿波罗的管理UI查看队列时，我可以看到我在我创建的测试队列中使用PHP/STOMP和使用Java/ActiveMQ发布的所有消息。php消息的编解码器是stomp，而java消息的编解码器是openwire。我的php客户端读取这两种类型的消息，但我的java客户机不读取stomp消息。
下
浏览 3提问于2013-09-09得票数 4
3回答
我使用的是Amazon API产品，对于相同的IP地址，该产品每秒只能发出一个请求。我能把php curl定义为每次请求都是在1秒内发出的吗？(全局)
浏览 1提问于2017-04-09得票数 1
1回答
我使用的是Mule 3.3.1
我正在尝试编写一个从队列中读取所有可用消息的组件，我打算使用Quartz调度器对其进行轮询。
这是我的代码。
@Override
public Object onCall(MuleEventContext muleEventContext) throws Exception {
MuleMessage[] messages = null;
MuleMessage result = muleEventContext.getMessage();
do {
if (result == null) {
浏览 0提问于2013-09-09得票数 1
<?php
/*
Template Name: isbn design
*/
get_header();
<!DOCTYPE html>
<html>
<head>
<title>Sell your book</title&g
浏览 3提问于2020-02-08得票数 0
回答已采纳
今天我有一个理论上的问题(我只是找不到一种方法来编写示例代码)。
我的系统架构是这样的：Client <--> Web Service1 <--> query <--> Web Service2 <--> Server。
我不能更改它，因为我的公司需要它是独立的。
问题出在同步上当client向WebService1发送请求时，WS1将一个对象放入查询中，WS2一直在监视查询并检查是否有新的东西，如果是，它会向Server发送一个请求，后者处理该请求并给出一个适当的响应，该响应必须返回给Client。
对于所有请求，Server的处理时间并不相等
浏览 0提问于2012-11-23得票数 0
回答已采纳
3回答
请帮帮忙，我可能做错了什么或理解错了什么。我正在创建一个批量上传到数据库，这需要一点时间，所以我决定使异步所有，并在后台处理它使用Laravel队列。
在控制器中，我创建了一个关联列表，并将其传递给Laravel Job。
foreach($data as $row)
{
$instantArray = array();
$orderDate = \PHPExcel_Shared_Date::ExcelToPHPObject($row[3]);
$issueDate = \PHPExcel_Shared_Date::ExcelToPHPO
浏览 4提问于2018-11-15得票数 1
4回答
我正在致力于提高一个在linux系统上运行的用C编写的网络应用程序的性能。
现在编写的程序从套接字接口读取数据包，对其进行一些处理，然后将其添加到发送队列中。
我是多线程编程的新手，但我熟悉基本概念(互斥、条件信号等)。我正在尝试实现一个解决方案，其中传递了一组从接口读取的工作线程，然后它们执行后续的工作。
我的问题是，如果第一线程读取第一个包，第二个线程读取第二个包，我如何确保将包添加到发送队列的顺序与读取的顺序相同。
浏览 0提问于2015-06-26得票数 1
1回答
我想读取队列中的bas队列名，已经编写了代码，但只能读取最后一个队列名而不是全部。
下面是一个代码
queueList = AdminConfig.list('MQQueue', AdminConfig.getid('/Cell:' + AdminControl.getCell() + '/')).splitlines()
for queue in queueList:
print "\t" + queue +"in QueueList"
queueName = AdminConfig
浏览 3提问于2020-05-23得票数 0
回答已采纳
4回答
老实说，我是一个Linux管理员，已经有几年没有做web开发了。在过去的10+岁月里，我所选择的制作任何网页的工具都是灯。
我正在编写REST，并且正在考虑扩展。我知道有很多方法可以在PHP中进行REST，但也许这已经不是最好的方法了。
就我而言，PHP模型如下所示：
用户在浏览器(或AJAX调用)中发出请求。
PHP get被召集了。
PHP从顶部开始，按顺序工作到底层，连接到DB，运行查询，执行操作和输出数据。
请求已经结束，用户已经有了他们的数据，并准备好创建一个新的数据。
对于PHP，每个请求都是一个新的交易。没有共享变量(可以通过cookies\session
浏览 5提问于2017-06-03得票数 0
回答已采纳
1回答
我从那里了解到运行exec()会产生一些开销，但在大型程序或网站中，让后端的一部分用另一种语言编写，让PHP使用exec调用程序不是很有好处吗？
例如，我编写/运行了一个带有大量字符串操作的测试- PHP用了2.3s，Java用了.52，C++用了.33。速度的差异已经很明显了。如果我将操作多线程，时间可能会更快。我还发现并行性可以通过以下方式来实现
exec("./largeoperation > mydir/$dirname.data &");
//or
exec('java Backend > /dev/null 2>&1 &a
浏览 11提问于2013-01-12得票数 5
回答已采纳
我正在编写一个IIB流，其中包括生成事件消息(监视功能)。为了能够处理所有这些事件，我需要做一个持久的订阅。但如果我这样做，如果消费应用程序由于某种原因无法恢复正常运行，QM可能会被填满，并最终停止。有什么办法可以避免吗？有任何方法创建带有“强制消息过期”的托管持久订阅吗？
浏览 3提问于2015-11-02得票数 2
回答已采纳
--我知道我可以编写一个write (true)循环来监视队列，但是它会导致CPU 100%的问题。I可以在while (true)循环中休眠几秒钟，但效率不高。在C语言中，我可以在while (true)循环中等待信号量。当任务添加到队列中时，释放信号量，以便while (true)循环能够完成其工作。当队列为空后，它可以设置信号量，并等待它。
在Nodejs中有类似的方法吗？
浏览 3提问于2020-03-07得票数 1
回答已采纳
1回答
我正在研究循环数组队列是如何编写的，而enqueue方法的一部分让我感到困惑，特别是back变量变成(back+1) % SIZE的部分。
void enqueue(char x) {
Q[back] = x
back = (back+1) % SIZE;
}
得到剩余部分有什么意义？我不明白。(数组名为Q、int front = -1、int back = 0和int size = 0)
浏览 2提问于2019-02-26得票数 1
回答已采纳
1回答
我编写了这个脚本，它向客户发送订单收据，但它有一个问题：
它不会等待PDF脚本.
因此，它只需要PDF脚本，并开始执行它和发送邮件，而PDF脚本仍在工作的PDF。我确信有一种方法可以延迟电子邮件脚本，但让事情变得更复杂：
整个order.php都是使用jquery调用执行的，脚本将等待php完成，然后报告请求成功的浏览器。因此，当客户端想知道为什么要花这么长时间时，它可以等待超过5分钟。
因此，我需要它等待PDF被创建，然后发送邮件，但它不应该让客户端等待。
这是我的密码：
<?php
$addid = "orderid.txt";
$current =
浏览 4提问于2012-09-07得票数 4
回答已采纳
我正在编写一款手机和pc之间的聊天应用。为了从电话接收，我设置了一个套接字并将其outputStream放入DataOutputStream中，从LinkedBlokingQueue中轮询字符串并使用writeUTF()发送它们。但是由于某些原因，我在执行dataOutputStream.writeUTF(input)时得到了一个空指针异常。
代码如下：
public class txThread extends Thread{
private LinkedBlockingQueue activityQueue;
private Socket socket;
priva
浏览 2提问于2012-04-30得票数 0
回答已采纳
1回答
我正在开发一个需要执行大量批处理的应用程序(例如，whois request)。为了确保最佳性能，我想在不同的计算机上分担这项工作。为此，我计划编写一个程序，它将查询主服务器上的作业队列，获取一个作业，处理它，并使用结果更新主服务器。实际的处理将由PHP完成。我的程序只需要轮询作业队列并调用本地php脚本。作业需要每隔几秒钟运行一次，因此我不能使用cron。
有没有人能推荐一种可以轻松创建这样一个守护进程的编程语言？有没有已经可以做到这一点的程序？
谢谢
浏览 2提问于2011-07-01得票数 1
回答已采纳
4回答
我想使用空堆栈S来检查队列Q是否包含元素x，因此我的解决方案是将q的元素复制到S中，检查是否包含x，但我还被要求将S元素再次返回到Q中，因为它是原始的，这必须只使用Q和S，而不使用任何SL数组，所以我编写了以下算法：
Boolean found ← false
int element ← 0
While(Q is not empty)
element ← Q.dequeue()
if(element equal x)
found ← true
S.push(element)
While(S is not empty)
( elements back
浏览 7提问于2014-12-16得票数 0
回答已采纳
1回答
我们有一个Node应用程序，节点代码的一部分作为后台作业运行。工作是使用，它是用JavaScript编写的，并且在引擎盖下使用Redis。
我们正在将一些Node应用程序移植到Rails。但是，我想保留这份背景工作，用Node写成。
是否有可能：
Rails中的路由，接受请求，安排作业并将其推送到Redis队列？
工人是否用Node/JavaScript编写了作业？
Rails是否监听队列(Websockets或长轮询)并在完成时将结果发送到浏览器？
另一个词是独立于语言的Redis / Queue系统吗？
浏览 1提问于2020-04-16得票数 0
我使用多处理库编写了一段简单的代码，除了主代码之外还构建了一个额外的进程(总共2个进程)。我通过Anaconda-Spyderv3.2.4在W7专业版x64上做了这段代码，它几乎按照我想要的那样工作，除了当我运行代码时，它增加了我的第二个进程(不是主进程)的内存消耗，直到它达到总容量，计算机被卡住和冻结(你可以在whindows任务管理器中注意到这一点)。
"""
Example to print data from a function using multiprocessing library
Created on Thu Jan 30 12:07:49 2018
浏览 12提问于2018-01-31得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
