Akka文件上传-在接收到请求结束之前发送2xx 'early‘响应
Akka文件上传是一种基于Akka框架的文件上传方式。Akka是一种用于构建高并发、分布式和可扩展应用程序的开源工具包。它提供了一种异步、非阻塞的编程模型，可以轻松处理大量并发请求。
在Akka文件上传中，当接收到文件上传请求后，服务器会立即发送一个2xx 'early'响应。这意味着服务器会在文件完全上传之前就开始发送响应，而不是等待整个文件上传完成后再发送响应。这种方式可以提高文件上传的效率和响应速度。
Akka文件上传的优势包括：
- 高并发处理能力：Akka框架的异步、非阻塞特性使得服务器可以同时处理多个文件上传请求，提高了系统的并发处理能力。
- 提高响应速度：通过发送'early'响应，可以在文件上传过程中就开始向客户端发送响应，减少了等待时间，提高了用户体验。
- 可扩展性：Akka框架支持分布式部署，可以根据需求增加更多的服务器节点，实现系统的水平扩展。
Akka文件上传适用于以下场景：
- 大文件上传：由于Akka框架的高并发处理能力，适合处理大文件的上传请求。
- 对响应速度要求较高的场景：通过提前发送响应，可以减少用户等待时间，适用于对响应速度有较高要求的场景，如实时数据上传等。
腾讯云提供了一系列与文件上传相关的产品和服务，其中包括：
- 对象存储（COS）：腾讯云对象存储（COS）是一种高可用、高可靠、弹性伸缩的云端存储服务，适用于存储和管理大规模非结构化数据，可以作为Akka文件上传的存储后端。了解更多信息，请访问：腾讯云对象存储（COS）
- 云服务器（CVM）：腾讯云云服务器（CVM）是一种可弹性伸缩的云计算服务，提供了高性能、可靠稳定的虚拟服务器。可以将Akka框架部署在云服务器上，实现文件上传功能。了解更多信息，请访问：腾讯云云服务器（CVM）
- 负载均衡（CLB）：腾讯云负载均衡（CLB）是一种将流量分发到多个云服务器的负载均衡服务，可以提高系统的并发处理能力和可用性。可以将Akka框架部署在多个云服务器上，并通过负载均衡服务实现文件上传的并发处理。了解更多信息，请访问：腾讯云负载均衡（CLB）
以上是关于Akka文件上传的概念、分类、优势、应用场景以及腾讯云相关产品的介绍。希望对您有所帮助！
相关·内容
1回答
我收到了多个2**响应的一个电话。问题是，一旦呼叫连接，服务器接收到"ACK“数据包，呼叫成功启动，服务器再次将"OK”响应数据包发送回被叫者，并为其再次接收"ACK“数据包。在调用自动终止之前，会多次发生这种情况。有人能向我解释为什么会发生这种情况，即使在调用成功地连接之后，我的服务器也会发送"OK“响应吗?这个问题的可能解决方案是什么？提前感谢您的帮助。
浏览 1提问于2013-09-05得票数 0
回答已采纳
在HTTP/1.1标准中，是否明确允许或禁止服务器在接收所有请求的数据之前发送响应？
例如，当使用POST请求上载大量数据时，我可以想象服务器在收到请求的头部后，但在接收到整个主体之前，返回"202接受“响应。这是否合法？这是野外存在的东西吗？
与密切相关，但那里的响应似乎集中在处理“错误”(4xx，5xx可能)，而不是“成功”(2xx)。
浏览 4提问于2022-06-27得票数 5
回答已采纳
我有一个关于SIP的问题，当读取RFC 3311更新请求时，它没有提到它在SIP中的无效行为。下面是调用流程：
UAC发送邀请请求UAS将1xx邀请发送给UACUAC发送更新请求UAS发送2xx INV</code>UAS发送2xx更新<代码>H 210<//代码><代码>G 211</code>
我假设了一些原因，使200 for的邀请第一，然后2xx响应更新请求后。这种情况是SIP调用后续中的通行证情况吗？
谢谢你们。
浏览 0提问于2020-01-20得票数 0
回答已采纳
我正在设计API，其中所有以下三种情况都是可能的
数组中的所有输入都是正确的，因此这个API将返回200个状态代码。
示例输出: 200状态代码
{“状态”：“成功”，“值”：“一些响应”}，{“状态”：“成功”，“值”：“一些响应”}
数组中的几个输入是正确的，因此这个API将返回207多状态代码。
示例输出: 207多状态代码
{“状态”：“成功”，“值”：“一些响应”}，{“状态”：“失败”，“值”：“失败的原因”}，{“状态”：“成功”，“值”：“一些响应”} }
数组中的所有输入都是错误的。在这种情况下，我是否需要发送400坏请求(或) 207状态代码？
因为如果我发送400坏请
浏览 3提问于2022-07-04得票数 0
最初我在寻找一个答案，为什么对2xx响应的ACK会形成一个单独的SIP事务，而对非2xx响应的ACK则不会。Google给了我这个：
“当UAC接收到200OK时，客户端事务在TL处被销毁。
这样做是因为TL不知道上面的核心。上述核心可以是代理或UAC核心。
在代理的情况下，转发200OK，而在UAC的情况下，生成ACK。现在这个ACK必须在TL创建一个新的事务(由INVITE创建的事务已经被销毁)来传输它，因此200OK的ACK在INVITE事务之外。
对于其他非2xx最终响应，TL处的客户端事务不会被销毁，并且由TL生成ACK。
因此，在这种情况下，ACK在事务中。“
现在我的下一个问题
浏览 10提问于2014-03-17得票数 1
我有以下情况：
2 UAC正在尝试通过远程SIP服务器(openSER/Kamailio 3.1.3) =客户端基础设施进行对话。UAC软件是使用星号在本地测试基础设施上开发的，在那里可以建立一个正常的调用。
问题是在客户端基础设施上进行测试，没有音频。
我不知道完整的客户端基础设施，但是从来自服务器的日志/响应(路由头字段)可以得出结论，存在一个代理授权服务器、一个CiscoSystem SIP以及PSTN。尤其是我们支持NAT，客户也支持NAT。AFAIK没有使用电击器。
呼叫流程的主要区别在于，在测试基础结构中，我们总是接收到180条消息(振铃)，而在客户端基础结构中，我们接收到183条
浏览 0提问于2011-12-02得票数 0
回答已采纳
这个问题涉及SIP (会话初始化协议)中的ACK请求。引用RFC-3261 - 18.1.1发送请求
If an element sends a request over TCP because of these message size
constraints, and that request would have otherwise been sent over
UDP, if the attempt to establish the connection generates either an
ICMP Protocol Not Supported, or results in a T
浏览 2提问于2016-08-29得票数 0
1回答
在我们收到web钩子之后，我们应该在后端执行一些附加逻辑之前返回2xx响应。
您的端点必须在任何可能导致超时的复杂逻辑之前快速返回成功的状态代码(2xx)。例如，您必须在更新您的会计系统中所支付的客户发票之前返回一个200响应。
他们建议首先返回成功的2xx响应，然后在后端执行其他操作。他们认为这是最佳实践，因此不会出现请求超时。
我看不出这种最佳实践是怎样的，因为很明显，如果我们的系统更新数据库失败了，并且我们已经返回了成功的响应，这是很明显的。这意味着Stripe以后不会尝试重新发送web钩子，而且我们将失去这个信息，因为我们的系统没有保存它。
对于这类问题，有什么解决办法吗？
浏览 2提问于2022-02-20得票数 0
回答已采纳
如果网站用户提交HTML表单时：(1) post方法；(2)多部分/表单-数据封装类型；(3)大型附加文件，服务器是否可以上传已发布的文件，并在文件上传完成之前发送服务器生成的HTTP响应，而不使用AJAX？
那是相当稠密的。所以，我写了一个例子来说明我的意思。假设有一个带有标题字段的图像上传表单。
<form action="upload-with-caption/" method="post" enctype="multipart/form-data">
<input type="hidden"
浏览 7提问于2011-01-25得票数 2
回答已采纳
所以我尝试用javascript发出一个跨域的AJAX请求。
我的OPTIONS请求正在执行，没有任何问题，并且我将返回Access-Control-Allow-Origin:*作为响应头。然而，当我尝试发出后续的POST请求时，我得到了以下错误：
No 'Access-Control-Allow-Origin' header is present on the requested resource. Origin 'http://phoenix-client.local' is therefore not allowed access.
我已经多次验证我的OP
浏览 1提问于2013-11-28得票数 3
1回答
我在服务器上收到了两个类似的事件。我感觉到状态201的响应，但它不能解决问题(在那之后，我收到了4个类似的事件)。事件之间唯一的区别是头中的两个字段(X传递-Id和X-转发-For)。事件完全是在同一时刻(差不到一秒钟)接收的。默认情况下启动两个事件？
谢谢你的帮助。
浏览 9提问于2019-09-18得票数 0
回答已采纳
在我的Azure管理中，我为整个API定义了CORS策略。选项命令的所有功能都很好，每个成功的请求以及500个响应都会返回允许的原点。
由于一些奇怪的原因，当API返回401或403时，允许的原点标头不会被发送回响应。我从前端团队了解到，这会带来麻烦，因为浏览器和/或角不能处理XHR响应，因为它不知道是否允许.
有人知道为什么API管理会这样做吗?我怎样才能防止这种情况呢？
非常感谢！
彼得
浏览 6提问于2016-02-26得票数 3
1回答
我是Google Cloud Functions服务的新手。我阅读了文档，但仍然有一些小的基本问题。我正在尝试创建一个函数，它获取POST请求(使用webhooks)，并发出POST请求(在解析收到的数据之后)。 使用webhooks，我的网站以JSON格式发送数据： {
"post": {
"id": 587,
"topic_title": "Test",
"admin": false,
"category": "8-category"
}
浏览 166提问于2019-10-19得票数 0
2回答
在阿克卡发期货还行吗？
、、、
我正在实现一种小型语言，以将任务发送到执行和控制执行流。在向我的系统发送任务之后，用户将得到一个未来(在这个未来，它可以调用阻塞get()或flatMap() )。我的问题是:在Akka消息中发送期货可以吗？
例如:参与者A向参与者B发送消息响应，并且响应包含其字段中的未来。然后，在某一时刻，A将实现创造未来的承诺。接收到响应后，B可以随时调用flatMap()或get()。
我之所以问这个问题，是因为Akka消息应该是不可变的，即使演员在不同的JVM上也是如此。如果演员A和B在不同的JVM上，我看不出上面的例子是如何工作的。而且，即使参与者在同一个JVM上，我的示例也有什么问题吗？
在接受的
浏览 6提问于2015-12-16得票数 2
回答已采纳
我们有这样一种情况: UAC向服务器发送INVITE，服务器以3xx-6xx响应。如果UAC不对此响应发送ACK，则不会重新传输。
根据RFC3261 ()，如果未接收到确认，则底层堆栈应重新传输响应。
我们的设置是一个带有MSS-tomcat (Mobicents8，tomcat8)的Linux工作站。
以前有没有人遇到过这种情况？
谢谢!
浏览 6提问于2016-05-17得票数 1
1回答
在“理解SIP”一书中，他们说只发送对INVITE ACK的响应，但是在这个呼叫流中也有ACK表示BYE。
有人能给我解释一下这个现象吗？
📷
]
📷
]
浏览 0提问于2016-12-08得票数 0
在使用Akka HttpRequest并将请求传递给参与者时，我无法识别响应。参与者将处理将接收到的每条消息，但它不知道用于获取此响应的请求。是否有任何方法来识别与响应匹配的每个请求？
注意:我没有服务器再次重新发送请求体的任何部分。
提前感谢
MySelf.scala
import akka.actor.{ Actor, ActorLogging }
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.stream.{ ActorMaterializer, ActorMaterializer
浏览 1提问于2018-05-27得票数 1
回答已采纳
1回答
我需要将json数据发送到服务器。我可以将json对象发送到服务器。但我想向服务器发送多个json对象，如下所示。
Json1：
{
"Comments" : "test”,
"user_id" : “test”,
"EdDate" : "08\/26\/2015 03:16:58 PM",
"StDate" : "08\/26\/2015 03:16:20 PM",
"latitude" : "",
"longitude" : &
浏览 0提问于2015-08-28得票数 0
我正在使用以下代码上传一个文件：
WebClient myWebClient = new WebClient();
byte[] responseArray = myWebClient.UploadFile(string.Format("http://{0}/WebApplication/Default.aspx", this.WebServerName), "POST", filePath);
我收到Page_Load()中的文件：
foreach (string f in Request.Files.AllKeys)
{
HttpPostedFile
浏览 2提问于2014-10-16得票数 0
我正在设计一个API，其中客户端PUT将文件发送到服务器，但是服务器可能已经有了该文件的副本，而不需要重新上传。
我已经计划使用Expect: 100-continue，以便服务器可以在客户端执行整个、低效的上传之前通知客户端。
我的问题是，在服务器不需要上传的情况下，返回的最佳状态代码是什么而不是100 Continue ？
通常，客户端可以发送一个If-None-Match头，如果已经匹配，服务器可以使用412 Precondition Failed进行响应。
但是，在我的例子中，去复制几乎是一个实现细节，我不希望客户端关心了解去dup‘’ing策略(例如，匹配的值是什么)。
302 Fo
浏览 6提问于2013-07-23得票数 1
回答已采纳
在这个角度应用程序中，用户填充表上的输入，每次更改后，应用程序发出一个http请求来保存更改，在每个请求中，它发送一个指示并发版本的数字。如果进程成功，服务器将发送带有新版本的响应。
当用户更改过快时，就会出现问题，在收到之前的响应之前将发送post请求，因此并发号将不匹配。
我对角度还不熟悉，那么，有什么最好的方法来创建一个服务，它可以一个接一个地发送请求(每次一个)，这样我就可以从下一个请求中使用的响应中保存并发版本了？
谢谢!
浏览 7提问于2022-04-18得票数 0
回答已采纳
1回答
我目前正在将Akka经典应用程序移植到Akka类型机。我有以下几个组成部分：
HttpService -不是演员
JobDispatcher -演员
JobWorker - JobDispatcher的儿童演员
JobDispatcher是一个单身汉演员，负责安排工作。每个JobWorker负责一个“任务”，并知道作业的状态。
HTTP服务将向JobDispatcher发出一个名为GetJobStatuses的请求。然后，JobDispatcher将询问每个JobWorkers的状态，将结果聚合到一个列表中，并回复HttpService。
我在Akka中这样做的方式是让Jo
浏览 4提问于2022-04-04得票数 0
回答已采纳
我有一个web应用程序，接受匿名和身份验证的请求。如果我匿名地将表单数据(通过文件上传)发布到web应用程序，然后收到401质询，那么我是否会在第二次请求时重新发送所有表单数据？
我并不是在尝试避免401响应，而是在接收到401响应时，尝试避免两次发送请求负载。
浏览 0提问于2015-09-05得票数 1
1回答
我正在尝试在文件上传和用户点击提交后的用户文本方面与params一起发出POST请求。然而，由于某些原因，我一直通过dd(); (来自我收到的API端点)收到失败的响应，即使我收到了flash定义的文件上传成功消息。我在控制器中做错了什么？
<?php
namespace App\Http\Controllers;
use Illuminate\Http\Request;
use Zttp\Zttp;
class FileUploadController extends Controller {
public function index(){
return
浏览 0提问于2020-04-23得票数 0
1回答
我对阿克卡世界非常陌生，我不得不把一个项目从喷雾迁移到阿克卡-http。
在喷雾中，一条路线是Route = RequestContext ⇒ Unit型。
但在akka中，它是Route = RequestContext ⇒ Future[RouteResult]类型的.
因此，在喷雾中，我们经常通过一个演员链(主控制器之外)处理和完成我们的请求，只使用点火和遗忘，这样我们就不必“询问”了，而且性能也很好。现在，每当我们将请求传递给其他演员时，我们都必须使用“询问”(如果我错了，请纠正我)。
我已经搜索了很多，我发现了一些选项，我不确定它们是否完全满足了我(需要在另一个Actor中完成一个请
浏览 1提问于2016-12-18得票数 2
2回答
我每分钟有数以千计的小文件(大约1KB)要上传到S3。如果我上传循环中的每个文件“发送我的超文本传输协议请求-等待S3的超文本传输协议响应-发送下一个请求-等待下一个响应..."，这需要花费大量的时间，因为我必须等待S3和我的服务器之间2倍的延迟。当然，我已经使用了HTTP Keep-Alive报头。
因此，我尝试发送多个HTTP请求，而不等待相应的请求(HTTP管道)。我尝试一批发送20个请求，并等待20个响应。我预计这可能会节省很多时间，因为我仍然可以发送请求时，前一个响应的方式。
然而，这并不能让世界变得更好。
我在大约200ms内发送了20个请求，然后尝试接收响应。我希望在收到
浏览 5提问于2011-10-13得票数 6
1回答
我们有一套现有的应用程序，使用城市飞艇进行通知。我们希望自动化服务器组件的测试。
我们尽可能使用自动化测试。具体来说，我希望能够验证，当我对特定的标记进行/api/post调用时，城市飞艇会为该标记生成一个通知。
在理想情况下，我会按照“收到tag=XXX通知或超时时返回”的方式进行web REST调用，并验证响应是否符合我的预期。
这样的电话存在吗?或者，除了包括手机硬件之外，还有人能提出其他方法吗？
查尔斯
浏览 2提问于2015-02-10得票数 0
3回答
他们是否是控制HTTP请求发送的一种方式？我的场景就像
发送请求1
收到答复1
发送请求2
收到答复2
注意:请求是在收到响应时逐个发送的。将并行请求塞满服务器(通过设置线程的no > 1)将产生错误的响应。所以我希望在收到响应1之后触发请求2。
最坏的解决办法是：
发送请求1
睡眠2秒
收到答复1
发送请求2
睡眠2秒
收到答复2
更准确地说，要求是“逐个读取存储在csv文件中的值并发送http post请求”。我想要实现的顺序是Send_1、Receive_1、Send_2、Receive_2.......Send_n、Rece
浏览 1提问于2020-07-31得票数 0
回答已采纳
1回答
我要自动接所有的小口电话。当我以尝试或振铃响应时，事务处于正在进行的状态，但当我发送OK响应时，事务处于终止状态。这是我的密码：
public void processRequest(RequestEvent requestReceivedEvent)
{
Address contactAddress = myAddressFactory.createAddress("sip:" + myIP + ":" + myPort);
myContactHeader = myHeaderFactory.createContactHeader(contac
浏览 3提问于2015-02-10得票数 1
回答已采纳
我正试图使用带有Alpakka S3连接器的Akka将一个大文件(目前为90 MB )上载到S3。它对小文件(25 MB)很好，但是当我试图上传大文件(90 MB)时，我得到了以下错误：
akka.http.scaladsl.model.ParsingException: Unexpected end of multipart entity
at akka.http.scaladsl.unmarshalling.MultipartUnmarshallers$$anonfun$1.applyOrElse(MultipartUnmarshallers.scala:108)
at akka.http
浏览 5提问于2020-06-19得票数 1
回答已采纳
2回答
然后，我使用Stripe Checkout，在“测试”模式中，我故意返回400 http响应或超时响应200 http响应到Stripe在<code>E 110</code>“test”模式<code>E 211</>中，而我等待从<code>E 112</code>Stripe</code>E 213</code>对<code>E 114</code>9小时</code>E 215</code>但是<code>E 116</code
浏览 19提问于2022-07-28得票数 0
回答已采纳
如果我从浏览器发送一个GET xhr，并且响应带有正确的标头，那么资源将存储在缓存中。但我在想，如果我把一个PUT发送到同一个url，会发生什么事。浏览器是否足够聪明，知道此方法将更改资源，从而将条目从缓存中排除？
浏览 3提问于2022-01-03得票数 0
1回答
我有一个API运行在谷歌应用引擎，通过邮件接收图像，通过应用程序引擎传入邮件功能。
这意味着我不能在JSP中使用Blob，因为Google将描述为一个典型的用例。相反，我使用将图像上传到Blob。
这是可行的，因为图片被上传到Blob，但是Blob使用415 Unsupported Media Type. 响应。我还试图上传其他文件类型，并使用，但Blob仍然使用415 Unsupported Media Type响应，即使是成功的请求。
改造
MailReceiver
String uploadUrl = BlobstoreServiceFactory.getBlobstoreService
浏览 3提问于2016-02-16得票数 1
回答已采纳
1回答
我知道有很多不同的comminucation protocals，比如：http, tcp, ssh, socks5, SMTP, POP,等等。
我还知道，要实现通信，我们需要将localhost:localport连接到remotehost:remoteport。例如，如果我们搜索某个内容，我们会将一个随机的本地port连接到www.google.com: 80。如果我们ssh一个远程主机，我们将连接一个随机的本地port到remotehost: 22。
我的问题是:通信协议是半双工还是全双工？
我想答案是Half-duplex。因为我认为在http连接中，首先我们将请求从localhos
浏览 2提问于2021-01-03得票数 1
回答已采纳
我正在尝试连接Akka HTTP和Actors。我有一个简单的演员，他收到“你好”并把“你好世界”发回。
class TestActor extends Actor{
def receive={
case "hello"=>{
sender!"Hello World"
}
}
}
我已界定以下路线：
object Main extends App{
val route1: Route =
get {
path("hello") {
complete {
浏览 6提问于2017-01-10得票数 0
回答已采纳
1回答
我编写了一个简单的参与者，它下载一个网页并将该页面的正文发送给它的发送者。我使用Akka HTTP来构建HTTP请求和处理HTTP响应。下面是我的代码：
class Downloader(uri: String) extends Actor {
import akka.pattern.pipe
import context.dispatcher
final implicit val materializer: ActorMaterializer = ActorMaterializer(ActorMaterializerSettings(context.system))
v
浏览 6提问于2017-01-14得票数 0
回答已采纳
1回答
在akka层次结构下面是父子结构，其中父节点向子节点发送一条消息，并且子节点用值1进行响应。但是，由于“接收到的是1”消息没有打印到控制台，因此父节点似乎没有接收到该值。
我的层次结构设置正确吗？：
import akka.actor.Actor
import akka.actor.ActorSystem
import akka.actor.Props
class ChildActor extends Actor {
def receive = {
case receivedValue: Int => {
println(receivedValue);
浏览 3提问于2016-06-11得票数 1
回答已采纳
我一直在试验服务工作者工具包。
复制建议工作框-反向同步QueuePlugin将捕获失败的请求，并在稍后重放它们。因此，通过深入挖掘，我发现了如何在POST方法调用上实现这个功能。
但是重放请求似乎有点失败。使用Chrome工具使应用程序脱机，确实会将请求放在IndexedDB中的队列中。好像什么都没发生，我想调试一下。我注意到，在中，它使用一个BroadcastChannel来触发重放。所以我实现了。然后，在active选项卡中的控制台中，我在dev tools中取消了脱机检查，并发送了一个postMessage。现在，请求愉快地启动，队列中的每个项都存储了响应。
然后，我离开机器运行，进入
浏览 4提问于2017-06-06得票数 1
回答已采纳
因此，在尝试测试如何使用尽可能少的数据创建产品时，我使用Shopware 6 API获得状态204 (无内容)响应和空响应。
当我再次按下“发送”键时，会收到以下消息的状态400错误：
{
"errors": [{
"status": "400",
"code": "CONTENT__DUPLICATE_PRODUCT_NUMBER",
"title": "Bad Request",
"detail
浏览 0提问于2021-10-06得票数 0
回答已采纳
有一个操作，我发送了一些值，如果一切正常，我返回200个代码作为响应。
现在，我想用同样的方法添加一个新的操作:使用APNS (Apple Push Notificacion Service)和GCM (Google Cloud Messaging)发送此修改的通知。
当我必须发送不超过3-5个通知时，它工作得很好，问题是APNS，因为我必须一个接一个地发送这些消息，这需要很长时间，所以我的应用程序收到超时异常(所有通知都已发送，但用户收到错误连接...)
我可以发送200代码响应，然后继续发送此通知吗？(就像这样……)
function my_update_method_post(){
浏览 3提问于2012-12-03得票数 5
回答已采纳
最近，在Akka演员中创建的scala.concurrent.Future对象正在经历一些超时，我想知道如何处理这些超时事件。他们真的迷路了吗？它们是否被重新尝试并保存在记忆中，或者是如何工作的？
为了提供一些上下文，代码如下所示。
List<Future<MyMessage>> futureMessageList = plainMessages.stream()
.map(this::toFuture)
.collect(Collectors.toList());
Futures.sequence(futureMessageList, Exe
浏览 0提问于2020-04-14得票数 0
回答已采纳
正如akka博士所描述的，akka会发送信息-忘了-。
但是在ask模式中，如果typekey不存在，我仍然需要等待响应使用超时。
在向不存在的typekey发送消息时，是否有一种立即失败的方法？
浏览 7提问于2022-11-25得票数 1
回答已采纳
1回答
我让一个线程使用while循环连续读取套接字，如下所示
while ((i = stream.Read(bytes, 0, bytes.Length)) != 0){ ..... }
当它接收到某些东西(例如设备心跳)时，它会在同一套接字上回复" on“。
现在，我想从Thread2发送一个字符串，并希望在Thread2中读取相同的套接字。
但是当我发送一个字符串时，它总是读取来自Thread1的响应。
请给我一个解决方案。
浏览 2提问于2017-12-19得票数 0
1回答
我正在与scala一起使用Play框架。我对scala，akka和play都很陌生。
这是我的演员制度。我不确定我做得对，但我有两个路由器。1名演员A，1名演员B：
val system = ActorSystem("ActionSystem")
val actorARouter = system.actorOf(Props[ActionParser].withRouter(
SmallestMailboxRouter(Runtime.getRuntime.availableProcessors())), name = "actorARouter"
浏览 1提问于2014-04-02得票数 1
回答已采纳
2回答
我的应用程序处理一些HTTP请求，这需要更多的时间来完成。当请求成功入队时，app会返回202 Accepted代码。然而，可能会有另一个请求被发送，而前一个请求还没有完成的情况，在这种情况下，app需要响应错误“另一个操作正在进行中”。我检查了HTTP错误列表，但没有类似描述的错误。我找到的最接近的是423 Locked。对于这种情况，这是正确的错误，还是其他错误会更好？
浏览 22提问于2021-04-27得票数 0
1回答
下面我就SIP核心在SIP通信中的行为提出以下问题。
假设甲方的主叫方B接收邀请并生成“200 OK”。生成“200 OK”后，B到达终止状态(SIP状态机)，因此B中没有状态机。
现在，如果'200 OK‘没有到达A，B应该重新发送'200 OK’，因为它还没有接收到ACK。RFC 3261表示，重新传输“200 OK”是SIP的核心责任。
那么，在B的SIP核中是什么触发来发送这个重传呢？它有计时器吗？还是它依赖于实现？
你好，苏丹苏
浏览 3提问于2016-05-23得票数 0
回答已采纳
2回答
我是Akka (Java )的新手，我正试图了解Akka是否可以用于向JDBC发出非阻塞请求，如果可以，它会是什么样的。我相信大多数JDBC驱动程序打开一个套接字连接并阻塞创建它的线程，直到接收到特定的JDBC响应，因此这里可能没有多少Akka可以做的事情，但是我想知道是否有一种方法(可能通过期货或代理？)Akka可以帮助提高性能，并允许参与者系统继续处理数据，同时正在进行现有的JDBC调用并等待响应。
我发现有点模糊/神秘，但听起来未来可能是这里的关键。然而，这篇文章并没有真正展示任何有意义的(现实世界)代码示例，所以我仍然感到困惑。因此，假设我们有一个存储过程sp_make_expensi
浏览 3提问于2015-07-27得票数 9
回答已采纳
通常我总是能找到解决我的问题的堆叠溢出，你们真是太棒了！但是经过几个小时的搜索，我仍然被这个问题困住了：
我正在为Chrome/FF编写浏览器扩展程序，它通过xhr post方法将文件上传到服务器。如果服务器没有响应，我想给用户一个连接超时的反馈。因此，首先，我使用了10000 ms的超时值，因为我认为超时只在请求/文件被完全发送之后才开始计数。但是，在缓慢的连接上，上传花费了超过10秒的时间，超时事件是在文件被完全发送之前触发的。对于一些较大的文件，上传甚至需要几分钟，因此我不得不将超时值设置为5分钟。然而，对于快速连接来说，这是不切实际的。在快速连接上，我不想等待5分钟才能通知用户，如果服
浏览 0提问于2018-02-24得票数 1
回答已采纳
我正在开始使用Akka；我正在尝试创建一个流，该流读取web服务中的数据，然后将它们保存在S3中。我想知道，如果我使用Sink.fold方法(为了收集持久化元素的信息)来定义Sink，那么发送到接收器的元素是将一个接一个地处理，还是并行处理？
这是一个基本的问题，但我无法在文档中找到明确的答案。
浏览 0提问于2016-04-06得票数 3
回答已采纳
1回答
我有一个具有2个节点的Akka集群，并使用滚动更新策略进行部署。 Actor A向Actor B发送一条消息，并成为一种等待回复的行为。 Actor A实现示例： class ActorA extends AbstractActor {
private ActorRef sender;
static Props props () {
return Props.create(ActorA.class);
}
@Override
public Receive createReceive() {
return Receiv
浏览 6提问于2019-05-18得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
