草庐IT

stream_socket_client

全部标签

java - fallback 如何与 socket.io 一起工作?

我想将WebSocket与Java一起使用。问题是,我的服务器通过无法配置的代理与客户端分开。我一直在寻找带有诸如long-polling之类回退的WebSocket的实现。我找到了socket.io但不知道回退是如何工作的。它在什么情况下取代WebSocket,如何取代?是否有其他库(如socket.io)具有回退实现?我想在Java中找到一个,但我只找到了Jetty。编辑:回退是否仅取决于浏览器与WebSocket的兼容性?如果失败的原因是代理配置错误怎么办,socket.io是否会将其检测为兼容性失败并因此切换到长轮询(或其他技术)?回答:从v1开始,socket.io包括eng

java - 卡夫卡 : How do I enable client logging?

当我实例化一个Kafka消费者时KafkaConsumerconsumer=newKafkaConsumer(props);我收到这条消息SLF4J:Failedtoloadclass"org.slf4j.impl.StaticLoggerBinder".SLF4J:Defaultingtono-operation(NOP)loggerimplementationSLF4J:Seehttp://www.slf4j.org/codes.html#StaticLoggerBinderforfurtherdetails.如何为我的客户端程序启用日志记录? 最佳答案

java - Streaming 的多项操作能否打破 Demeter 法则?

我有点想用Java8流编写Selenium页面对象,如下面的代码所述,并收到评论说我的代码违反了Demeter法则,因为我在一行中执行了很多操作。我被建议将代码分解为第一个流以收集列表并运行另一个流操作来进行匹配(简而言之,根据需要将其分解为多个流)。我不相信,因为引入Stream是为了处理数据处理,如果我们将它分解成多个流,那么使用流就没有意义了。之前我曾在一个网络安全项目中工作,其中数百万条记录通过流式处理和多个逻辑操作对数据进行排序。请分享您的想法,我已按照审阅者的建议对其进行了更改,但他无法解释原因,我想了解有关流的更多信息以及利用Java8的这一强大新增功能的正确方法。示例代

java - Spliterator 与 Stream.Builder

我读了一些关于如何创建有限的Stream的问题(FinitegeneratedStreaminJava-howtocreateone?,Howdostreamsstop?).建议实现Spliterator的答案。Spliterator将实现如何提供以及下一个提供哪个元素的逻辑(tryAdvance)。但是还有另外两个非默认方法trySplit和estimateSize()我必须实现。Spliterator的JavaDoc说:Anobjectfortraversingandpartitioningelementsofasource.Thesourceofelementscoveredby

java - 如何在 Java 8 Stream API 中使用 Collectors.grouping 来创建 map

我第一次寻找Java8的StreamAPI。我尝试创建一个过滤器来从Map中删除元素。这是我的map:Mapm=newHashMap();我想删除值)。这是我一直在尝试的:m.entrySet().stream().filter(p->p.getValue()>0).collect(Collectors.groupingBy(s->s.getKey()));我得到一个HashMap>。所以,这不是我想要的。我也试过:m.entrySet().stream().filter(p->p.getValue()>0).collect(Collectors.groupingBy(Map::Ent

java - 如何使用 Stream API 随机播放流?

我决定采用函数式方法生成字符串或随机字符,到目前为止我想到了这个,它应该比装箱然后使用StringJoiner作为收集器执行得更好:Randomrandom=newRandom();StringrandomString=IntStream.concat(random.ints(8,'a','z'),random.ints(8,'A','Z')).collect(StringBuilder::new,(sb,i)->sb.append((char)i),(sb1,sb2)->sb1.append(sb2)).toString();我想生成16个字符的流,范围从a-z或A-Z,我遇到的问题

具有 3 个参数的 Java8 stream.reduce() - 获得透明度

我编写这段代码是为了将单词列表缩减为一个很长的计数,即有多少单词以“A”开头。我编写它只是为了学习Java8,所以我想更好地理解它[免责声明:我意识到这可能不是编写此代码的最佳方式;这只是为了练习!]。LongcountOfAWords=results.stream().reduce(0L,(a,b)->b.charAt(0)=='A'?a+1:a,Long::sum);中间参数/lambda(称为累加器)似乎能够在没有最终“Combiner”参数的情况下减少完整列表。事实上,Javadoc实际上说:The{@codeaccumulator}functionactsasafusedma

java - Stream.sorted() 然后收集,还是收集然后 List.sort()?

这个问题在这里已经有了答案:Whatismoreefficient:sortedstreamorsortingalist?(3个答案)关闭4年前。总的来说,这两段代码在性能上有区别吗?Listlist1=someStream1.sorted().collect(toList());//vs.Listlist2=someStream2.collect(toList());list2.sort(Comparator.naturalOrder())变体2显然令人讨厌,应该避免,但我很好奇Stream的主流(嘿,mainstream)实现是否内置了任何性能优化,从而提高了性能两者的区别。我想因

java - 如果 Tomcat 服务器说 "Client Aborted",而客户端说 "Premature EOF",谁是对的?

我有一个Tomcat服务器通过http将数据流式传输到Java客户端。它将字节从文件复制到servlet中的HTTPServletResponse输出流。客户端使用HttpURLConnection连接并读取数据。有时一切正常,有时客户端和服务器都会抛出异常。客户说有一个“过早的EOF”。服务器声明“ClientAbortException”。是不是只有上述一种可能?客户:java.io.IOException:PrematureEOFatsun.net.www.http.ChunkedInputStream.fastRead(ChunkedInputStream.java:234)a

socket.io库xamarin.forms(便携式类库)

我应该使用哪个库来连接socket.io从C#Xamarin表格(便携式类库)至nodejs应用程序。我想创建用于移动的跨平台应用程序,并在Web应用程序的插座上进行通信。我所有的nodejs代码都使用socket.io库编写。这是示例代码,因为我不能粘贴所有套接字代码,所以它太大而无法粘贴,所以我要粘贴示例代码。Nodejs代码:io.on('connection',function(socket){console.log('auserconnected');socket.on('hi',function(data){console.log('HelloWOrld');});socket.o