草庐IT

apache-kafka-streams

全部标签

java - Apache 事务 :write file transactionally - how to use resourceId

如果有人实现了事务写入文件,请帮助我。相关主题已在较早的线程(transactionalwrite)中讨论过。用例如下:如果写入日志文件失败,应回滚相应的数据库事务。因此写入文件应该以事务方式执行。我选择了ApacheCommonsTransaction库。有问题,这不会让我更进一步,因为没有找到合适的文档或示例。我已经创建了FileResourceManager实例:FileResourceManagerfrm=newFileResourceManager("c:\cur","c:\cur",true,logger);据我了解ApacheCommonsTransactiontutor

java - Apache 的 Velocity — getTemplate() 。如何传递字符串/对象而不是 .VM 文件

Apache的Velocity—getTemplate()。实际上它允许传递.vm文件名,我可以在这里传递字符串/对象吗?是否有任何方法可用于传递字符串/对象? 最佳答案 这是适合我的示例代码。极速版本:1.7我使用log4j作为记录器。importorg.apache.log4j.Logger;importorg.apache.velocity.Template;importorg.apache.velocity.VelocityContext;importorg.apache.velocity.app.Velocity;impo

java - 将 Apache POI 工作簿作为附件添加到 Javamail 的 MimeMessage 中,而无需在文件系统中写入

我正在尝试弄清楚如何将WorkBook(来自ApachePOI库)“直接”传递给MimeMessage对象(来自Javamail库)附件,而不必直接将其写入文件系统。最简单的方法如下:FileattachmentSource=newFile("tmpsource.xls");WorkBooktmpWorkbook=newHSSFWorkBook();//DostuffwithworkbooktmpWorkBook.write(newFileOutputStream(attachmentSource));//CreatealltheSession,MimeMessageandMimeMu

java - 为什么我得到 java.io.IOException : Stream closed?

我正在尝试下载一个zip文件,但我收到了一个流关闭异常。当我使用swinggui时,它会出现此错误,但如果我使用控制台,则没有问题。为什么我会得到这个异常(exception)?我该如何解决?这是我的代码:URLConnectionconn=url.openConnection();InputStreamin=conn.getInputStream();FileOutputStreamout=newFileOutputStream(destination.getPath());byte[]b=newbyte[1024];intcount;while((count=in.read(b))

java - Apache Ant - 带有 "[java]"标记的程序输出

一个愚蠢的问题,但我找不到任何答案。目前正在学习ApacheAnt,我首先制作了一个非常基本的构建文件和Java项目,该项目将一行字符串打印到控制台。这是我使用命令时输出的内容ant编译jar运行PSC:\Users\zayd\Desktop\Apps\pbox>antcompilejarrunBuildfile:C:\Users\zayd\Desktop\Apps\pbox\build.xmlcompile:[mkdir]Createddir:C:\Users\zayd\Desktop\Apps\pbox\build\classes[javac]C:\Users\zayd\Deskt

java - 使用 Java stream API 像 SQL GROUP BY 一样汇总数据

使用SQL,我可以编写以下代码来汇总数据:SELECTsum(f1),sum(f2),f3,f4FROMTABLEXGROUPBYf3,f4这将返回一个列表,每行有4个值:sum1、sum2、v3、v4例如:这是表中的内容:1,2,a,b1,2,a,b2,2,c,d2,2,c,d3,4,c,d结果将是:2,4,a,b7,8,c,d现在假设我的数据不是数据库表,而是Java对象列表中的变量f1、f2、f3、f4。JavastreamAPI中有没有函数可以根据f3、f4来汇总这个列表? 最佳答案 仅使用JDK的StreamAPI执行此操

java - 在stream中查找对应于post-map minimum的pre-map元素

我经常发现自己在做这样的事情:list.stream().min(newComparator(){@Overridepublicintcompare(Ea,Eb){returnDouble.compare(f(a),f(b));}})其中f是计算密集型函数。这需要对f的计算次数是实际需要的两倍。我更愿意list.stream().mapToDouble(f).min()但是后来不知道怎么得到这个最小值对应的原始元素。一个丑陋的解决方法是classWithF{privatefinalEe;privatefinaldoublefe;WithF(Ee,doublefe){this.e=e;t

java - 如何在不使用 Spring 引导和使用单独的 Apache tomcat 服务器的情况下在 Spring WS 中配置双向 SSL 连接?

我需要以双向SSL连接安全机制向服务器发送soap请求消息,还需要处理来自服务器的Soap响应。我正在使用SpringMVC以及完全使用配置的Springws注释并需要以两种方式SSL连接进行配置,以便将soap请求发送到服务器。如何在我的SpringMVCWeb服务应用程序中使用两种方式的SSL连接,以便通过SSL将我的soap消息发送到服务器?。 最佳答案 我可以指导您完成所有必需的步骤,但仍有不足之处。请查看我的回答,以便我可以为您提供正确的配置链接双向SSL是一种带有客户端证书身份验证的TLS连接。它与签署soap请求不同(

java - Apache Ivy 和本地 Maven 存储库 - 如何处理使用 Maven 3 构建的快照

我们目前有一个项目设置,它使用Ivy进行依赖项管理,使用Ant作为通用构建工具(尽管这可能与此处无关)。此外,我们有一堆使用Maven构建的库,并且项目(我们有多个)依赖于这些库。我们知道这种情况远非理想,我们正在评估改善这种情况的方法,但我们无法像我们希望的那样迅速改变这种情况。因此,我们必须利用我们目前拥有的东西来工作。无论如何,问题来了:它可以与Maven2和Ivy一起使用,但我们最近由于几个原因(一个是更好的冲突解决方案)开始切换到Maven3,而这种组合破坏了我们的构建。首先,我将尝试描述我们的构建如何与Maven2和Ivy一起工作。之后,我将添加切换到Maven3时中断的位

java - Java 8 Streams 中副作用的危险是什么?

我试图理解我在Streams文档中发现的警告。我已经养成了使用forEach()作为通用迭代器的习惯。这导致我编写了这种类型的代码:publicclassFooCache{privatestaticMapsortOrderCache=newConcurrentHashMap();privatestaticMapcodeNameCache=newConcurrentHashMap();publicstaticvoidpopulateCache(){ListmyThings=getThings();myThings.forEach(thing->{sortOrderCache.put(th