Описание тега akka-http

Описание тега Вопросы с тегом
Цель уровня HTTP Akka - предоставить участникам доступ к сети через HTTP и позволить им использовать HTTP-сервисы в качестве клиента. Это не HTTP-фреймворк, это набор инструментов на основе акторов для взаимодействия с веб-службами и клиентами.
2 ответа

Akka http с помощью Java - получить строку из RequestEntity

Я пытаюсь получить тело запроса http, но кажется, что это не так просто, как может показаться, если, конечно, я что-то упустил. У меня есть экземпляр HttpRequest (от akka.http.javadsl.model) и от этого я могу получить RequestEntity, но я не могу пон…
18 июл '16 в 20:22
1 ответ

Как отправить в реальном времени количество активных подключений WebSocket через HTTP WebSocket Akka? (работает только с Akka Streams)

Как можно посчитать в реальном времени количество активных подключений WebSocket через Akka WebSocket? Кажется, что Akka HTTP WebSockets изменяет ход предварительной подготовки Akka Stream. В первом блоке кода, приведенном ниже, счетчик отправляется…
06 сен '17 в 19:04
1 ответ

HTTP-поток Akka не останавливается при возникновении исключения

Я пытаюсь использовать Akka HTTP для размещения на веб-сервере. Если POST терпит неудачу, я хотел бы, чтобы он прекратил и не отправлял больше POST, поскольку они не являются идемпотентными. Приведенный ниже код создает сообщения POST и отправляет и…
09 май '16 в 16:17
1 ответ

Пропагандировать / делегировать значение пути к дочерним маршрутам akka http

Я хочу иметь базовый маршрут, который получит IntNumber и сделайте несколько проверок с базой данных, чтобы узнать, правильны ли значения или нет, и затем, если значение верное, я хочу распространить значение на дочерние маршруты. Базовый маршрут cl…
04 сен '16 в 11:12
0 ответов

Загрузка файла akka-http не загружает весь файл?

