聚合完成的线程并在超时后发送响应rX Java
rX Java是一个基于观察者模式的异步编程库，用于处理数据流和事件序列。它是Java编程语言的响应式扩展，提供了丰富的操作符和工具，使开发者能够更轻松地处理异步任务和事件流。
rX Java的主要特点包括：
- 响应式编程：rX Java通过使用观察者模式和可观察序列（Observables）来实现响应式编程。开发者可以通过订阅观察者来接收数据流，并使用操作符对数据进行处理和转换。
- 异步处理：rX Java提供了丰富的操作符，如map、filter、reduce等，用于对数据流进行处理和转换。这些操作符可以在不阻塞主线程的情况下进行异步处理，提高应用程序的性能和响应能力。
- 线程管理：rX Java可以方便地管理线程，包括线程的创建、调度和销毁。开发者可以使用操作符指定任务在特定的线程上执行，从而更好地控制并发和并行处理。
- 错误处理：rX Java提供了丰富的错误处理机制，包括异常处理、重试机制和错误回退等。开发者可以通过操作符来处理和恢复错误，保证应用程序的稳定性和可靠性。
- 跨平台支持：rX Java可以在多个平台上使用，包括Java SE、Android、JavaScript等。这使得开发者可以在不同的环境中共享和重用代码，提高开发效率和代码质量。
rX Java在云计算领域的应用场景包括：
- 异步任务处理：云计算环境中常常需要处理大量的异步任务，如数据处理、消息传递、事件处理等。rX Java提供了强大的异步处理能力，可以帮助开发者更好地管理和处理这些任务。
- 数据流处理：云计算环境中的数据通常以流的形式存在，如日志数据、传感器数据、网络数据等。rX Java提供了丰富的操作符，可以对数据流进行处理、转换和聚合，帮助开发者更好地分析和利用数据。
- 并发编程：云计算环境中常常需要处理大规模的并发请求，如Web服务、分布式计算等。rX Java提供了线程管理和并发处理的能力，可以帮助开发者更好地管理和调度并发任务。
腾讯云提供了一些与rX Java相关的产品和服务，包括：
- 腾讯云消息队列 CMQ：腾讯云消息队列 CMQ是一种高可靠、高可用的消息队列服务，可以与rX Java结合使用，实现异步消息传递和事件驱动编程。
- 腾讯云函数 SCF：腾讯云函数 SCF是一种事件驱动的无服务器计算服务，可以与rX Java结合使用，实现按需执行的函数计算。
- 腾讯云流计算 TSC：腾讯云流计算 TSC是一种实时数据分析和处理服务，可以与rX Java结合使用，实现实时数据流处理和分析。
更多关于腾讯云产品和服务的信息，可以访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
简短描述：--我正在尝试获得一个ZuulProxy来处理实例故障转移，但是它会抛出ZuulException: Forwarding错误，而不是用一个工作实例的结果进行响应。
Long description: My是一个独立的Eureka、一个ConfigServer、一个ZuulProxy (@EnableZuulProxy)和两个服务实例，它们都在Eureka中注册。
所有的一切都是用spring云启动器父Angel.SR3运行的。
我的servicediscovery:
@SpringBootApplication
@EnableEurekaServer
public class Eu
浏览 0提问于2015-08-20得票数 16
回答已采纳
1回答
我已经为长轮询编写了我的服务器端代码。我想用java编写客户端程序。因此，对于每个长轮询，客户端发送一个请求，该请求得到服务器的帮助，服务器在事件发生时响应该请求，然后客户端发送一个新的请求。
所以我面临的麻烦是客户端，它是用java编写的。在我发送请求之后，如何保持在客户端检查服务器是否响应它。我应该每隔多长时间向服务器发送请求。我完全糊涂了。我对Web技术还是个初学者。我尝试过用谷歌搜索这个问题，但所有的例子都是基于客户端的java脚本或JSP。谁能给一个适当的教程的链接与客户端是一个java HTTp应用程序或提供一个例子(即实现长轮询)。
浏览 0提问于2013-07-23得票数 4
回答已采纳
1回答
BSD流套接字是全双工的，这意味着连接双方可以同时发送/接收。
QTcpSocket (qt套接字实现)具有异步支持、非阻塞模式，但只能属于一个线程，参见。
事件驱动对象只能在单个线程中使用。具体而言，这适用于计时器机制和网络模块。
假设我希望使用相同的套接字并同时发送/接收数据，就需要一个transmit/tx线程和一个单独的接收/rx线程。
据我理解，这可以通过qt信号/插槽“完成”，但是套接字线程永远不会真正同时执行send()和接收()。它只运行事件循环，它将以串行方式执行此操作，并在完成发送/接收时发出信号。
是的，我的rx和tx线程可以并发工作并通过qt插槽处理通知，但是套
浏览 4提问于2015-01-16得票数 2
回答已采纳
3回答
我的骡子流中有JMS，其中生产者从缓存中读取记录，放入队列，消费者使用消息并进行进一步处理。以下是理解的流程。
服务1(从文件读取数据) ->服务2(将每一行放在缓存中) -> JMS 3(从缓存逐行读取数据并放入队列)和用户从队列->服务4读取数据
在上面的流程中，在JMS组件中，一旦生产者将所有记录放在队列响应中，流就会变成异步，返回到客户端，表示流程已经完成，但是消费者仍然有可能使用消息。
我希望保持进程从生产者发送回响应，直到消费者使用所有的消息。
对此有何想法如何实现？
浏览 3提问于2017-08-18得票数 0
大家好，我在调用微服务时遇到了异常。我正在使用j hipster生成的网关和微服务应用程序，请为问题.i更改所有超时设置，但我仍然无法调用服务。
调用微服务时出现异常。我正在使用j hipster生成的网关和微服务应用程序，请为问题.i更改所有超时设置，但我仍然无法调用服务。
com.netflix.zuul.exception.ZuulException: Forwarding error
at org.springframework.cloud.netflix.zuul.filters.route.RibbonRoutingFilter.handleException(Ribbon
浏览 0提问于2018-04-11得票数 2
我有一个使用TClientSocket用Delphi编写的应用程序，它向另一个用C#编写的应用程序发送数据。由于许多原因，C#应用程序响应缓慢，阻塞了我的Delphi应用程序，不尊重我设置的超时。
我的Delphi应用程序的响应如下：
Sock.Socket.ReceiveText
这将导致应用程序等待响应。但是，如果我这样做，应用程序等待并尊重超时：
while not receiveData do
begin
if Sock.Socket.ReceiveLength > 0 then
begin
receiveData := True;
end;
Inc(Co
浏览 6提问于2016-09-06得票数 0
回答已采纳
2回答
我有一个用于异步执行的应用程序。
我在get方法上设置了参数，当线程没有得到响应时，线程应该在10秒后被杀死：
Future<RecordMetadata> meta = producer.send(record, new ProducerCallBack());
RecordMetadata data = meta.get(10, TimeUnit.SECONDS);
但这条线在60秒后就死了：
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutExcep
浏览 7提问于2017-11-17得票数 0
回答已采纳
2回答
实际上，我写的是Java (如果这是件大事，而且java有具体的方法来解决我的问题，老实说，我不知道)一个IRC协议客户端，而且有点缺乏知识。我有一条从IRC服务器读取行的行。这一行是：
line = reader.readLine();
它工作得很好，我在循环中使用了这一行，但是如果服务器没有发送任何内容，则在这一行上冻结应用程序。我的问题是，如果服务器在10秒内没有发送任何内容，我如何能够中断循环？
我试过这样做
do {
start = System.currentTimeMillis();
line = reader.readLine();
... //doin
浏览 2提问于2017-04-05得票数 1
回答已采纳
偶尔在爬行的时候，我会得到一个非常慢的响应。
连接速度并不慢，因此超时不起作用。它的主机速度是3-4字节/秒。
有没有办法在超过10秒的时候终止这个请求，比如超时？
浏览 1提问于2011-07-16得票数 0
我有基于Spring的简单应用程序。
在本例中，我不使用任何XML配置。
主要组件是appMain (使用隐式构造函数自动装配)，它依赖于实现LifecycleProcessor的dataCollector。它覆盖并定义了public void start()，我希望它将在创建Spring容器后立即调用。
根据文件：
“任何Spring托管对象都可以实现该接口。然后，当ApplicationContext本身接收到启动和停止信号时，例如在运行时停止/重新启动场景时，它会将这些调用级联到在该上下文中定义的所有生命周期实现。”
但是这个start方法从未被调用过。那么，start signal是必
浏览 1提问于2017-06-09得票数 0
1回答
我遇到了一些麻烦的外部硬盘。恐怕它已经开始被腐蚀或损坏了。
在应用程序中，我使用statfs检索外部HDD的信息：
const char *mountPoint = "/media/hdd";
struct statfs s;
statfs(mountPoint, &s);
但是，我不时地在应用程序日志中注意到，整个Linux系统被阻塞(事实上，是因为没有在正确的时间注册一些事件)。我在这些“关键”时刻输入了"df“命令，自己注意到了这一点。其效果是所有分区显示正确，但HDD分区除外，其行在出现前持续几秒钟。
此外，HDD被格式化为NTFS，我使用ntfs-3g
浏览 0提问于2015-07-16得票数 1
我有请求列表，我需要在线程中发送它们，并在线程完成时收集所有响应。我怎么知道所有的踏面都修好了？
List<Task<Response>> tasks = new ArrayList<Task<Response>>();
for (Request request : requestList) {
tasks.add(executor.runTask(new RequestCaller(request))); // runTask is my method witch will run threads
}
for (int i
浏览 2提问于2011-08-06得票数 1
回答已采纳
2回答
我正在构建一组web服务，目的是聚合多个后端的相似数据集(通过db调用和服务调用)。有些查询可能需要几秒钟以上的时间才能运行，如果我按顺序堆叠这些请求，总的运行时间可能会超出期望的响应时间。
我希望并行调用，收集所有结果，然后聚合。解决这个问题的最佳方法是什么？
这些服务将被部署到Websphere 6.1 (so java5，j2ee 1.4)。
任何信息都将不胜感激。
浏览 1提问于2011-04-28得票数 0
回答已采纳
我的jax-ws web服务(在它被客户端请求击中之后)向后端遗留平台(通过套接字)发送一个请求，然后等待20秒的响应。
在发出该请求之前，它会使用其唯一的事务编号更新表。
一个单独的监听线程(独立的java应用程序)正在该套接字上等待响应，每个响应将在其中具有事务编号，以标识它与哪个请求(先前发送)相关联。
这个独立的java应用程序如何与在web服务中等待的线程通信，表明它的响应已经到来，并且它可以继续其处理。
目前，我认为监听器线程可以更新表(基于事务编号)，以指示响应已经到达。并且web服务线程可以在数据库中保持轮询(每2秒检查一次)，以确定响应是否已经到达。
我正在寻找一些推送通知在
浏览 3提问于2012-07-14得票数 1
1回答
环境
主机应用程序是Windows (.NET 3.5)；
目前还没有可能切换到.NET 4+框架。
过程
处理一条消息可能需要5分钟。
使用异步模式(ReceiveCompleted事件订阅接收消息)：
私有OnMessageReceived(对象源，ReceiveCompletedEventArgs eventArgs) { var queue =(MessageQueue)源；消息m= null；尝试{ var处理器=新线程(() => { try { // 1.处理消息// 2.向m的响应队列}catch(异常ex) {Logger.Log.Error(
浏览 3提问于2016-03-23得票数 3
1回答
我正在将Azure Web应用程序(应用程序服务)用于java (java 8)应用程序(.war)。它使用了Spring4和JSP。
某些请求需要超过4-5分钟才能发送响应。
Azure应用程序服务有一个限制，如果一个请求在230秒内没有得到任何响应，它就会抛出请求超时，并且我们无法更新此超时持续时间。
我想知道是否有办法确保在响应仍在准备期间请求不会保持空闲(例如，如果响应尚未发送，则每3分钟发送一次)。
浏览 0提问于2020-12-30得票数 0
5回答
我是一个嵌入式程序员，试图为一个通信应用程序做一点编码，需要一个最好/最简单的方法的快速入门指南。
我成功地发送了串行数据包，但需要实现某种形式的发送/响应协议，以避免目标系统上的溢出，并确保数据包被正常接收。
现在-我有所有的传输代码在一个按钮点击，它发送整个没有任何控制的一批。组织这段代码的最好方法是什么，即发送一些数据包-等待响应。发送更多..依此类推，直到全部完成，然后继续执行主程序。我以前没有在这个环境中使用过线程或回调之类的东西，但我会学习的--我只需要一个指向最直接的方法的指针。
谢谢Rob
浏览 0提问于2009-10-18得票数 2
2回答
不等待响应的HTTP请求
、、、
是否可以在不等待响应的情况下发送HTTP请求？
我正在从事一个IoT项目，该项目需要记录来自传感器的数据。在每个设置中，有许多传感器和一个中央协调器(主要由树莓派实现)，它从传感器收集数据，并通过互联网将数据发送到服务器。
这种日志记录每秒都会发生。因此，数据的发送速度应该很快，这样队列才不会变得太大。如果请求不等待响应(如UDP)，则速度会快得多。
如果偶尔丢弃几个数据包，这是可以的。
另外，请告诉我实现这一点的最佳方式。最好是用Java编写。
服务器端是使用PHP实现的。
提前感谢！
编辑:传感器是无线的，但它们使用的技术在发送到协调器时延迟很小(或没有)。该协调器必须通过互联网发送数据。
浏览 1提问于2016-05-31得票数 4
我使用的是Apache Http client的executeMethod，它会一直阻塞，直到收到服务器响应。我可以设置超时，但一旦超时到期，客户端似乎就无法继续等待响应。
是否可以让Apache Http客户端在超时后恢复等待响应？
浏览 1提问于2011-07-28得票数 2
1回答
是否可以取消当前正在执行的SOAP请求(Axis1.4，Java1.6)？
我使用的是用WSDL2Java生成的接口，所以调用类似于myProvider.submitMyRequest(request)。这是同步的，直到收到响应才会返回。我希望能够基于外部条件中断呼叫。除了终止运行请求的线程之外，我还有什么选择？
浏览 4提问于2010-05-12得票数 2
我正在调用一个Web服务，我希望它能在5秒内响应。如果它不能在5秒内处理它(忽略网络延迟)，我希望它回滚事务并向我发送一个超时异常。
我可以看到只在调用客户端的代码上设置了超时。我希望这由Web服务实现者(服务器端)强制执行。我似乎找不到任何方法来做这件事。
如果我通过在客户端指定超时来超时，服务器很可能会继续并完成事务。我甚至不知道原始请求是否成功，或者它是否遇到任何错误，因为它在服务器完成请求处理之前超时。
我正在使用Java客户端与EJB实现的WS进行对话。感谢您的任何意见。
谢谢你，芒露
浏览 0提问于2009-05-14得票数 2
我使用外部邮件服务器发送SMTP邮件，此服务器实际上超出了我的控制范围。
最近，这个邮件服务器出现了几次问题，这导致我的Java (Struts/Spring)应用程序在等待邮件服务器的回复时完全挂起。
我正在使用Spring org.springframework.mail.javamail.JavaMailSender发送邮件。
当外部邮件服务器出现问题时，下面的一行会冻结mailEngine.send(mailMessage);
我不介意有时电子邮件不会被发送，但是当我的应用程序等待SMTP服务器的回复时，我该如何阻止它冻结呢？
有什么好的Java电子邮件排队解决方案吗？
浏览 10提问于2010-03-02得票数 4
有没有办法向多个服务器发送(广播)一个请求？
我的要求是，我需要一个模块，可以发送一个单一的请求到多个服务器(一般来讲，广播的请求)，.After它等待响应一段时间，比如说5毫秒)，它从不同的服务器得到的响应，它要么棍棒在一起，并发送回客户端，或基于响应中的一个参数(假设价格)，它发送响应到客户端。
例如:请求(获取价格)需要一次发送到server1、server2、server3和Server4。server1响应:价格：$5 server2响应:价格：$3 server3在5毫秒内没有响应server4响应:价格：$8
我的模块或者将server4响应发送回客户端，因为它具有最高的价格，或
浏览 0提问于2014-05-14得票数 2
当我的输入主题中有1000条消息时，我想要一个java代码来停止ActiveMQ 5分钟。然后在5分钟后再次启动。
谢谢！
浏览 0提问于2013-04-10得票数 1
很少的接口调用得到RunTime异常，并且不能理解根本原因。
INFO | jvm 1 | main | 2020/02/28 14:04:34.738 | java.lang.RuntimeException: java.util.concurrent.TimeoutException
INFO | jvm 1 | main | 2020/02/28 14:04:34.738 | at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:463) ~[rxja
浏览 21提问于2020-02-28得票数 0
1回答
在Rxjava上管理线程
、、、、
我正在尝试实现Redux模式来管理状态，在Jake：的演示文稿之后，我希望流中的所有内容都在后台线程上运行，并在AndroidMainThread上接收输出。但是，在当前设置之后，我的订阅服务器抛出一个异常，即在AndroidMainThread之外的另一个线程上操作UI。提前谢谢。
Observable events = Observable.merge(Observable.just(new GetUsersEvent()/*, other event streams*/));
events.compose(mergeEvents(GetUsersEvent.class,
浏览 2提问于2017-04-25得票数 1
回答已采纳
我正在试图找出一个场景，在这个场景中，应该为一个ListItem列表中的每个SharePoint触发一个邮件。
Sharepoint列表如下
ID-相关名称-再发邮件
1.准直接合同-直接合同
2粉末冶金金氏粉末冶金粉末冶金Kim@gmail.com
3.初级商品-商业银行( Sim@gmail.com )
我已经创建了一个Power工作流，它是根据重复调度触发的。当它被触发时，它会检查一个包含个人列表的SharePoint列表。流程应该处理每一个个体，
options".wait 触发器邮件使用发送电子邮件进行响应(批准/拒绝/需要一些详细信息)记录从单个收到的响应
但这里的问题是，
浏览 4提问于2022-04-04得票数 0
当使用apache客户端从我的web应用程序对第三方系统进行http调用时，我遇到了一个问题。我使用的是http 4.4.4和4.5.1。此票证表示已解决死锁问题，并在异常情况下优雅地终止线程。有没有人面对这个例外，以及知道是甚麽原因造成这个问题，以及如何解决这个问题呢？
编辑:用于进行Http调用的http代码段
protected <ResponseObj> run() throws Exception {
String uri = <target system uri>;
HttpPost httpPost = new HttpPost(uri
浏览 5提问于2017-03-26得票数 6
2回答
我正在尝试编写一个程序，它可以不断地监听UDP上的数据包，但也会定期发送UDP上的数据(每隔x秒)。棘手的部分是我接收的数据将改变我发送的数据，所以我不认为我可以简单地在一个单独的线程中完成其中一个任务。我也不能有任何阻塞。我希望有人能给我一个正确的方向。如果相关，我正在用Java编程，并且将同时与多个客户端发送和接收数据。
浏览 1提问于2016-10-14得票数 0
3回答
我对boost::asio库没什么问题。我的应用程序异步接收和处理数据，它创建线程并在每个线程上运行io_service.run()。
boost::asio::io_service io;
boost::thread_group thread_pool;
...
int cpu_cnt = get_cpu_count();
for (int i = 0; i < cpu_cnt; ++i)
{
thread_pool.create_thread( boost::bind(&run_service, &io) );
}
void run_service(boos
浏览 0提问于2008-12-10得票数 1
回答已采纳
2回答
Winsock接受超时
、、、
在使用阻塞winsockets时，是否可以将超时设置为接受函数？就像我们可以通过setsockopt来恢复和发送功能一样？
似乎不可能，但我想确保。
浏览 1提问于2012-03-13得票数 4
回答已采纳
我使用Httpurlconnection从我的jboss服务器向我的设备发送请求。该设备是由cgi建立的。
当服务器一次从多个线程向设备发送请求时，一些线程会得到一个异常，比如java.net.ConnectException: Connection refused。但是设备会在一定的延迟时间内向服务器发送响应。我将httpurlconnection超时设置为30秒(3000毫秒)。
但只有当多个线程同时发送它时，错误才会出现。
有没有人知道请指导我解决这个问题。
java.net.ConnectException: Connection refused: connect
at jav
浏览 0提问于2013-11-27得票数 2
回答已采纳
当我发送延迟为200秒的响应时，我的expressJS框架出现了问题，它发送的是err_empty_response，状态代码为324
下面是fakeTimer示例
fakeTimeout(req, res) {
setTimeout(() => { res.json({success: true})}, 200000)
}
浏览 1提问于2018-05-21得票数 0
1回答
我们有一个用Java编写的自定义消息传递系统，我想实现一个基本的批/压缩特性，它在负载很重的情况下，会将一堆推送响应聚合到一个推响应中。
实质上：
如果我们检测到在过去的一秒内发送了3条消息，然后开始批处理响应并安排一个计时器在5秒钟内触发定时器将在接下来的5秒内接收到的所有消息响应聚合到一个消息中。
在我寻找Java中最好的例子之前，我确信这已经实现了。我并不是在寻找一个完整的消息传递层，仅仅是基本的每秒检测消息并安排一些任务(显然，我可以轻松地自己编写它--我只是想将它与任何现有的算法进行比较，以确保我没有遗漏任何边缘情况，或者我已经尽可能地简化了问题)。
是否有构建基本QoS批处理/节流
浏览 1提问于2010-09-02得票数 2
我在servlet中打包了一个数据流作业(在BlockingDataflowPipelineRunner模式下运行，每天由CRON作业(在AppEngine中)触发)。
当管道完成时，我无法执行一些Java脚本。它在使用Jetty在本地启动时工作，但在使用AppEngine部署时不起作用。
做这样一件事最好的方法是什么？
编辑:这是我得到的错误。基本上，我尝试先将数据沉入云存储中，然后执行BigQuery修补程序，然后加载标准的java代码。
在日志记录中，这是在Dataflow日志之后可以找到的内容(虽然我看不到任何“停止数据流工作人员”日志，这很奇怪.)：
javax.net.ssl.S
浏览 7提问于2017-08-03得票数 0
回答已采纳
2回答
因此，我试图做以下工作:我有两个参与者(我们称他们为A和B)通过TCP套接字(send()和recv())进行通信。A是发送一个计数器和一个随机的现在，B只是用它得到的同样的消息来响应。然后检查响应是否与发送的数据包匹配，如果是，则会增加计数器并重复。
这是一个代码片段，说明了A目前所做的事情：
send(sock, payload, strlen(payload), 0);
struct timeval t_out;
t_out.tv_sec = 0;
t_out.tv_usec = 5000;
setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO,&t
浏览 4提问于2020-04-10得票数 0
I有时会出现异常-- android.os.NetworkOnMainThreadException，有时代码会工作.
这是我的密码
Observable.create(new Observable.OnSubscribe<Response>() {
OkHttpClient client = new OkHttpClient();
@Override
public void call(Subscriber<? super Response> subscriber) {
try {
浏览 0提问于2017-04-19得票数 0
1回答
我开发了一个基于java的客户端，它使用Java套接字连接到服务器。为了信息交换，我使用了http协议。基本上，我通过一个套接字建立了一个连接，并在客户端编写了一个向服务器发出http请求的方法。我正在连接的服务器是我自己开发的一个非常简单的服务器，我想问一问，是否可以通过套接字使用请求-方法进行长时间轮询。
由于我的类客户机中有一个请求-方法，我有两个选项：-一个连续请求：包含发送每毫秒的请求，询问是否发生了新的事件。一个长时间的请求(称为长轮询)：客户端发送请求。如果服务器有响应，服务器将响应。否则，它将不会发送响应和请求将超时。此时，客户端发送一个新请求。
下面是对我的模型的描述：
I
浏览 7提问于2015-08-06得票数 2
回答已采纳
2回答
我正在尝试理解如何将我的Java象棋引擎移植到dart。
因此，我知道我应该使用隔离来运行我的引擎与GUI并行，但我如何才能强制引擎终止搜索。
在java中，我只是设置了一些在引擎线程和gui线程之间共享的布尔值。
我得到的答案是：
您应该向隔离器发送一条消息，告诉它停止。您可以简单地执行以下操作：
port.send('STOP')；
我的请求
谢谢你的澄清。我不明白的是，如果国际象棋引擎隔离由于思考(‘port.send’)命令而繁忙，它如何响应停止(‘port.send’)命令
浏览 0提问于2013-05-11得票数 5
回答已采纳
我的应用程序使用Java串行通信api。如果没有可用的数据，inputstream.read()方法将阻止读取文档。
我尝试在serialport对象上设置超时，但isReceiveTimeoutEnabled()方法返回false，这表明我的驱动程序本身并不支持超时。
那么，考虑到上述情况，实现读取超时的最佳方式是什么？
谢谢，弗莱德
浏览 0提问于2010-04-13得票数 1
嗨，我试图通过Rest模板从不同的服务调用一个spring引导服务。我现在使用领事作为服务发现服务--Service1->rest->service2
我不希望这种沟通通过Zuul service1应该能够直接打电话给service2，但是丝带应该通过领事发现第二个服务。每件事情都很好，但是当我试图调用service1到service2时，我在service1的异常之下
java.lang.IllegalStateException: No thread-bound request found: Are you referring to request attributes out
浏览 11提问于2016-06-06得票数 1
我知道spring集成有TcpInboundGateway、TcpOutboundGateway和ByteArrayStxEtxSerializer来处理通过TCP端口传输的数据。
如果TCP服务器需要读取从客户端发送的所有数据，然后对其进行处理，ByteArrayStxEtxSerializer就会工作得很好。(请求和响应模型)我使用的是single=false，这样就可以在同一个连接中处理多个请求。
例如，如果客户端发送0x02AAPL0x03，那么Server可以发送AAPL价格。
如果客户端发送0x02AAPL0x030x02GOOG0x03，则我的TCP服务器正在工作。它发送AAPL
浏览 2提问于2016-11-05得票数 0
回答已采纳
2回答
我正在为BB开发一个项目。该应用程序与网络一起工作，并通过HTTP发送/接收数据。现在我使用队列和队列管理器。管理器从后台线程开始，在while (true)循环中工作，检查队列中是否有新的事务发送到服务器。如果队列不为空，则执行事务，否则管理器将休眠200毫秒。
事务的处理过程如下：-运行另一个线程(使用Runnable)，它打开一个到网络的连接，第一个线程等待我们设置的后台线程或超时(为此，我们需要一个循环)。-如果建立了连接，然后启动另一个线程(使用Runnable)，它运行getResponseCode ()，并启动第一个线程，等待我们设置的后台线程或超时(为此，我们需要一个循环)。
浏览 2提问于2010-03-05得票数 3
回答已采纳
2回答
我正在开发一个多线程的JMS接收器和发布器代码。从队列接收XML消息，调用存储过程(执行时间为70秒)，并在90秒内将响应发送到主题。我需要处理broker宕机时的情况。即从队列接收消息并在java中处理消息的情况，同时队列和主题都将关闭。那么如何处理那些不在队列中、没有发送到主题但在java内存中的消息呢？不同的选项可用：
1.使用CLIENT_ACKNOWLEDGE 2.将发布者代码与接收者代码分开。3.使用error实用程序从日志中获取消息并对其进行处理，然后发送到主题(最不受欢迎)
请给我推荐一个合适的选项
浏览 1提问于2010-09-22得票数 1
回答已采纳
我在WSO2 Esb上工作了几个月，现在我需要使用Iterator中介器拆分传入的消息，将每个部分发送到一个端点，并使用聚合中介收集答案。就像这样：
<iterate expression="//element" id="ELEMENTS">
<target>
<sequence>
[send to endpoint using element data]
</sequence>
</target>
</iterate>
&
浏览 1提问于2016-12-29得票数 0
我正在开发一个基于java (+netty)的系统，它接收来自客户端的不同类型的消息，聚合它们并将聚合结果推送到存储中。
I需要在聚合之前预先积累消息，直到满足两种条件之一--超过超时或超过数量。超时和数量是为每种类型预先配置的，可能会有很大的不同。之后，我聚合/减少相同类型和发送方的消息，并将结果推送到存储中。聚合可能类似于计算消息之间的平均值。或者可能要复杂得多。在我的情况下，存储中的后聚合是不可接受的。
这个任务似乎很简单，但我仍然坚持实现。显然，我需要收集某些数据结构中的消息，并检查每个元素的超时和数量规则。我想到了DelayedQueue<Delayed<List<
浏览 1提问于2014-04-05得票数 1
回答已采纳
我是Rx的新手，我正在尝试创建一个可观察的序列，它将允许我执行以下操作：
使用System.Net.Http.HttpClient.SendAsync( request，cancelToken)向URI发送HTTP请求
等待返回响应或请求超时的可配置时间段。
如果请求超时，则重复请求。
继续重复请求，直到收到响应(不一定是200确定)或最大响应。达到重试次数。
如果最大的。达到重试次数，那么我必须知道它，这样我就可以记录一个错误。
我一直在玩：
HttpRequestMessage request = new HttpRequestMessage(HttpMetho
浏览 0提问于2014-12-10得票数 6
回答已采纳
1回答
我有一个向导(org.apache.wicket.extensions.wizard.Wizard)，它有一个AjaxButton作为下一个按钮。
我正在对next按钮的onSubmit()方法执行一个长时间运行的操作。在退出该方法之前，我使用了ajaxTarget.appendJavascript(js)，其中ajaxTarget是AjaxRequestTarget，js是我想要计算的JavaScript片段。
现在，据我所知，在返回`onSubmit()并将响应发送回浏览器之前，这个脚本不会被执行。
如何在不等待onSubmit完成的情况下立即执行我的JavaScript？
注意:我使用的
浏览 0提问于2016-07-04得票数 0
遇到了一个很奇怪的问题正在寻找方向。
上下文：在WordPress中上传大文件(最多100 up)。作为这个过程的一部分，服务器端也有一个很长的任务正在运行(通过他们的API使用分块将文件推送到DropBox )，因此对于较大的文件不可避免地会延迟响应。通过执行PHP的sleep()函数，可以很容易地模拟该部分。
问题：文件上传器达到100%，显示waitingForResponse消息约15秒(此时服务器仍未完成处理)，然后从头开始重新启动上传。第二次尝试之后，它声称没有从服务器接收到任何内容，并将上传列为失败。控制台调试消息：
[FineUploader] xhr - server res
浏览 2提问于2013-05-19得票数 2
回答已采纳
4回答
给定一个List<Message>，我用Send(message)发送第一条消息。现在，我想在发送下一条消息之前等待(异步)响应返回.
阻塞直到被通知为“旧”方式
我知道如何针对这种情况使用线程锁定/使用Monitor.Wait和Monitor.Pulse实现基于事件的解决方案。
反应的“新”方式？
但我在想，在这里使用是否有意义？
如果Rx将在这里传递有价值的好处，那么，如何能够使响应主动地进入下一次发送调用？显然，它将涉及IObservable，可能是两个主要来源，但之后呢？
浏览 5提问于2011-09-21得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
