Tag: 龙卷风

我如何使用参数化过滤创build一个类似Twitter的stream媒体API?

我正在尝试开发一个与Twitter的stream式API( https://dev.twitter.com/streaming/reference/post/statuses/filter )function相同的数据streamAPI,即具有过滤function的数据stream。 我正在生成大量数据,并希望将其提供给客户端。 我知道如何制作一个为所有客户端提供相同数据的应用程序。 这相对容易。 我遇到的困难来自于允许客户指定数据filter并为每个客户提供独特的数据。 我的想法: 首先我想打开stream式HTTP请求(如Twitter)。 我可以创build一个端点来接受带有参数的GET请求(例如https://stream.example.com/v1/filter.json?track=twitter )。 根据这个答案streamAPI和Rest API? ,这不容易扩展,需要大量的资源。 然后我想用websockets,让客户端提供一个过滤信息(例如locations = -122.75,36.8,-121.75,37.8)。 但是,我找不到一个WS服务器为每个客户端分配唯一数据的好例子。 如果inheritance了tornado.websocket.WebSocketHandler或类似的实现,这个类会是什么样子? 我还考虑将数据推送到消息服务(RabbitMQ)或数据库(Redis),并在客户端连接到其独特的频道时订阅客户端。 (我想这个问题任何想法如何创build参数化的streamapi? )。 我不知道创build独特渠道的有效方法。 这似乎也过于复杂。 我宁愿在Python中这样做,但我也会考虑使用Ruby和JS实现。

为追随者提供实时新闻馈送 – 哪些工具和语言?

我想实时地为Twitter这样的追随者实施新闻推送。 但是,我被困在哪些工具将是我的目的最好的。 解决scheme(复合解决scheme)应该是生产就绪的。 我试过node.js + socket.io + rabbitmq(node-ampq,rabbitJS),但节点经常崩溃…另一个解决scheme是Tornado + sockJS-tornadio,但是我不确定(并且知道Python不好)。 在深入研究代码之前,我只需要知道哪些工具可以用于我的目的,并且可以“真正”实时。 真的,我的意思是快速的请求响应。 我已经尝试了RabbitMQ + PHP API + Ajax,但它不是“真正”实时的,而是使用ajax而不是websockets。 新闻源的数据将会像“John更新其个人资料”,“Doe上传新文件”以及类似的内容。 谢谢!

对于非阻塞和快速服务器,框架,语言的build议?

我们的新项目会得到很多并发请求。 我没有太多的经验。 有什么build议么? 我已经看过NodeJS,Twisted,EventMachine和Tornado,但是我没有办法衡量它们的适用性。 有什么build议么?

在逻辑上什么是线程中的事件循环?

我遇到了node.js和python's tornado与Apache 。 他们说 : Apache为每个连接创build一个线程。 Node.js & tornado实际上是在线程上进行事件循环,而单个线程可以处理多个连接。 我不明白,逻辑上是一个线程的孩子。 在计算机科学方面: 进程具有隔离内存,并与上下文切换共享CPU。 线程划分一个进程。 因此,具有多个控制点的过程是由多个线程实现的。 现在, 什么event loop在一个线程下工作? 如何处理一个线程控制下的不同连接? 更新: 我的意思是如果在一个线程下有3个套接字进行通信,那么1个线程怎样才能与3个套接字进行通信,而不会让任何人等待呢?

什么是事件驱动的服务器/应用程序的免费PaaS的限制?

我问这个问题,因为Heroku或者CloudControl对于免费应用程序如何使用他们的资源并不是很明确? 应用程序将使用基于事件驱动的服务器( 节点或龙卷风 ),事件驱动是单线程的,所以这里是我的问题: 一天中有多less用户可以免费的应用程序处理,因为事件驱动对于CPU而言并不重要,对内存来说也不重要。 在龙卷风(我不知道节点),你可以使用ThreadPoolExecutor ,可以使用另一个线程的情况下,耗时的操作,免费提供让我使用这个选项? 或者我将仅限于一个线程?

是否有可能发送消息到所有活动的WebSocket连接? 使用node.js或python龙卷风websockets

我正在尝试构build一个基于websocket的应用程序。 我想知道是否有可能发送消息到所有活动的连接,因为他们是持久的。 说我正在运行一个现场拍卖网站,我有多个用户在观看拍卖页面,每个用户都通过套接字连接到我的服务器。 现在让我们说一个用户提高出价。 我想发送消息给所有连接的客户端。 最简单的方法是让客户端每秒钟通过套接字轮询服务器,但是我认为websockets的思想是要有真正的双向通信。 如何才能做到这一点? 提前致谢, ROTEM