个人中心
文章发布
退出
作者热门文章
- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库？
- java - OnItemClickListener 不起作用，但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
26
4
我们正在从基于 python 的环境转移到 scala play 框架之一，我必须编写一个缓冲的发布者订阅者，它将与另一个用 python 编写的系统交互。这里的目标是编写一个发布者，它会从缓冲区/队列中获取消息，并通过 TCP 套接字将它们发送到服务器，并保持套接字打开，以便我们以后可以重用它。
我们的旧 python 发布者创建了一个永远不会关闭的 socket.socket(socket.AF_INET, socket.SOCK_STREAM) 套接字，并使用调度程序从队列中取出消息并通过流式套接字发送它们。
我对使用 akka streaming io 很感兴趣，但我不知道如何创建一个与调度程序一起工作的流套接字，定期查看队列并将消息发送到服务器。
如果有人有代码示例可以说明如何在 scala/play framework/akka streaming io 中完成此操作，那就太棒了。
先谢谢你弗朗西斯
最佳答案
听起来你想要 Akka TCP:
关于scala - 如何在 scala playframework/akka 中设计缓冲的 tcp 发布者/订阅者，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/37080548/
26
4
0
我正在使用Play 2.1.0，突然之间一切都很好，当我从Play控制台执行~run时遇到了这个奇怪的错误(附加快照)。 环境: Windows 7，IntelliJ12，Mysql，JDK 1.6
最佳答案在评论部分(所以我不能给他们答案:()。 我想知道 playframework 是否以这种方式异步(这将是真正的异步或完全异步)。是的， Play 在前端是异步的，允许 100 个线程上的 1
以编程方式停止 Play 应用程序以便返回到 activator 控制台的最佳方法是什么？(用Java 8玩2.3.7) 如果出现初始化问题，我的服务器应该在启动时退出。 System.exit(1)
我想用 activator run在不发出任何请求的情况下启动应用程序。当前 activator run在启动应用程序之前等待第一个请求。有什么办法可以解决吗？ 我知道 activator start
我使用带有@OnApplicationStart 的“通用”作业来做一些初始化工作。如果其中任何一个失败， Play 应该退出。我试过 Play.stop()，但在开发模式下，它会重复重启。 最佳答案
是否有一种简单/内置的方法让 Controller 检查连接是否被授权访问静态文件而不是服务器(使用数据库查找)，然后在需要时提供访问权限。 有大视频文件，我想 a) 检查是否允许用户访问该文件，以及
我昨天晚上在南特(法国)和 Play! 参加了与 Guillaume Bort 的 session 。真的很棒!! 我从大约 2 周开始使用它。 Guillaume 使用了 URL http://lo
我在 Global.scala 和 application.conf application.global=Global 中添加了一些代码 object Global extends WithFilt
我正在努力让 capistrano 发布我的 PlayFramework 应用程序，但我在运行命令时遇到了一些问题。 发生的事情是 cap 运行 Play 开始命令并且它似乎正在启动，但是当我执行一个
我们正在使用 play 1.2.x 数据库进化功能。我想让脚本创建和开发正在 Play 自动测试中测试的模式 所以在测试套件之前我需要一个空的数据库。 我想过: 注册可以删除所有的@OnApplica
我在 Scala 中从事一个 playframework 项目。然而，我们的团队想要使用 scalatest 而不是规范。我已将以下内容添加到 plugins.sbt 文件中: libraryDepe
现在 playframework 有了新的版本 2，与版本 1 完全不同；后者会怎样？在 play 1 中编写的所有项目都应该绝对迁移到版本 2 吗？我想知道是否可以依靠 play 1 在近期或中期不
是否可以运行一些 Controller 和 路线仅在测试模式下？ 单击链接时，我需要模拟一些响应。我将创建仅在运行 时可用的 Controller 和路由游戏测试 . 是否可以？ 最佳答案 正如 Mi
我正在使用PlayFramework 2.4.6，尝试上传多部分文件(大小为18M)，并且服务器返回以下错误: For request 'POST /api/myEndpoint' [Request
由于依赖于我正在使用 Play!Framework 开发 Web 应用程序的项目，我必须配置 logback 以防止它用 DEBUG 消息淹没我的输出。 但由于 log4j 是 Play!Framew
我正在使用 PlayFramework 的 2.0.2 版本，并且正在尝试创建一个游戏play.mvc.Action实现 后置过滤器 对于 http 结果。 play docs 中解释了使用 acto
我已经开发了一个基于 Play Framework 的小应用程序(我还在学习)。现在我需要把它捆绑起来运输。一种方法是创建一个 war 文件并将其部署在 servlet 容器(例如 tomcat)中
使用 Play Framework 2.1.1-RC1，我将一个项目分成多个模块，如下所示: object ApplicationBuild extends Build { val appName
我正在使用 Play 2.1 (Java) 和 Play 附带的默认 logback (1.0.7) 记录器。在我的一个 Controller 中，我使用“play.Logger”来打印调试日志消息。
这个问题不太可能帮助任何 future 的访客；它仅与一个小地理区域、一个特定时刻或一个非常狭窄的情况相关，而这些情况通常不适用于互联网的全局受众。如需帮助使这个问题更广泛地适用，visit the
我是一名优秀的程序员,十分优秀！