<\/div>\n

Merhaba,<\/p>\n

Bu i\u00e7eri\u011fimizde, iki uygulama aras\u0131nda ileti\u015fimin gRPC \u00fczerinden Server Streaming y\u00f6ntemiyle nas\u0131l sa\u011fland\u0131\u011f\u0131n\u0131 pratikte inceliyor olaca\u011f\u0131z.<\/p>\n

\u0130lk olarak Server Streaming y\u00f6nteminin ne oldu\u011funu hat\u0131rlayarak ba\u015flayal\u0131m.
\n

$\"gRPC$ <\/a>

Client\u2019\u0131n servar\u2019a tek bir istek g\u00f6nderdi\u011fi ve server\u2019\u0131n stream d\u00f6nmeye ba\u015flad\u0131\u011f\u0131 RPC t\u00fcr\u00fcd\u00fcr.<\/p><\/div>
\nBu y\u00f6ntemde server tek bir request’e kar\u015f\u0131l\u0131k birden fazla response d\u00f6nebilmektedir.<\/p>\n

\u015eimdi gelin, bu y\u00f6ntem ile bir client ve server \u00e7al\u0131\u015fmas\u0131 sergileyelim.<\/p>\n

Proto Dosyas\u0131<\/h4>\n
Client ve server olmak \u00fczere her iki uygulama aras\u0131ndaki kontrat\u0131 a\u015fa\u011f\u0131daki message.proto<\/em> dosyas\u0131 \u00fczerinden sa\u011flayaca\u011f\u0131z.<\/p>\n
\r\nsyntax = "proto3";\r\noption csharp_namespace = "gRPCExample";\r\npackage message;\r\n\r\nservice Message {\r\n rpc GetMessage(MessageRequest) returns (stream MessageResponse);\r\n}\r\nmessage MessageRequest {\r\n string message = 1;\r\n}\r\nmessage MessageResponse {\r\n string message = 1;\r\n}\r\n<\/pre>\n
Yukar\u0131daki message.proto<\/em> i\u00e7eri\u011fine g\u00f6z atarsan\u0131z e\u011fer i\u00e7erisinde ‘GetMessage’ isimli fonksiyon bar\u0131nd\u0131ran ‘Message’ isimli bir servis olu\u015fturulmaktad\u0131r. \u0130lgili fonksiyon yap\u0131lacak request neticesinde bir ‘MessageRequest’ nesnesi istemekte ve response olarak geriye ‘MessageResponse’ stream’i d\u00f6nd\u00fcrmektedir. Yani bu birden fazla ‘MessageResponse’ nesnesi d\u00f6nd\u00fcrebilir demektir. \u015eimdi gelin bu durumu inceleyelim.<\/p>\n
Server\u2019da Message Service\u2019i<\/h4>\n
Client\u2019tan gelecek olan iste\u011fi server’da kar\u015f\u0131layacak olan ‘MessageService’i a\u015fa\u011f\u0131daki gibi tasarlayal\u0131m.<\/p>\n
\r\n public class MessageService : MessageBase\r\n {\r\n public override async Task GetMessage(MessageRequest request, IServerStreamWriter<MessageResponse> responseStream, ServerCallContext context)\r\n {\r\n Console.WriteLine($"Mesaj al\u0131nm\u0131\u015ft\u0131r.");\r\n Console.WriteLine("Gelen mesaj : ");\r\n Console.WriteLine(request.Message);\r\n\r\n await Task.Run(async () =>\r\n {\r\n int count = 0;\r\n while (++count <= 10)\r\n {\r\n await responseStream.WriteAsync(new MessageResponse { Message = $"G\u00f6nderilen mesaj {count}" });\r\n await Task.Delay(1000);\r\n }\r\n });\r\n }\r\n }\r\n<\/pre>\n
Dikkat ederseniz e\u011fer ‘MessageService’ geriye bir stream d\u00f6nd\u00fcrece\u011finden dolay\u0131 override edilen ‘GetMessage’ metodunun ikinci parametresi ‘IServerStreamWriter’ olarak generate edilmi\u015ftir. Yani stream edilebilir bir t\u00fcrde ilgili response de\u011ferimiz gelmi\u015ftir. Haliyle bizde \u00f6rneklendirme ama\u00e7l\u0131, ilgili metot i\u00e7erisinde operasyonel olarak 1’er saniye arayla toplamda 10 adet mesaj stream eden sembolik bir operasyon ger\u00e7ekle\u015ftirmekteyiz.<\/p>\n
Client<\/h4>\n
\u0130stek g\u00f6nderecek client\u2019\u0131n a\u015fa\u011f\u0131daki gibi geli\u015ftirilmesi yeterli olacakt\u0131r;<\/p>\n
\r\n class Program\r\n {\r\n static async Task Main(string[] args)\r\n {\r\n var channel = GrpcChannel.ForAddress("https:\/\/localhost:5001");\r\n var messageClient = new Message.MessageClient(channel);\r\n Console.WriteLine("L\u00fctfen g\u00f6nderilecek mesaj\u0131 giriniz.");\r\n var messageResponse = messageClient.GetMessage(new MessageRequest { Message = Console.ReadLine() });\r\n\r\n await Task.Run(async () =>\r\n {\r\n while (await messageResponse.ResponseStream.MoveNext(new System.Threading.CancellationToken()))\r\n Console.WriteLine($"Gelen mesaj : {messageResponse.ResponseStream.Current.Message}");\r\n });\r\n }\r\n }\r\n<\/pre>\n
Dikkat ederseniz client kullan\u0131lan Server Streaming y\u00f6ntemine uygun olacak \u015fekilde tek bir istekte bulunmakta, lakin stream’den gelen bir\u00e7ok veriyi d\u00f6ng\u00fcyle elde etmektedir.<\/p>\n
Test Edelim<\/h4>\n
$\"gRPC$ <\/a>
\nG\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere Server Streaming y\u00f6ntemiyle client ve server aras\u0131nda ba\u015far\u0131yla ileti\u015fim kurulabilmekte ve yap\u0131lan tek bir request’e kar\u015f\u0131l\u0131k birden fazla response elde edilebilmektedir.<\/p>\n
\u0130lgilenenlerin faydalanmas\u0131 dile\u011fiyle\u2026
\nSonraki yaz\u0131lar\u0131mda g\u00f6r\u00fc\u015fmek \u00fczere\u2026
\n\u0130yi \u00e7al\u0131\u015fmalar dilerim\u2026<\/p>\n
Not : \u00d6rnek projeleri indirebilmek i\u00e7in a\u015fa\u011f\u0131daki adreslere t\u0131klay\u0131n\u0131z.
\n gRPCClientExample<\/a>
\n gRPCServerExample<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
Merhaba, Bu i\u00e7eri\u011fimizde, iki uygulama aras\u0131nda ileti\u015fimin gRPC \u00fczerinden Server Streaming y\u00f6ntemiyle nas\u0131l sa\u011fland\u0131\u011f\u0131n\u0131 pratikte inceliyor olaca\u011f\u0131z. \u0130lk olarak Server Streaming y\u00f6nteminin ne oldu\u011funu hat\u0131rlayarak ba\u015flayal\u0131m. Bu y\u00f6ntemde server tek bir request’e kar\u015f\u0131l\u0131k birden...<\/p>\n","protected":false},"author":1,"featured_media":20387,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[4032],"tags":[4065,4060,4075,4058],"class_list":["post-20538","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-grpc","tag-grpc","tag-grpc-server-streaming","tag-grpc-server-streaming-iletisim","tag-server-streaming"],"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/20538","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/comments?post=20538"}],"version-history":[{"count":6,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/20538\/revisions"}],"predecessor-version":[{"id":20552,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/20538\/revisions\/20552"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media\/20387"}],"wp:attachment":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media?parent=20538"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/categories?post=20538"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/tags?post=20538"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}

Proto Dosyas\u0131<\/h4>\nClient ve server olmak \u00fczere her iki uygulama aras\u0131ndaki kontrat\u0131 a\u015fa\u011f\u0131daki message.proto<\/em> dosyas\u0131 \u00fczerinden sa\u011flayaca\u011f\u0131z.<\/p>\n

Client<\/h4>\n\u0130stek g\u00f6nderecek client\u2019\u0131n a\u015fa\u011f\u0131daki gibi geli\u015ftirilmesi yeterli olacakt\u0131r;<\/p>\n