标签: real-time

我将开发实时应用程序,它将接收股票市场数据并进行一些处理,然后传播到客户端应用程序.我决定在服务器和客户端之间划分计算,服务器将进行基本计算,然后将基本数据发送到计算最终变量的客户端.

我决定使用C#和使用C++计算最终变量(称为:变量计算器)的组件开发客户端应用程序(仅限GUI).在c ++中开发"变量计算器"的目的是为了模块化.例如,如果我发现变量计算将在客户端需要更多时间,我可以在服务器端使用相同的模块.

我还将使用标准C++开发服务器端.

注意:服务器应该处理一组消息并在不到一秒的时间内将其发送到客户端.市场开始时消息的最大数量为100,000条消息

有什么建议？

有人能指出我在Matlab中进行实时网络摄像头处理的一些例子吗？有一些关于如何从网络摄像头获取图片的在线教程/示例,然后处理该图片,但我正在考虑从网络摄像头实时处理视频.

我需要构建一个电子邮件解析脚本,该脚本将解析将进入收件箱的电子邮件并将内容转储到数据库中,同时发出一个卷曲请求,其中包含从电子邮件中解析的详细信息.

此时此刻我仍然坚持实施有关如何在收件箱中收到电子邮件的实时解析部分.有没有办法设置触发器来做这样的事情？我在使用基于php的webmail客户端方面拥有丰富的经验,但这似乎有所不同.

如何实现这一目标 - 我正在做一个cron工作,但如果有另一种方式这样做,我会全力以赴.

我在确定如何在我的场景中最好地使用CouchDB时遇到问题(或者找到更适合的另一种解决方案).这是对所需内容的概述,我希望我能更好地了解我的需求:

• 该系统几乎完全基于关键字.
• 每个文档都有一系列关键字.
• 我需要能够根据关键字搜索和返回文档.
• 我还需要能够根据增量ID号搜索和返回文档(例如,所有带有关键字"test OR more"的文档,因为文档ID:1318814)
• 这一切都需要能够处理数十万个文档,对关键字进行实时更新,并且最好不会​​有太多延迟(例如,CouchDB视图生成因此输入以便能够将其输出到动态生成的查询只需要几秒钟最多).

这可以在CouchDB中做到吗？CouchDB有什么好的扩展可以让我这样做吗？

编辑:我正在使用PHP连接到数据库和Java以将信息提供到数据库中.

我做了一些研究,但我找不到答案.

我想做的是,在运行时更改ActiveMQ配置.

假设我想在activemq运行时增加内存使用量,流量控制等.但我不想重新启动它.这可能吗？我尝试过,但改变没有开始.

有没有办法做到这一点？

我有C++和Java客户端(分别是生产者和消费者)

我正在编写OS X(Obj-C/Cocoa)的应用程序,它运行模拟并将结果显示给用户.在一种情况下,我希望模拟以"实时"运行,以便用户可以以与现实生活中相同的速度观看它.模拟以特定的时间步长dt运行.现在,我正在使用mach_absolute_time()来减慢模拟速度.当我分析这段代码时,我发现到目前为止,我的大部分CPU时间都花在了mach_absolute_time()上,而我的CPU固定在100%.我这样做了吗？我想如果我放慢模拟速度以致程序在大多数时间没有模拟任何东西那么CPU使用率应该下降但是mach_absolute_time()显然不是"免费通话"所以我觉得可能有更好的方法？

double nextT = mach_absolute_time();
while (runningSimulation)
{
    if (mach_absolute_time() >= nextT)
    {
         nextT += dt_ns;
         // Compute the next "frame" of the simulation
         // ....
    }
}

我刚刚构建并设置了一个应用了RT补丁的vanilla Linux内核.一切都很顺利,我现在可以正确启动进入新内核.

令我疑惑的是:我有一个我在C中制作的模拟器程序,我希望它以硬实时模式执行,新内核应该允许它.可能整个模拟器不需要以实时优先级运行,但内部的一些任务可以.

我怎么能做到这一点？我认为只是运行该程序是行不通的.

我正在为ElasticSearch数据源编写单元测试,但是,我的结果好坏参半.问题是match_all查询没有找到我提交的记录,但是,当我使用CURL以相同的顺序手动运行命令单元测试时,我能够找到记录.

我相信也许索引没有刷新,因此,我在提交记录后开始运行"刷新"api命令,但是,这也没有用.这是我的命令列表 - 如果有人有任何关于如何确保这些命令工作的建议,即使它们是立即连续运行的,也会有所帮助.

命令单元测试运行:

curl -XGET 'http://localhost:9200/test_index/_mapping'

curl -XDELETE 'http://localhost:9200/test_index/test_models'

curl -XPOST 'http://localhost:9200/test_index/test_models/_refresh' -d '{}'

curl -XPUT 'http://localhost:9200/test_index/test_models/_mapping' -d '{"test_models":{"properties":{"TestModel":{"properties":{"id":{"type":"string","index":"not_analyzed"},"string":{"type":"string"},"created":{"type":"date","format":"yyyy-MM-dd HH:mm:ss"},"modified":{"type":"date","format":"yyyy-MM-dd HH:mm:ss"}},"type":"object"}}}}'

curl -XPOST 'http://localhost:9200/test_index/test_models/_bulk' -d '{"index":{"_index":"test_index","_type":"test_models","_id":"test-model"}}
{"TestModel":{"id":"test-model","string":"Analyzed for terms","created":"2012-01-01 00:00:00","modified":"2012-02-01 00:00:00"}}
'

curl -XPOST 'http://localhost:9200/test_index/test_models/_refresh' -d '{}'

curl -XGET 'http://localhost:9200/test_index/_mapping'

curl -XGET 'http://localhost:9200/test_index/test_models/_search' -d '{"query":{"match_all":{}},"size":10}'

这个问题也被发布到(超级棒)ElasticSearch邮件列表中:

https://groups.google.com/forum/?fromgroups#!topic/elasticsearch/Nxv0XpLDY4k

-DK

我正在使用Node.js和Socket.IO的实时跟踪应用程序.在我的目标站点上的跟踪代码中,我有一些代码可以抓取浏览器的用户代理字符串并将其发送回服务器.这个USUALLY工作正常,但有几次将这些数据设置为undefined(这是它发生的地方).

现在,我只是在服务器上有一个巨大的try/catch块,因此在运行我定义的方法时它不会崩溃,以检测它是什么浏览器(它在尝试运行match()方法时崩溃).我假设这是从机器人或其他没有用户代理或已被篡改的浏览器发生的.我错了吗？还有其他原因吗？

Socket.IO是否提供浏览器检测功能？无论哪种方式,我知道我需要使浏览器检测功能更强大,但我只是让这个项目开始.

如果没有更好的方法可以做到这一点,我最好只检查发送到服务器的数据是否未定义并将其视为"其他"浏览器？

查看总连接数和浏览器总数的差异？目前,有一点差异超过100.如果没有发生此浏览器跟踪问题,则数字应该完全相同(因为每个连接都有浏览器,分辨率,操作系统和URL).

只是阅读有关风暴的更多细节,并且发现它能够进行字段分组,例如,如果你计算每个用户的推文,并且你有两个任务,其中一个字段分组为user-id,则相同的用户ID将被发送到相同的任务.

所以任务1在内存bob中可以有以下计数:10 alice:5

任务2可能在记忆吉尔中有以下计数:10乔:4

如果我向群集中添加了一台新机器以增加容量并运行重新平衡,那么我在内存中的计数会怎样？你会开始让不同用户的用户？