Вопросы по теме 'akka-http'

Является ли akka-http полностью совместимым с DSL-распределением?
akka-http полностью совместим с spray-routing DSL ? (мой сервис полностью реализован в spray-routing , пытаясь понять, насколько бесшовной является миграция (надеюсь, просто изменение зависимости) Производство готово? Может ли он работать...
289 просмотров
schedule 04.07.2023

Клиенту отправлен неправильный отказ
У меня есть маршруты без проверки подлинности и маршруты с проверкой подлинности в моем Akka/Spray DSL. Ниже приведен упрощенный вариант кода val nakedRoutes = pathPrefix("user") { post { entity(as[UserNew]) { user =>...
113 просмотров
schedule 21.11.2022

Параметры запроса для запросов GET с использованием Akka HTTP (ранее известного как Spray)
Одной из особенностей Akka HTTP (ранее известного как Spray) является его способность автоматически сортировать и демаршалировать данные туда и обратно из json в классы case и т. д. Мне удалось заставить это хорошо работать. На данный момент я...
11628 просмотров
schedule 07.04.2022

Акка Потоки и HTTP. Внешний HTTP-запрос в версии 1.0-RC4
Этот код больше не работает при попытке создать http-клиент/поток: lazy val myConnectionFlow = Http().outgoingConnection("localhost", port).flow def myRequest(request: HttpRequest): Future[HttpResponse] =...
62 просмотров
schedule 10.10.2023

используя handleWebsocketMessage в akka-http
Используя akka-http, как я могу создать Flow[Message, Message, _] для передачи to handleWebsocketMessage , который только прослушивает входящие данные, но ничего не записывает? Можно ли вообще использовать раковину? Потому что Раковина звучит как...
487 просмотров
schedule 12.05.2024

HttpEntity с ошибками `application/xml` при переходе с 1.0 на 2.0
У меня не так много опыта работы с akka, но что-то изменилось в том, как HttpEntity обрабатывает строки? В настоящее время я использую akka-http 1.0, но хотел бы перейти на версию 2.0 и начать использовать функциональность Source.queue . Я...
288 просмотров
schedule 07.11.2023

Включение поддержки безопасных веб-сокетов в Akka HTTP
Как включить поддержку безопасного веб-сокета в Akka HTTP версии 2.0.*? Мне не удалось найти какой-либо конкретной директивы для этого или каких-либо подсказок в официальной документации, пожалуйста, помогите. Мой текущий подход заключается в...
1154 просмотров
schedule 17.03.2023

откуда неявно предоставляется, когда я вызываю akka.http.scaladsl.Http.apply ()?
Я использую Akka HTTP для поддержки REST, и мне нужно использовать Actors в другой части сервера, который я разрабатываю. Насколько я понимаю, обычно нужно использовать только ОДИН экземпляр ActorSystem во всем приложении. Из определения...
62 просмотров
schedule 19.01.2024

Автоматический выключатель для службы Scala и akka-http rest
В настоящее время я реализую автоматический выключатель с Akka-HTTP следующим образом: def sendMail(entity: MyEntity): ToResponseMarshallable = { Thread.sleep(5 * 1000) validateEntity(entity).map[ToResponseMarshallable] {...
1513 просмотров

Какой веб-сервер использует akka akka-http и как я могу получить его версию?
Я использую akka и akka-http 2.4.2 и пытаюсь понять их внутренние компоненты. Что используют akka и akka-http для запуска веб-службы отдыха? Он использует встроенный веб-сервис? (например, Jetty?) Как получить его версию? Код, который я...
808 просмотров
schedule 15.05.2022

Akka Flow зависает при отправке http-запросов через пул соединений
Я использую Akka 2.4.4 и пытаюсь перейти с Apache HttpAsyncClient (безуспешно). Ниже приведена упрощенная версия кода, которую я использую в своем проекте. Проблема в том, что он зависает, если я отправляю в поток более 1-3 запросов. Пока что...
1358 просмотров
schedule 20.03.2024

Неблокирующая операция в потоке Flink или Sparks vs Akka
Я изучаю и оцениваю Sparks и Flink, прежде чем выбрать одну из них для проекта, который у меня есть. В своей оценке я придумал следующие простые задачи, которые я могу понять, как реализовать это в обоих фреймворках. Скажем так 1- / У меня...
1337 просмотров

Как справиться с ошибкой ответа HTTP-клиента Akka
Запросы HTTP-клиента Akka возвращают Future[HttpResponse] — как справиться с ошибкой Future? Просто запротоколировать ошибку или повторно передать ее супервайзеру? Есть ли документация о типе ошибок, которые могут быть возвращены клиентом (и,...
2654 просмотров
schedule 29.06.2022

ошибка компиляции akka http
Я новичок в фреймворке akka и теперь пытаюсь настроить простой веб-сервис с помощью этого фреймворка. напишите простое приложение akka-http: import akka.actor.ActorSystem import akka.http.scaladsl.Http import...
2512 просмотров
schedule 26.07.2023

Директива использует как заголовок, так и тело запроса в akka-http
Для проверки подписи в некоторых вызовах API мне нужно вычислить подпись из тела запроса и сравнить ее с подписью в заголовке. Поскольку я не смог найти какие-либо предопределенные директивы, которые могли бы выполнять эту работу, я придумал...
468 просмотров
schedule 11.04.2024

Как сопоставить все пути в Akka HTTP
Большинство примеров Akka HTTP показывают, что очень легко определить Routes с помощью path . У меня есть следующее (слегка упрощенное) из вводный пример , val route = path("hello") { complete( HttpEntity(...
3064 просмотров
schedule 10.02.2023

Как загрузить файл в акка http 10 размер файла › 100 КБ
У меня есть http-сервер akkka (версия 10.0) для запроса загрузки файла с почтальона на другую службу (он подключает amazon s3) используйте файл изображения (размер изображения = 275 КБ), и у него есть исключение...
943 просмотров
schedule 10.06.2024

В akka-http, как получить список [HttpRequest] из маршрута?
В akka-http со следующего case HttpRequest(GET, Uri.Path("/ping"), _, _, _) => HttpResponse(entity = "PONG!") также можно записать как val route: Route = path("ping") { complete("PONG!") } Можно ли...
115 просмотров
schedule 25.11.2022

Akka-Http: что может быть доступно между клиентом и сервером?
Чтобы запустить сервер с Akka-Http, примерно так: implicit val system = ActorSystem() implicit val materializer = ActorMaterializer() Http().bindAndHandle(routes, webHost, webPort) И использовать клиент уровня запроса: implicit val system...
133 просмотров
schedule 17.12.2023

akka http client system.shutdown() создает ошибку исходящего потока запросов (akka.stream.AbruptTerminationException) при использовании https
Привет, следующий код работает, как и ожидалось. implicit val system = ActorSystem() implicit val materializer = ActorMaterializer() import system.dispatcher val request = HttpRequest(uri = "http://www.google.com")...
2030 просмотров
schedule 19.10.2022