《apache》专题

在我的测试应用程序中，我使用Apache HttpClient向同一主机执行连续的HttpGet请求，但在每个下一个请求时，都会发现之前的HttpConnection被关闭并创建新的HttpConnection。 我使用同一个HttpClient实例，不关闭响应。我从每个实体获取InputStream，用扫描仪读取，然后关闭扫描仪。我测试了KeepAlivestStrategy，结果是真的。请求之

我正在试用ApacheHttpClient 4.3.6连接池管理器，以提高HTTP调用的吞吐量。我的假设是，HTTPClient实现通常使用持久性连接。然而，我的测试代码（包括在最后）的结果显示，使用JDK的多个并发HTTP连接的性能更好。 如何使快速 谢啦 我做了一些观察和结论， JDK在 我的观察来自我贴在这里的例子。它们是比上面粘贴的代码更好的示例。

我正在Scala应用程序中使用Apache Http客户端。 该应用程序具有相当高的吞吐量和高并行性。 我不确定，但我想我可能是在泄露连接。似乎每当使用客户机的代码部分变得繁忙时，应用程序就会失去响应。我的怀疑是，我正在泄漏套接字或其他东西，从而导致应用程序的其他方面停止工作。与其说是连接泄漏，还不如说是关闭速度不够快。 对于更多上下文，有时，某些操作会导致此代码每分钟并行执行数百次。当这种情况发

我尝试了kafka-console-consumer.sh和kafka-console-producer.sh,它工作得很好。我能够看到生产者在消费者中发送的消息 1）我已经下载了s3连接器(https://docs.confluent.io/current/connect/kafka-connect-S3/index.html) 2）将文件解压缩到/home/ec2-user/plugins/

这里有一个原始的、不太详细的问题：不知道为什么我不能将GWT应用程序部署到Apache Tomcat7上。在我写这篇文章的时候，我决定再试一次，这一次成功了。但是，示例应用程序中的servlet似乎不能工作。点击按钮时显示“远程过程调用失败”。下面是我采取的步骤列表。 下面是为了将示例应用程序部署到Apache Tomcat7而尝试执行的操作列表。 在虚拟机上安装Ubuntu 12.04 更新的系

我有一个对象列表，我想从它的字段中得到一个列表<假设我通过了列表

我正在使用Apache HTTPComponents（版本4.5.2），并试图通过代理服务器请求HTTPS页面。 编辑： 我的主要问题是，我需要知道如何区分代理服务器的故障和请求的URI的故障（对于HTTP和HTTPS）。我有很多代理，它们不是百分之百可靠的，所以在代理失败的情况下，我需要用不同的代理服务器重试请求。 例如（对于HTTPS），在这两种情况下都可以返回NoHttpResponseEx

嗨，我是阿帕奇星火新用户。我正在学习的路上。我已经从kafka主题为json数据编写了spark streaming。下面是json数据的连续流。但现在我不知道如何使用这个json数据。我使用DataSet和DataFrame来处理Json数据，但遇到了一些错误。请用几个例子来帮助我，如何使用流式传输的数据流。 注意：我使用的是Apache Spark1.6.3版本。 代码：

我对Kafka和斯托姆有意见。我现在不确定是我正在设置的KafkaSpout配置有问题，还是我没有正确地进行处理。 我在我的Kafka主题上排了50个条目，但我的喷口发出了1300多个（而且还在计数）元组。此外，the Spout报道说，几乎所有人都“失败了”。拓扑实际上并没有失败，它正在成功地写入数据库，但我只是不知道为什么它明显地重播所有内容（如果它正在这样做的话） 最大的问题是： 下面是我如

我一直在使用storm拓扑设置，以便在不出现内存错误的情况下实现最大吞吐量。 3节点storm(V1.0.1)群集。显然，一个节点也是主节点，部署到AWS M3.2xLarge实例上。有12个工作人员（每个节点4个）： 每个工作者有4 GB的堆空间： 特别是我的一个bolt，让我们称之为:具有12的并行性提示。 这将创建12个执行器，每个执行器有一个任务（因为我正在使用Flux配置/部署）。的流类

我正在尝试把阿帕奇Storm和Kafka整合在一起。连接似乎建立良好，但没有收到任何消息。但是这些消息似乎也被发送到了Kafka服务器，而Kafka服务器中相应主题的索引文件显示存在一些数据。有没有一种方法可以在Storm End上调试这个更多的..？我正在使用Storm的客户解码器来处理信息。Storm的实现是：

如果有人能解释一下Twitter Storm和Apache Hadoop在架构上的区别，那就太好了？我正在寻找一些超出实时V/S批处理的内部东西。因为这两种技术在编写Storm的拓扑或Hadoop上的map-reduce、Hadoop的task tracker/Job tracker和Storm的等效Nimbus/Supervisor以及Storm上的Hadoop分区和等效的shuffling（随

我需要一个java程序来生成以下请求。我正在使用Apache HttpClient Library，但仍然无法生成这样的请求： 这是我的python程序生成的，我编写了一个等效的java程序。但它扔403。 2012-09-10 15:12:05G信息：G2OAuth auth data=“3，0.0.0，0.0.0，1347289925，3223833979，crlakamai”2012-09-

我使用HttpClient 4.1.3编写了以下代码： 这是从特定URL获取HTTP 500响应（如中找到的）并抛出异常。 问题是，当我在浏览器中找到“失败”的URL时，它运行得非常好。 所以我问： 是否会超时，缩短请求-响应周期，并且只是给我一个HTTP 500？ 这里还会发生什么？当浏览器显示相同URL的页面完全正常时，怎么可能给我500秒？ 提前感谢！

我试图在java web start应用程序中使用Apache FTPCleint连接到FTP服务器。下面是我正在使用的代码。 问题出现在第