Вопросы по теме 'akka-http'
не удалось найти неявный: akka.http.server.RoutingSetup
Играя с экспериментальной версией akka-http 1.0-M2, я пытаюсь создать простой пример Hello world.
import akka.actor.ActorSystem
import akka.http.Http
import akka.http.model.HttpResponse
import akka.http.server.Route
import...
2553 просмотров
schedule
01.10.2022
Запрос POST иногда попадает не в ту конечную точку в программе Akka-http
У меня есть сервер Akka-http 2 для обработки HTTP-запросов.
На любой конечной точке я перехожу к классу случая A или B:
case class caseClassA(data: String, eventID: String)
case class caseClassB(data: String, otherData: JsObject)
У меня...
570 просмотров
schedule
24.02.2024
Ошибка тайм-аута клиента Scala akka-http
У меня есть приложение Scala Play, которое использует Akka и запрашивает сервер REST. Ответ на запрос может занять много времени, и я получаю тайм-ауты:
"Сервер не смог своевременно ответить на ваш запрос. Пожалуйста, повторите попытку через...
1572 просмотров
schedule
18.11.2023
Ответ JSON с Http AKKA и классами case
Я хотел бы построить простой сервер-заглушку с несколькими маршрутами, используя Http AKKA. У меня есть следующий класс case:
case class Person(name: String, age: Int)
object Person {
implicit def cardJsonFormat: RootJsonFormat[Person] =...
4166 просмотров
schedule
29.09.2022
В akka-http должны ли объекты ответа потребляться в приемнике, если ответ отличается от 200?
На этом http://doc.akka.io/docs/akka/2.4.9/scala/http/client-side/request-level.html#Future-Based_Variant внизу есть предупреждение:
Обязательно используйте объекты ответа dataBytes:Source[ByteString,Unit] , например, подключив его к...
1486 просмотров
schedule
11.12.2022
Akka: Как работать с возвращенным фидом Json?
Я получаю обратную связь Json от удаленного стороннего API следующим образом:
val myjson: Future[HttpResponse] = http.singleRequest(HttpRequest(uri = encodedUri))
myjson onComplete {
case Success(response) => sender !...
573 просмотров
schedule
27.12.2023
Использование Akka Http для нескольких привязок
Использовать akka http для привязки к порту, а затем маршрутизировать входящие соединения достаточно просто, учитывая документация .
Один нерешенный вопрос заключается в том, как связать несколько портов для разных маршрутов. Если у меня есть...
1047 просмотров
schedule
06.06.2024
Akka HTTP Websocket, как идентифицировать соединения внутри актора
Я работаю над простой многопользовательской игрой в scala, которую я хотел бы открыть через веб-сокеты для клиентов JS.
Вот мой класс WebsocketServer
class WebsocketServer(actorRef: ActorRef, protocol: Protocol, system: ActorSystem,...
1409 просмотров
schedule
06.11.2023
спрей-json в Http().bindAndHandle
В настоящее время я просматриваю документацию и примеры akka-http. Я застрял, вероятно, на чем-то очень тривиальном: передаче конфигурации маршрута с директивами и JsonSupport. Я слежу за документацией по введению . и json-поддержка
Для...
152 просмотров
schedule
27.03.2024
Akka Http извлекает строковое значение с помощью Segment PathMatcher
Я пытаюсь реализовать простой API, где я могу получить параметр пути как String . Вот мой тестовый код:
class SimpleRouteTest extends WordSpec
with Matchers
with ScalatestRouteTest {
val routes: Route = pathPrefix("foo") {
get {...
805 просмотров
schedule
28.05.2024
Akka HTTP с использованием демаршаллера ответа
Я создаю конвейер данных, используя потоки Akka и Akka HTTP. Вариант использования довольно прост: получить веб-запрос от пользователя, который сделает две вещи. Сначала создайте сеанс, вызвав сторонний API, во-вторых, зафиксируйте этот сеанс в...
545 просмотров
schedule
28.09.2022
Пользовательские заголовки Akka HTTP: ошибка в документации или незнакомый синтаксис?
Я читаю эту часть документации Akka HTTP
В подразделе о пользовательских заголовках есть эти фрагменты кода:
final class ApiTokenHeader(token: String) extends ModeledCustomHeader[ApiTokenHeader] {
override def renderInRequests = false...
177 просмотров
schedule
22.09.2022
как я могу полностью запустить покрытие кода scala
мой отчет о покрытии кода scala был 0,00% (микросервисы Akka-HTTP) , и мой отчет
[info] Statement coverage.: 0.00%
[info] Branch coverage....: 0.00%
[info] Coverage reports completed
[info] All done. Coverage was [0.00%]
как я могу запустить...
247 просмотров
schedule
28.10.2023
Преобразование данных Slick Streaming и отправка фрагментированного ответа с помощью Akka Http
Цель состоит в том, чтобы выполнить потоковую передачу данных из базы данных, выполнить некоторые вычисления для этого фрагмента данных (это вычисление возвращает Future некоторого класса case) и отправить эти данные в виде ответа по фрагментам...
700 просмотров
schedule
11.04.2024
Как использовать Scala / Akka Http для обработки более одного заголовка HTTP
Я новичок в Scala и Akka Http. Пожалуйста, простите за вопрос новичка. У меня есть следующий код, который обрабатывает входящие HTTP-запросы GET:
def clickRoute(): Route = func1( requestData =>
pathPrefix(“somewebevents”) {...
284 просмотров
schedule
26.05.2024
Spark Открытие нескольких потоков для одного задания при попытке запуска параллельных заданий
У нас есть вариант использования, в котором нам нужно запускать параллельные SQL-запросы Spark в одном сеансе Spark через rest-api (akka http).
Конфигурация приложения
my-blocking-dispatcher {
type = Dispatcher
executor =...
1336 просмотров
schedule
27.11.2022
PersistenceQuery и зомби-поток Akka-Http
Я пытаюсь передать результат PersistenceQuery с помощью akka-http в качестве SSE, но кажется, что когда http-соединение закрывается от клиента, поток PersistenceQuery по-прежнему периодически попадает в серверную часть события.
// Http part...
38 просмотров
schedule
24.05.2024
Один и тот же класс случаев, другая проверка
Что я пытаюсь сделать в Scala 2.11 и akka, так это иметь один класс case, но две разные проверки в зависимости от того, какой маршрут используется.
Например, давайте рассмотрим класс случая ниже
case class User(_id: String, name: String, age:...
71 просмотров
schedule
26.10.2023
Акка http здание Ури
Я пытаюсь создать Uri, но метод Query дает мне несоответствие типа, ожидаемую строку, фактический Uri.Query
def buildUri(url: String, query: Option[Map[String, String]] = None): Uri = {
val fullUrl = endpoint + (if (endpoint.endsWith("/"))...
390 просмотров
schedule
28.05.2024
Почему Akka HTTP не соответствует моему телу JSON?
Я пытаюсь следовать примеру на https://doc.akka.io/docs/akka-http/current/common/json-support.html
Мой код выглядит так
final case class LeaderboardPostRequest(name: String, kind: String)
final case class LeaderboardPostResponse(name:...
133 просмотров
schedule
05.11.2022
