草庐IT

Akka-Http

全部标签

java - 什么时候使用 Akka 微内核?

我正在阅读Akka文档,并对一些真正没有很好解释的东西感到好奇。他们mention一个叫做AkkaMicrokernel的东西,并暗示它是某种应用Bootstrap/启动器,但他们并没有真正解释它是什么以及何时使用它。p>稍后在文档中有一个entirepage致力于微内核,但它同样神秘而模糊,声明:TheAkkaMicrokernelisincludedintheAkkadownloadfoundatdownloads.然后:TorunanapplicationwiththemicrokernelyouneedtocreateaBootableclassthathandlesthest

java - 什么是 http-remoting 协议(protocol)

我已经在Wildfly上设置了一个EJB并编写了一个客户端来访问它。使用“http-remoting”协议(protocol),它工作正常。不幸的是,我不确定http-remoting的功能细节。我想这是RMI协议(protocol)的http隧道。但是我找不到关于这个主题的任何合适的资源。所以我真的不确定。有人知道http-remoting作为协议(protocol)是如何工作的吗? 最佳答案 这是在JBossRemoting中实现的协议(protocol).有一个GitHubrepo也是为了它。另外,根据您使用的WildFly版

java - 无法使用 kerberos 票证缓存对 apache http 客户端 4.5 进行身份验证

我正在对kerberos身份验证的REST服务执行https请求。如果我使用key表,一切都很好。但是,我有一个要求,我应该使用在使用密码登录工作站时创建的kerberos票证缓存文件。我会将域替换为MY_DOMAINE.COM因此,klist显示:Ticketcache:FILE:/tmp/krb5cc_210007Defaultprincipal:dragomira@MY_DOMAINE.COMValidstartingExpiresServiceprincipal05/15/1807:21:5105/15/1817:21:51krbtgt/MY_DOMAINE.COM@MY_DO

java - 在 HTTP POST header 中发送非 ASCII 文本

我正在将文件作为八位字节流发送到服务器,我需要在header中指定文件名:Stringfilename="«úü¡»¿.doc"URLurl=newURL("http://www.myurl.com");HttpURLConnectionconn=(HttpURLConnection)url.openConnection();conn.setRequestMethod("POST");conn.addRequestProperty("Accept","application/json;charset=UTF-8");conn.addRequestProperty("Content-Ty

java - 使用 Netty 和 NIO 的高并发 HTTP

我正在处理exampleNettyHTTPClientcode为了在并发的线程环境中发出http请求。但是,我的系统在相当低的吞吐量下完全崩溃(有一系列异常)。几乎是伪代码:ClientBootstrapbootstrap=newClientBootstrap(newNioClientSocketChannelFactory())bootstrap.setPipelineFactory(newHttpClientPipelineFactory());ChannelFuturefuture=bootstrap.connect(newInetSocketAddress(host,port)

java - 使用 Netty 的 HTTP 请求

我刚开始使用netty,我对netty上的文档感到非常失望他们的网站。我正在尝试使用Netty连接到一个URL。我从他们的网站上获取了时间客户端示例,并根据我的要求进行了更改。代码:publicclassNettyClient{publicstaticvoidmain(String[]args)throwsException{Stringhost="myUrl.com/v1/parma?param1=value";intport=443;EventLoopGroupworkerGroup=newNioEventLoopGroup();try{Bootstrapb=newBootstra

java - Actor 名字不是唯一的 - AKKA

我在JAVA中使用Akka2.10。我有一个为我获取Actor引用的方法-或者创建一个(如果之前没有)-但有时当我尝试创建一个时,我收到以下异常:akka.actor.InvalidActorNameException:actorname[]isnotunique!atakka.actor.dungeon.ChildrenContainer$NormalChildrenContainer.reserve(ChildrenContainer.scala:130)atakka.actor.dungeon.Children$class.reserveChild(Children.scala:

java - AsyncHttpClient 是否知道为所有 HTTP 请求分配多少线程

我正在评估AsyncHttpClient对于大负载(~1MHTTP请求)。对于每个请求,我想使用AsyncCompletionHandler调用回调,它只会将结果插入阻塞队列我的问题是:如果我在紧密循环中发送异步请求,AsyncHttpClient将使用多少个线程?(我知道你可以设置最大值,但显然你冒着丢失请求的风险,我已经看到了here)我目前在这些版本中使用Netty实现:async-http-clientv1.9.33nettyv3.10.5.Final如果以后的版本有什么优化的话,我不介意使用其他版本编辑:我读到Netty使用reactorpattern要对HTTP响应使用re

java - 在 Java 中从哪里获取 'http' 字符串文字?

创建一个URL,例如通过URLurl=newURL("http","localhost","test.txt");我必须使用常量字符串“http”。也在许多其他代码行中。我找不到任何包含此字符串的常量(或者更好的是所有常见协议(protocol)的常量集合)。是否有任何现有的协议(protocol)常量? 最佳答案 简答:在撰写本文时,JavaSEJDK中没有最终字符串文字http常量。更长的答案我意识到这是一个老问题,但我认为它不一定得到充分回答。我相信莱昂的回答是部分正确的。在许多情况下,拥有一个名为HTTP且字符串值为“htt

java - 在 AKKA 中,调用 supervisor 的 shutdown 会停止它所监督的所有 actor 吗?

假设我有一位主管已关联2位Actor。当我的应用程序关闭时,我想优雅地关闭那些Actor。调用supervisor.shutdown()会停止所有actors还是我仍然需要手动停止我的actors?谢谢 最佳答案 Stoppingasupervisor(调用Supervisor.stop())停止所有链接的(受监督的)actor:finalclassSupervisorActor{...overridedefpostStop():Unit=shutdownLinkedActors然而,当你想优雅地关闭系统中的所有参与者时,还有另一个