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

Как сделать запрос HTTPS (не HTTP) с использованием akka-http?
Я использую следующий код для выполнения HTTP-запроса с библиотекой akka-http внутри Akka Actor: implicit val materializer = ActorFlowMaterializer() implicit val system = context.system val request = HttpRequest(HttpMethods.GET,...
2200 просмотров
schedule 06.03.2023

akka-http отправлять непрерывный фрагментированный HTTP-ответ (поток)
У меня есть этот грубый тестовый пример с akka-http клиентом и сервером. Server.scala: import akka.actor.ActorSystem import akka.stream.ActorMaterializer import akka.stream.scaladsl.Sink import akka.http.scaladsl.Http import...
2924 просмотров

Akka HTTP Streaming Десериализация JSON
Можно ли динамически десериализовать внешний ByteString поток неизвестной длины из Akka HTTP в объекты домена? Контекст Я вызываю бесконечно конечную точку HTTP , которая выводит JSON Array , которое продолжает расти: [ {...
1883 просмотров
schedule 03.08.2023

akka-http с несколькими конфигурациями маршрутов
Быстрый фон Я просматриваю несколько примеров изучения HTTP-стека Akka для создания нового проекта REST (полностью не UI). Я использовал и дополнял Пример HTTP-микрослужбы Akka , чтобы работать с множеством вариантов использования и конфигурации...
11522 просмотров
schedule 28.06.2022

Как лучше всего выполнить аутентификацию OAuth2 с помощью akka-http?
Akka HTTP и Spray предоставляют директиву authenticateOAuth2 , но в их документации указано , что Эта директива не реализует полный протокол OAuth2, но вместо этого позволяет реализовать его, извлекая необходимый токен из заголовков HTTP....
3662 просмотров
schedule 12.08.2023

Как добавить новейшие Akka-HTTP и Akka-stream в build.sbt
Я использую активатор Typesafe/Lightbend и создал проект с «минимальным akka-scala-seed». Затем я изменил версию akka с 2.3.11 на 2.4.2 (текущая стабильная версия). Теперь я хочу добавить в свой проект новейшие стабильные Akka-HTTP и Akka-stream....
2380 просмотров

Преобразование маршрута в поток в Akka-Http для Java
Есть ли способ конвертировать javadsl Route в Flow? В Scala у нас неявно доступен handlerFlow, но в Java у нас нет аналогов. Пытался вызвать handlerFlow, но он использует типы scaladsl и несовместим с версией Route для javadsl. Я хочу...
817 просмотров
schedule 04.08.2022

Akka Stream + Akka Http - получить запрос при ошибке
У меня очень хорошо работает следующий поток: source .map(x => HttpRequest(uri = x.rawRequest)) .via(Http().outgoingConnection(host, port)) .to(Sink.actorRef(myActor, IsDone)) .run() и простой субъект для обработки статуса ответа и...
685 просмотров
schedule 08.05.2022

Akka HTTP-клиент + балансировщик нагрузки
Как правильно запустить балансировщик нагрузки с помощью akka http? В настоящее время я использую следующий фрагмент кода: val poolClientFlow = Http().cachedHostConnectionPool[String](host, port) source .map(url => HttpRequest(uri = url)...
623 просмотров
schedule 27.11.2022

Сериализация Akka-HTTP JSON
Как контролировать десериализацию для spray-json? Например, у меня есть класс, определенный как: класс случая A (имя: строка, значение: строка) И я хотел бы десериализовать следующий JSON в список объектов A: { "one": "1", "two": "2"...
906 просмотров
schedule 26.04.2023

Показать список всех маршрутов в Akka HTTP
У меня есть небольшой сервер Akka Http. Есть ли способ перечислить все маршруты/сервисы сервера?
2096 просмотров
schedule 10.07.2023

Akka Http возвращает 404 не найдено
Я пытаюсь добиться очень простой вещи. Скажем, у меня есть REST API. Когда я звоню /api/recipe/1 Я хотел бы, чтобы ресурс был возвращен в виде json. Когда я ударил /api/recipe/2 должен быть возвращен HTTP-ответ 404 Not Found....
4998 просмотров

найдено: akka.http.scaladsl.server.StandardRoute [ошибка] требуется: scala.util.Try
Я новичок в Scala, и в akka я пытаюсь опубликовать конечную точку. Возникает следующая ошибка компиляции. found: akka.http.scaladsl.server.StandardRoute [error] required: scala.util.Try[Option[com.activegrid.entities.AuthSettings]] =>...
921 просмотров
schedule 07.04.2023

Пропускная способность спрея и akka-http значительно снизилась при изменении длины ответа
Я тестирую spray и akka-http, чтобы знать возможную пропускную способность, которую я могу получить. Протестированное приложение простое. Он возвращает статический вывод по статическому пути GET. Но в случае обоих фреймворков я получаю снижение...
128 просмотров
schedule 03.07.2022

Как отображать частичные ответы с помощью Akka HTTP
Я хотел бы отобразить частичный ответ, используя Akka HTTP. В запросе клиент должен указать, какие поля включать в ответ (например, используя параметр запроса fields , например: https://www.acme.com/api/users/100?fields=id,name,address ). Я был...
144 просмотров
schedule 21.04.2023

Как использовать Akka-HTTP client websocket send message
Я пытаюсь использовать веб-сокет на стороне клиента, следуя документу webSocketClientFlow . пример кода: import akka.actor.ActorSystem import akka.Done import akka.http.scaladsl.Http import akka.stream.ActorMaterializer import...
4016 просмотров
schedule 03.05.2023

akka-http отвечает исходящим ответом в случае сбоя
Я вызываю внешний API и хочу вернуть пользователю результат «КАК ЕСТЬ» в случае, если код состояния отличается от OK : val connectionFlow: Flow[HttpRequest, HttpResponse, Future[Http.OutgoingConnection]] = Http().outgoingConnection("akka.io")...
121 просмотров
schedule 26.07.2023

Тестирование маршрута akka-http, который завершается бесконечным потоком
У меня есть маршрут akka-http, который возвращает Source , содержащий бесконечный поток объектов. Как я могу проверить это с помощью набора тестов маршрута? Я хотел бы проверить только первые n элементов потока, но я взглянул на код тестового...
232 просмотров
schedule 01.05.2023

Как предотвратить заголовок WWW-Authenticate в ответ с помощью директивы authenticationBasicAsync?
Как при использовании authenticationBasicAsync можно опустить заголовок ответа WWW-Authenticate? Проблема в том, что API-интерфейс Javascript (ajax) вызывает службу akka-http, и браузер отображает окно входа в систему при сбое аутентификации....
150 просмотров
schedule 14.12.2022

акка http (не)маршал черты
Предположим, что следующий код: sealed trait Action { def run(): Boolean } case class SimpleAction(parameter: String) extends Actions { // some impl } case class ExtendedAction(parameter1: String, parameter2: String) extends Actions { //...
466 просмотров
schedule 27.02.2023