Свързани публикации 'akka'
Случай за неблокиране на JDBC — част втора
Заден план
Това е серия от три части
Първа част — Кликнете върху връзката Втора част — Тази страница Част трета — Актуализация от началото на 2021 г
В част първа преминахме през неблокиращи обаждания и базирани на събития системи
Раздели на тази страница
Ще се опитаме да разберем Java NIO на високо ниво Ще обясним значението на курсорите/връзките в база данни Ще направим аргумент за неблокиране на JDBC
Java IO NIO и NIO2
Ключови аспекти
Java IO имаше нишка за..
Мониторинг на приложенията на Akka с Mesmer и OpenTelemetry
Мониторинг и наблюдаемост
Термините мониторинг и наблюдаемост напоследък се завъртат често, често в объркващи взаимозаменяеми контексти. Те са тясно свързани, но по същество подхождат към проблемите от различни посоки.
Накратко, мониторингът е акт на събиране на данни, докато наблюдаемостта е свойство (и мярка https://en.wikipedia.org/wiki/Observability ) на система, която ни позволява да направим извод за вътрешно състояние въз основа единствено на външен изход. Можем да кажем,..
Свързани въпроси 'akka'
Използване на WebService с Akka Actors и рамката за игра
Създадох уеб услуга с помощта на Play & Akka и сега трябва да интегрирам друга уеб услуга, където моята уеб услуга е клиент.
Моят контролер по подразбиране (със свързан файл с маршрути) изглежда така
class myController @Inject() (implicit val...
724 изгледи
schedule
15.09.2022
Блокировка на темата с игра 2.2.1 и JPA
Намирам някакво странно поведение с JPA. В някои случаи получихме грешка
"Timed out waiting for a free available connection."
at com.jolbox.bonecp.DefaultConnectionStrategy.getConnectionInternal(DefaultConnectionStrategy.java:88)...
805 изгледи
schedule
27.09.2022
Модел на проектиране: как да се реализира верига от участници, обработващи едно логическо съобщение
Започвам да разглеждам Akka и се чудя за правилния начин да внедря конвейер от актьори, които си сътрудничат за обработка на съобщение. Позволете ми да използвам случай, за да илюстрирам въпроса си:
Имам съобщение, което представлява „решение“,...
873 изгледи
schedule
24.09.2022
Безопасно ли е да се замени `receive` в Akka FSM?
Създадох FSM с Akka. Моят FSM обаче не получава само предавани съобщения, които са от значение за неговото FSM състояние. Неговите деца могат също да предадат ActorRef s до него, които моят FSM трябва да предаде по-нататък до своя родител. Тъй...
178 изгледи
schedule
27.09.2022
Как ръчно да хвърля HTTP 404 Not Found изключение в спрей/akka?
В моята функция за хранилище чета потребител, след което актуализирам този потребител:
def update(u: User): Future[Int] = {
this.read(u.id).flatMap {
case Some(existingUser) =>
db.run(
userTable...
634 изгледи
schedule
27.09.2022
Как мога да дросел съобщения до IO(Tcp) актьора в Akka
Имам такъв актьор
class TcpClientActor(target: Target) extends Actor with Logger {
override def preStart(): Unit = {
self ! TestConnection
}
override def receive: Receive = {
case TestConnection =>
IO(Tcp) !...
72 изгледи
schedule
26.09.2022
не може да намери имплицитно: akka.http.server.RoutingSetup
Докато си играя с akka-http experimental 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
Как да комбинирате Source.repeat и Source.completionStage с помощта на Akka
Използвам akka с рамка за микросервизи, така че имам много заявки за етап на завършване. Искам да получа списък с елементи от една микроуслуга и да ги компресирам заедно с един елемент от друга, така че да получа източник на двойка‹списъчен елемент,...
78 изгледи
schedule
02.10.2022
Множество бъдещи повиквания в метода на получаване на актьор
Опитвам се да направя две външни извиквания (към база данни на Redis) в метода receive на актьор. И двете обаждания връщат Future и имам нужда от резултата от първото Future във второто. Обгръщам и двете извиквания в транзакция на Redis, за да...
1243 изгледи
schedule
08.10.2022
Как да използвате фючърси с Akka за асинхронни резултати
Опитвам се да пиша в множество файлове едновременно, като използвам рамката Akka. Първо създадох клас, наречен MyWriter, който пише във файл, след това използвайки фючърси, извиквам обекта два пъти, като подскачам, че ще бъдат създадени 2 файла за...
1018 изгледи
schedule
24.11.2022
Ограничен брой нишки в рамката на Play 2.1
Използвам Play 2.1 със Scala, за да изпълнявам няколко теста непрекъснато. Правя Future.traverse(tests)(test => Future(runTest(test)) .
Искам да огранича броя на паралелните тестове, така че искам да огранича броя на нишките в диспечера по...
1646 изгледи
schedule
01.11.2022
Akka: Какво се случва, когато кажете на ActorRef и той очаква да попитате?
Имам следното:
val future = myActor ? Message
И в моя актьор съобщението ми за получаване има нещо подобно:
sender ! Response
Ако направя следното и пренебрегна отговора, има ли някакво отрицателно въздействие?
myActor ! Message...
2848 изгледи
schedule
04.11.2022
akka с рамка за игра
все още се уча да овладявам akka java с play framework. Имам кодов фрагмент по-долу. Работеше добре, но реши да създаде някои главоболия.
public class Application extends Controller {
static ActorRef masterActor;
RubineActor rubineactor;...
864 изгледи
schedule
25.11.2023
Фючърси в Scala и Akka
С какво Scala Futures се различава от Akka Futures, единият по-добър ли е от другия? Концептуално те изглеждат подобни, което прави неблокиращото, асинхронно програмиране лесно.
451 изгледи
schedule
21.10.2022
Akka ZeroMQ - Има ли начин да получите адреса на сокета?
Да приемем следната част от кода:
class MQActor extends Actor {
// Bind on port 0... Technically this should pick a free port
val pubSocket = context.system.newSocket(SocketType.Pub, Bind("tcp://127.0.0.1:0"))
def receive = {...
854 изгледи
schedule
27.11.2023
conf/reference.conf не работи в dist zip в Play 2.2.1 с Akka 2.2.3
Кодирам P2P приложение в Scala, което работи на Play 2.2.1 с Akka 2.2.3. Когато разпределя моя проект в Play, my project/conf/reference.conf ще бъде включен в dist zip. Това е добре.
След това извлякох ZIP файла и презаписах...
275 изгледи
schedule
02.12.2023
Как да профилирате пощенските кутии на приложението Akka Java
Как мога да профилирам моето базирано на Java приложение Akka? Погледнах отговора на този въпрос .
Но открих, че е незадоволително. В отговора се казва, че Typesafe Activator е пуснал нещо, наречено „Typesafe Console“, но връзката в отговора е...
1142 изгледи
schedule
20.11.2023
Създаване на общ подклас на актьор, който също приема параметър на конструктора
Имам следния код, където T е подклас на актьор, който също трябва да приема аргумент на конструктор:
abstract class AbstractActor(dest: ActorRef) extends Actor {
//...
}
class ChildActor(dest: ActorRef) extends AbstractActor(dest) {
//......
501 изгледи
schedule
04.11.2023
Какво се случи с конзолата Typesafe за мониторинг на Akka/Play?
Всички връзки за информация относно Typesafe Console (напр. http://typesafe.com/platform/runtime/console ) бъдете пренасочени към Typesafe Activator , инструмент за обучение/шаблон за проекти (не инструмент за наблюдение). Не мога да намеря...
5013 изгледи
schedule
14.10.2022
Съобщението не се изпраща, когато актьорът Akka е убит с помощта на DeathWatch
Опитвам се да изпратя съобщение, когато актьор е убит.
Това се основава на документацията на Akka deathwatch: http://doc.akka.io/docs/akka/2.3.6/java/untyped-actors.html#deathwatch-java
В serviceActor чакам съобщение за „убиване“, но всъщност...
1339 изгледи
schedule
19.11.2022