У меня есть следующий сервер object FileUploadServer { implicit val system = ActorSystem("fileUploadServer") implicit val materializer = ActorMaterializer() implicit val ec = system.dispatcher val route = path("upload") { post { extractRequest { req…
04 дек '15 в 03:33
1 ответ

reference.conf против файлов application.conf в Akka

Я новичок в Акке и пытаюсь понять разницу между reference.conf а также application.conf файлы? Как правильно их использовать? Какие переменные я должен иметь в каждом файле?
24 апр '18 в 08:03
1 ответ

Тестирование потока Akka, содержащего поток cachedHostConnectionPool Akka Http

Любые идеи о том, как лучше всего протестировать Akka Stream, содержащий Akka Http Flow? Я борюсь со следующим методом, в частности: def akkaHttpFlow(server: String)(implicit actorSystem: ActorSystem, actorMaterializer: ActorMaterializer) = { val ur…
28 янв '18 в 21:03
2 ответа

Вернуть ошибки JSON в API-интерфейсе akka-http

В API, который я пишу, я хочу взять и вернуть JSON даже в случае ошибок. Я пытаюсь выяснить, как сохранить все default RejectionHandler поведение, но преобразовать коды состояния и текст в объект JSON. Поскольку поведение по умолчанию задается в выз…
02 фев '16 в 22:54
1 ответ

akka-http отвечает исходящим ответом, если не удалось

Я звоню по внешнему API и хочу вернуть пользователю результат "КАК ЕСТЬ", если код состояния отличается от " ОК": val connectionFlow: Flow[HttpRequest, HttpResponse, Future[Http.OutgoingConnection]] = Http().outgoingConnection("akka.io") def respons…
14 дек '16 в 13:53
1 ответ

Swagger-Akka-Http: список объектов в теле запроса

Я использую swagger-akka-http для создания документов Swagger для моего сервиса Akka HTTP. Мой сервис имеет метод POST, принимающий List из Characteristic, @ApiOperation(value = "Fetch offerings by characteristics", httpMethod = "POST") @ApiImplicit…
31 июл '18 в 08:45
2 ответа

Переход от socko к веб-сокетам akka-http

У меня есть приложение akka, основанное на soso websockets. Связь с сокетами происходит внутри одного субъекта, а сообщения, выходящие из субъекта и входящие в него (входящие и исходящие сообщения соответственно), помечаются идентификатором сокета, …
26 май '16 в 19:12
1 ответ

Потоковое CSV с помощью akka-http в Scala

Я очень новичок в akka-http, и я хотел бы передать поток csv с произвольным числом строк. Например, я хотел бы вернуть: a,1 b,2 c,3 со следующим кодом implicit val actorSystem = ActorSystem("system") implicit val actorMaterializer = ActorMaterialize…
27 окт '16 в 08:14
2 ответа

Вариант результата в akka-http

У меня возникла проблема при попытке вернуть результат Option из aka-http. По сути, это может быть 404. pathPrefix("contacts" / Segment) { id => get { contactService.getById(id).map { case Some(c: ContactDto) => complete(OK -> toResource(c)…
19 авг '16 в 04:29
1 ответ

Соответствие пути HTTP Akka - pathEndOrSingleSlash не соответствует

Конечная точка должна отражать часть пути запроса. Есть два варианта запроса: <host>/xyz-<token>/ <host>/xyz-<token>.txt token часть - это то, что я хотел бы извлечь. Однако мне подходит только второй вариант, а не первый. За…
02 фев '16 в 17:29
0 ответов

Как изменить Akka HttpResponse?

Я использую Akka и хочу изменить сущность HttpResponse, В частности, я хочу изменить body или же header конкретного HttpResponse, поскольку HttpResponse это последний класс, я не могу изменить его, но копирование и установка слегка измененного body …
09 окт '16 в 17:11
0 ответов

Перенаправить запрос Http после добавления нового заголовка

Существует три приложения A,B и C. A - это приложение, которое выполняет saml-аутентификацию и возвращает ответ saml. Приложение B - это сервер (написанный на scala с использованием akka-http), который принимает ответ saml, проверяет предоставленную…
12 апр '18 в 10:18
1 ответ

Акка http выдает исключение на высокой пропускной способности - java.io.IOException: слишком много открытых файлов в системе

Я пытаюсь отправить 200k сообщений на akka-http . protected val someRouts: Route = pathPrefix("foo") { pathEndOrSingleSlash { put { entity(as[Foo]) { foo => log.debug(s"/foo update $foo") complete(Future(Foo("a")).map(f => s"Got - $f ")) } } }…
05 сен '17 в 15:54
1 ответ

Захватить все сегменты пути в Akka/Java

Я пытаюсь захватить каждый сегмент пути URL в AkkaHTTP с Java. Вот мой код: public Route routes() { return route(pathPrefix("users", () -> route( getOrPostUsers(), path(PathMatchers.segment(), name -> route( getUser(name), deleteUser(name), pa…
12 май '18 в 14:26
1 ответ

Почему Akka HTTP Routing перехватывает мое исключение?

Учитывая этот код def leaderboardPost(name: Option[String]): Route = post { logRequest("leaderboard", Logging.DebugLevel) { handleRejections(postBodyRejections) { entity(as[LeaderboardPostRequest]) { leaderboard => try { complete(leaderboardCreat…
23 янв '19 в 00:39
1 ответ

Как получить ошибку от akka-stream, распространяющуюся на akka-http, чтобы оба были зарегистрированы и правильно уведомлять клиента?

Щас пользуюсь akka-stream а также akka-HTTP построить API потоковой передачи файлов. Таким образом, я внедряю потоковый источник в объект, чтобы данные передавались напрямую HTTP-клиенту следующим образом: complete(HttpEntity(ContentTypes.`applicati…
16 фев '17 в 19:56