<\/div>\n

Merhaba,<\/p>\n

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

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

$\"gRPC$ <\/a>

Client’\u0131n server\u2019a stream mesaj g\u00f6nderdi\u011fi ve server\u2019\u0131n tek bir response d\u00f6nd\u00fcr\u00fc\u011f\u00fc RPC t\u00fcr\u00fcd\u00fcr. Yani client birden \u00e7ok mesaj g\u00f6nderiyor, server buna kar\u015f\u0131l\u0131k tek bir cevap d\u00f6nd\u00fcr\u00fcyor. Anlayaca\u011f\u0131n\u0131z Server Streaming’in tam tersi bir ak\u0131\u015f s\u00f6z konusudur.<\/p><\/div>
\nEvet, Server Streaming<\/a>‘de inceledi\u011fimiz ak\u0131\u015f\u0131n tam tersi Client Streaming i\u00e7in ge\u00e7erlidir. \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(stream MessageRequest) returns (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>\nYukar\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’ stream’i istemekte ve response olarak geriye ‘MessageResponse’ nesnesi d\u00f6nd\u00fcrmektedir. Yani g\u00f6nderilen birden fazla ‘MessageRequest’ nesnesine kar\u015f\u0131l\u0131k tek bir ‘MessageResponse’ nesnesini cevap olarak g\u00f6ndermektedir.<\/p>\nServer’da Message Service’i<\/h4>\nClient’tan 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<MessageResponse> GetMessage(IAsyncStreamReader<MessageRequest> requestStream, ServerCallContext context)\r\n        {\r\n            await Task.Run(async () =>\r\n            {\r\n                while (await requestStream.MoveNext())\r\n                {\r\n                    Console.WriteLine($"Mesaj al\u0131nm\u0131\u015ft\u0131r.");\r\n                    Console.WriteLine("Gelen mesaj : ");\r\n                    Console.WriteLine(requestStream.Current.Message);\r\n                }\r\n            });\r\n\r\n            return new MessageResponse { Message = "\u0130stek al\u0131nd\u0131 ve i\u015flendi..." };\r\n        }\r\n    }\r\n<\/pre>\nYukar\u0131daki servis detay\u0131n\u0131 incelerseniz e\u011fer kullan\u0131lan Client Streaming y\u00f6ntemine uygun olacak \u015fekilde stream olarak birden fazla de\u011fer \u015feklinde gelen request’e kar\u015f\u0131l\u0131k tek bir response d\u00f6n\u00fclmektedir.<\/p>\nClient<\/h4>\n\u0130stek g\u00f6nderecek client’\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 request = messageClient.GetMessage();\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 request.RequestStream.WriteAsync(new MessageRequest { Message = $"G\u00f6nderilen mesaj {count}" });\r\n                    await Task.Delay(1000);\r\n                }\r\n            });\r\n\r\n            \/\/RequestStream ba\u015far\u0131yla sonland\u0131r\u0131l\u0131yor.\r\n            await request.RequestStream.CompleteAsync();\r\n\r\n            var response = await request;\r\n            Console.WriteLine($"Gelen Cevap : {response.Message}");\r\n        }\r\n    }\r\n<\/pre>\nDikkat ederseniz client, kullan\u0131lan Client Streaming y\u00f6ntemine uygun olacak \u015fekilde stream data ile istekte bulunmakta, buna kar\u015f\u0131l\u0131k server’dan gelen ‘MessageResponse’ t\u00fcr\u00fcnden sonucu elde ederek ekrana yazd\u0131rmaktad\u0131r.<\/p>\nTest Edelim<\/h4>\n<\/a><\/p>\n
G\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere Client Streaming y\u00f6ntemiyle client ve server aras\u0131nda ba\u015far\u0131yla ileti\u015fim kurulabilmekte ve yap\u0131lan stream request’e kar\u015f\u0131l\u0131k tek bir 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.
\ngRPCClientExample<\/a>
\ngRPCServerExample<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
Merhaba, Bu i\u00e7eri\u011fimizde, iki uygulama aras\u0131nda ileti\u015fimin gRPC \u00fczerinden Client Streaming y\u00f6ntemiyle nas\u0131l sa\u011fland\u0131\u011f\u0131n\u0131 pratikte inceliyor olaca\u011f\u0131z. \u0130lk olarak Client Streaming y\u00f6nteminin ne oldu\u011funu hat\u0131rlayarak ba\u015flayal\u0131m. Evet, Server Streaming‘de inceledi\u011fimiz ak\u0131\u015f\u0131n tam tersi Client...<\/p>\n","protected":false},"author":1,"featured_media":20392,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[4032],"tags":[4057,4065,4076,4077],"class_list":["post-20553","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-grpc","tag-client-streaming","tag-grpc","tag-grpc-client-streamingg","tag-rpc-client-streaming-iletisim"],"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/20553","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=20553"}],"version-history":[{"count":10,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/20553\/revisions"}],"predecessor-version":[{"id":20566,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/20553\/revisions\/20566"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media\/20392"}],"wp:attachment":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media?parent=20553"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/categories?post=20553"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/tags?post=20553"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}