akkadotnet/akka.net

Port of Akka actors for .NET

Vagif Abilov

@object

@langebo When working with actors it's best no to think in OOP terms. It's all about messages. When you build a state of AppointementActor from its events you are replaying messages that were received and persisted for the given AppointmentActor persistence ID. Events come from the event journal (event store). If AppointementActor state should include more than that (e.g. a number of ResourceActor events), then you have to arrange it yourself. This is why I'd go for storing all contained events under the same persistence ID (corresponding to the aggregate root, in your case it will be AppointmentActor).

James Hulse

@jameshulse

hi all, I worked on an akka.net system 2 years ago but have nearly forgotten everything I learned. trying to get back up to speed but can't seem to find the really great article on the "work pulling pattern" that I had back then. Anybody know which one I might be referring to or where I can find something similar now? cheers

Aaron Stannard

@Aaronontheweb

push and pull?

damn, thought it might be https://petabridge.com/blog/top-akkadotnet-design-patterns/

but we don't cover it there

Alexandr Baranovskyi

@baranovskyi1_gitlab

@Aaronontheweb is there any documentation on how Lighthouse should be started and configured?
It seems like there's a lot of custom cases that aren't described anywhere (seed-node cycle, as I wrote in the previous message, and constant gateway association errors if lighthouse referenced by another lighthouse starts later than latter)

edwinparker

@edwinparker

I'm using NLog to log errors in my akka app. I would like to be able to add additional data to the exception before it logs...including the message value. I was using PreRestart override for this which works, but I noticed the error often gets logged before that event is triggered so sometimes the extra data is not included. Where would be the appropriate place to do this kind of logging? Do I need a custom logger or some other approach?

atresnjo

@atresnjo

Is there a way to send a "global" message in akka? as in notify every known actor in the system.

Arjen Smits

@Danthar

@atresnjo take a look at actorselections and how addresses work: https://getakka.net/articles/concepts/addressing.html#querying-the-logical-actor-hierarchy

atresnjo

@atresnjo

Yeah I can know that I can do it myself, question was more like if there's something already inbuilt.

thanks tho

Chris

@chriskolenko

Is there any gotcha's when using Cluster Discovery Consul + Routing?

Here is my deployment config:

            /other {
                router = broadcast-group
                routees.paths = ["/user/api"]
                virtual-nodes-factor = 8
                cluster {
                    enabled = on
                    max-nr-of-instances-per-node = 2
                    allow-local-routees = off
                    use-role = "other"
                }
            }

I have the other console application running with an actor ready for messages at /user/api

Here is the cluster config:

    cluster {
        roles = ["other"]
    }

Logs are showing that the nodes are up and running with the correct roles.

But the when telling /user/other a message it keeps deadlettering. Anyway to debug what's going on?

Oh... I'm having no issues with routing when I'm broadcasting to the same role + enabling allow-local-routees. But once scaling up I'm sure the external routees wouldn't work :(

Chris

@chriskolenko

^^^^^^^^^ Nevermind.. Found my issue..
Was creating the ActorSystems with different names. Once I figured it out, started working like a charm. :D

AndreSteenbergen

@AndreSteenbergen

Doe anyone knwo why this can occur in a cluster? I see a lot of these in my logs

[ERROR][12/2/18 4:18:21 PM][Thread 0007][remoting] SkipLastField called on an end-group tag, indicating that the corresponding start-group was missing
Cause: Google.Protobuf.InvalidProtocolBufferException: SkipLastField called on an end-group tag, indicating that the corresponding start-group was missing

Can my MsgPack serialization be the reason that message in protobuf is raised? All my own messages are serialized in MsgPack, but I can't find a lot googling this error.

Zied

@zimayel_gitlab

Hello, can maybe someone Confirm that the first example releated to this: https://getakka.net/articles/intro/use-case-and-deployment-scenarios.html using FluentConfig is absolete and have to be updated ?

joowon

@HIPERCUBE

How can i configure hyperion serialization?
I followed getakka.net serialization document, but it doesn't work.

As you can see, matched serializer is still NewtonSoftJsonSerializer

Jack Wild

@jackowild

does anybody know if it is possible to check if all actors in an actor system have an empty mailbox?

Bartosz Sypytkowski

@Horusiath

@HIPERCUBE how are you attaching this HOCON config to your actor system? (Also: are you using .net core or full framework?)

Chris G. Stevens

@cgstevens

I do want to give a shout out to the Akk.Net team. You all have done an amazing job.

I've been using Akka.Net for over 3 years and just really enjoy working with Actors, messaging and SignalR.
Here is my latest creation - https://github.com/cgstevens/FileProcessor

Aaron Stannard

@Aaronontheweb

@cgstevens wow! that is really cool

and this can work simultaneously across multiple machines?

Chris G. Stevens

@cgstevens

@Aaronontheweb Thanks Aaron!
Well I have only been working on my system but I did run a quick test and my work was in a different domain as well as a copy of my WindowsMonitor, so yes to answer your question :)
I am trying to get a project together that demonstrates all of the AWESOME tools you all have built.
So right now in the solution contains the following services:
Lighthouse - service discovery
Processor (EastCoast/WestCoast) - This is to simulate the Singleton Actor, there can only be one just like highlander :) Basically keeps track of jobs.
Worker (EastCoast/WestCoast) - This demonstrates the ClusterRouterPool and distributes the reading of a line.
WIndowsMonitor - WindowsForms application that allows you to view into the cluster... (just like my other I have created)
WebMonitor - This is using SignalR to funnel message from an actor which is using PubSub Mediator to subscribe to Topics from the Processor and Worker services.

