《阅文》专题

我最近被介绍给LMAX Disruptor，并决定试一试。多亏了开发人员，安装速度很快，没有任何麻烦。但如果有人能帮我，我想我遇到了一个问题。 问题：有人告诉我，当制作人发布活动时，它应该阻止，直到消费者有机会在包装之前取回它。我在消费者方面有一个序列障碍，我可以确认，如果生产者没有发布数据，消费者的waitFor呼叫将被阻止。但是，生产者似乎并没有受到任何监管，只会在环形缓冲区中封装并覆盖未处理

我正在使用Jasper Report 6.9.0版本和Java 1.8.0\u 201以及Arial Unicode MS和NotoSerifCJKsc（尤其是繁体中文）字体来显示Jasper Report的中文字符。 Pdf生成正确，当我在chrome上打开它时，我能够看到完整的内容，但是如果我尝试用Acrobat reader打开它，那么我就会收到错误 “无法提取嵌入字体“PWLEAX Not

我正在构建一个由亚马逊服务提供支持的警报系统。 我每天将一个文件放到S3上，它生成一个lambda函数（我们称之为生成器函数）来处理该文件。 Generator基于此文件构建警报并将多条消息发布到SNS主题（让我们称之为发件箱）-由Generator计算的每个收件人一条消息。 我在发件箱中订阅了第二个lambda函数（我们称之为Courier），它应该接收每条消息并对其进行处理。 发电机代码： 以

我有一个调查多个主题的消费者。对于这个问题，我限制了每个主题一个分区。假设当消费者开始轮询时，每个主题都有一些数据。阅读的顺序是什么？ 是循环赛吗？它是从第一个读到下一个吗？我使用进行轮询。

所以我遇到了这个不太安全的应用程序 我想知道是否有其他选择？我需要能够通过我的应用程序阅读电子邮件和下载附件，而无需用户自己这么做，因此Gmail API在我看来并不好。 如果不启用此选项，我也找不到任何其他访问gmail收件箱的选项。。。谢谢你的时间。

所以我有一个csv文件，其中的数字是整数，但有尾随。0 当我使用spark csv reader时，给出一个将列指定为整数的模式，它将返回null。 回报 当我将其读取为浮点数，然后将列转换为整数时，它有效。 显示器 这是正常行为吗？我可以将复杂的步骤保存为先读取浮点数，然后强制转换它们吗？ 谢谢

我正试图找到一种方法，使用Firebase云消息发送通知给我的应用程序的所有用户，但我有一个仅限web的应用程序。我见过一些针对Android/iOS的解决方案，基本上是让用户自动订阅一个名为“allDevices”的主题，然后向订阅该主题的所有用户发送通知。我似乎找不到任何关于如何让基于web的用户订阅主题的文档。有人知道这是否可能吗？如果有，是否有我遗漏的文件可以涵盖这一点？ 谢谢！

如果BrokeredMessage的正文是JSON文本，那么是否可以在该JSON中的属性上设置一个带有过滤器的主题订阅？

我正在使用Azure service bus主题/订阅和会话。我正在为sessionId设置一个硬编码值，因为我想控制传入消息的处理。 因此，即使有多个合格的订阅者可以处理该消息，也只有一个订阅者将获得sessionlock并处理它。我通过关闭会话来释放锁，一旦会话完成处理，这样任何处理器都可以接收到新消息。我在这里唯一关心的是，在完成消息处理后关闭会话有没有坏处？如果我关闭会话，会话关闭的处理器

我用Spring4、STOMP和sock做了一个简单的web套接字通信。js,接下来呢,https://spring.io/guides/gs/messaging-stomp-websocket/ 现在我想升级到简单聊天。我的问题是，当用户订阅新的聊天室时，他应该得到过去的消息。我不知道如何捕捉他订阅发送邮件列表的那一刻。 我尝试使用@MessageMapping注释，但没有成功： 然后我创造了：

要求是一次处理一批PDF，成功后用用户密码加密每个PDF。 然而，这些PDF的加密之前随机生成的动态所有者密码（不知道任何人），以防止任何编辑。 我使用iText加密，如下所示： 但此代码抛出 是否有一个关于如何解决这个错误/绕过所有者密码的指导？ 在这里我想说明的是，我们合法拥有这些PDF，所以没有犯罪/黑客行为。

这是我第一次在android中处理应用内计费1）我正在使用API v3 2）我已经上传了我的应用程序的alpha版本，以便能够进行测试 3）我已创建订阅产品 4）这是我要在产品中订阅的代码 我还尝试从应用管理器中清除Google Play Store的数据 有谁能帮忙吗？？

目前我们正在使用Axon 2。我们想把Axon 2升级到4。我们使用Axon 2订阅带有重放选项的事件处理器。在Axon 4中，一个显著的区别是跟踪事件处理器。看来，跟踪处理器是重播的必备。有可能拥有订阅和跟踪事件处理器吗？有没有可能把跟踪处理器只用于重放，剩下的就不管了？还是必须改变整个结构？

如何在Reactor中将一个发布者拆分为两个，这样就存在两个相同的数据流，可以在不同的流中处理下游的数据？ 因此，我可以映射每个流并单独订阅每个流。 我在 API 中看不到任何表明这是在 API 上的内容。 在发布之前，我需要等到两个订阅者都启动并准备好。

有人能帮我弄清楚是什么导致了这个问题吗？