I’m now going to take a look at what’s required to implement a remote Proto.Actor and a “client” to interact with it. I’m going to stick to the standard Greet class, as shown in my previous post, but we’re going to generate the Greet class from a .proto (protocol buffers) definition file.<\/p>\n
So before we get into the client\/server code, let’s create the Greet.proto file, here’s it is<\/p>\n
\r\nsyntax = "proto3";\r\n\r\npackage messages;\r\noption csharp_namespace = "Messages";\r\n\r\nmessage Greet {\r\n string Who = 1;\r\n}\r\n<\/pre>\nThe Greet message will generate a Greet type with a property name Who. So once you’ve created this file, you’ll need to use protoc.exe with the following command line<\/p>\n
protoc.exe –csharp_out=. Greet.proto<\/p>\n
This will generate the Greet.cs file, which I will not bother to show here.<\/p>\n
Next up, we’ll reuse our GreetActor class from the previous post, recreated below<\/p>\n
\r\npublic class GreetingActor : IActor\r\n{\r\n public Task ReceiveAsync(IContext context)\r\n {\r\n var greet = context.Message as Greet;\r\n if (greet != null)\r\n {\r\n Console.WriteLine("[Thread {0}] Greeting {1}",\r\n Thread.CurrentThread.ManagedThreadId,\r\n greet.Who);\r\n }\r\n return Actor.Done;\r\n }\r\n}\r\n<\/pre>\nAs we know, strictly speaking Akka.net and also Proto.Actor do not adhere to a client\/server architecture but remote objects are created in a peer to peer architecture. For the sake of this post we will create two separate projects, one named Server the other Client, just for simplicity.<\/p>\n
Creating our server<\/strong><\/p>\n\n- Create a Console application, named something like ProtoActorServer<\/li>\n
- Using Nuget add the Proto.Actor and Proto.Remote packages<\/li>\n
- Add or link to the Greet.cs file generated by protoc<\/li>\n
- Add or link to the GreetActor.cs file from above<\/li>\n
- In Program.cs add the following using clauses\n
\r\nusing Messages;\r\nusing Proto;\r\nusing Proto.Remote;\r\n<\/pre>\n<\/li>\n
- In the Main method add the following code\n
\r\nSerialization.RegisterFileDescriptor(GreetReflection.Descriptor);\r\nRemotingSystem.Start("127.0.0.1", 12000);\r\n\r\nvar props = Actor.FromProducer(() => new GreetingActor());\r\nActor.SpawnNamed(props, "remote");\r\n\r\n\/\/ just to keep the app. open\r\nConsole.ReadLine();\r\n<\/pre>\n<\/li>\n<\/ul>\nCreating our client<\/strong><\/p>\nAs we know, this is going to basically be very similar to the server is set-up, but there are differences in the code, but I’ll still list all the steps for completeness<\/p>\n
\n- Create a Console application, named something like ProtoActorClient<\/li>\n
- Using Nuget add the Proto.Actor and Proto.Remote packages<\/li>\n
- Add or link to the Greet.cs file generated by protoc<\/li>\n
- Add or link to the GreetActor.cs file from above<\/li>\n
- In Program.cs add the following using clauses\n
\r\nusing Messages;\r\nusing Proto;\r\nusing Proto.Remote;\r\n<\/pre>\n<\/li>\n
- In the Main method add the following code\n
\r\nSerialization.RegisterFileDescriptor(GreetReflection.Descriptor);\r\nRemotingSystem.Start("127.0.0.1", 12001);\r\n\r\nvar remote = new PID("127.0.0.1:12000", "remote");\r\nremote.Tell(new Greet { Who = "Hello World" });;\r\n\r\n\/\/ just to keep the app. open\r\nConsole.ReadLine();\r\n<\/pre>\n<\/li>\n<\/ul>\nIf you now run the ProtoActorServer and then the ProtoActorClient you should see the Greeting Hello World<\/em> message displayed on the server console via it’s GreetingActor.<\/p>\nDisclaimer<\/strong><\/p>\nAt the time of writing this I’ve not yet seen documentation to suggest I’m doing everything 100% by the Proto.Actor book, so to speak, I’ve based this code on previous use of protobuf and Akka.net as well as a couple of examples from the Proto.Actor git repos. If I find I’m doing anything incorrectly, I will update this page.<\/p>\n","protected":false},"excerpt":{"rendered":"
I’m now going to take a look at what’s required to implement a remote Proto.Actor and a “client” to interact with it. I’m going to stick to the standard Greet class, as shown in my previous post, but we’re going to generate the Greet class from a .proto (protocol buffers) definition file. So before we […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":""},"categories":[156,159],"tags":[],"class_list":["post-4680","post","type-post","status-publish","format-standard","hentry","category-actor-model","category-proto-actor"],"jetpack_sharing_enabled":true,"jetpack_featured_media_url":"","_links":{"self":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/4680","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/comments?post=4680"}],"version-history":[{"count":4,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/4680\/revisions"}],"predecessor-version":[{"id":4687,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/4680\/revisions\/4687"}],"wp:attachment":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/media?parent=4680"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/categories?post=4680"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/tags?post=4680"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}