Chris G. Stevens

@cgstevens

If anyone would love to clone my project and make sure it works that would be awesome; LOL :)
You know.. famous last words... works on my box!

Chris G. Stevens

@cgstevens

Ohhhh if you want to run across multiple systems you will need to change the 127.0.0.1 ipaddress in the hocon config to the host ipaddress.
You will need to do this with all members of the cluster so that they know how to talk to each other.

Aaron Stannard

@Aaronontheweb

@jackowild you'd need to write some custom code for that - using wildcard actor selections and a custom message type

@zimayel_gitlab yes, that's correct

we haven't supported that syntax in years

Ilya Komendantov

@IlyaKomendantov_twitter

Hey guys,
I have data duplication issue when using TCP. I'm sending from "for" loop on client and reply with the same message from akka (echo).
If the message size 15 bytes + 4 for length, everything is perfect (sent 20k messages that is arrived in order and no duplication).
If message size more than that, duplications arrived. The pattern here is 1,2,3,4,2,3,4,5,6,7,8,2,3,4,5,6,7,8,9,10, ... (not always)
From my investigation the issue caused by

<NetworkStream>.WriteAsync(packet, 0, packet.Length).ConfigureAwait(false) on client
or
<Tcp.Received>.Data.ToArray() on server (akka)

I have a repro project and will send to anyone who volunteers for investigation :)

Alex Michel

@amichel

Hi, is there an easy way to get count of actors my actor is currently watching? FullActorState is internal class and doesn't expose _watching.Count?

joowon

@HIPERCUBE

@IlyaKomendantov_twitter Can you share the reproduce repo?

Ilya Komendantov

@IlyaKomendantov_twitter

@HIPERCUBE https://drive.google.com/open?id=15TWRUolXLb4Sejyojv3z3fjqI9ahh8J1

Ilya Komendantov

@IlyaKomendantov_twitter

@HIPERCUBE I've also captured traffic it shows that client sent 10 messages and got 22 in the reply https://drive.google.com/open?id=1KYSKINzPWPoyUuK5BWHR8PeXQPg7Z-iz

remark: this is a localhost

Jan Schoeman

@oofpez

Hi! I'm looking into options for telemetry and monitoring so I can find bottlenecks.
seeing a lot of stuff for JVM Akka but not so much for AKKA.NET.

joowon

@HIPERCUBE

I really want to know that too :)

Arjen Smits

@Danthar

https://www.google.com/search?q=akka.net+phobos

Phobos is a monitoring and tracing integration for Akka.Net build by @Aaronontheweb

the JVM has the advantage of using AOP like things to weave that stuff into your actors. .NET does not has that advantage

joowon

@HIPERCUBE

https://petabridge.com/blog/phobos-akkadotnet-devops/

senzacionale

@senzacionale

I also have a problem
Message='akka.actor.provider' is not a valid type name : 'Akka.Cluster.ClusterActorRefProvider, Akka.Cluster'

my hocon config file:

akka {

stdout-loglevel = DEBUG
loglevel = DEBUG
loggers=["Akka.Logger.Serilog.SerilogLogger, Akka.Logger.Serilog"]
log-config-on-start = on  

actor {
    provider = "cluster"
}

remote {
    dot-netty.tcp {
            hostname = "127.0.0.1"
            port = 8081
            maximum-frame-size = 256000b
        }
}            

cluster {
    seed-nodes = ["akka.tcp://tradex@127.0.0.1:4053"] # address of seed node
    roles = ["ordersync", "logger"] # roles this member is in
    role.["ordersync"].min-nr-of-members = 3 # crawler role minimum node count

    # auto downing is NOT safe for production deployments.
    # you may want to use it during development, read more about it in the docs.
    #
    # auto-down-unreachable-after = 10s
}

}

Bartosz Sypytkowski

@Horusiath

@senzacionale do you have Akka.Cluster dependency in you project (it's separate nuget package). Also sometimes people are calling their project the same names, as akka packages are named, causing namespace clashes: make sure it's not your case ;)

Where communities thrive

People

Repo info

Activity