网站制作步骤,大型flash网站,用dw建设个人网站视频,wordpress 重复文章一、客户端流式处理概述
客户端流式处理方法在该方法没有接收消息的情况下启动。 requestStream 参数用于从客户端读取消息。 返回响应消息时#xff0c;客户端流式处理调用完成。客户端可以发送多个消息流到服务端#xff0c;当所有客户端消息流发送结束#xff0c;调用请…一、客户端流式处理概述
客户端流式处理方法在该方法没有接收消息的情况下启动。 requestStream 参数用于从客户端读取消息。 返回响应消息时客户端流式处理调用完成。客户端可以发送多个消息流到服务端当所有客户端消息流发送结束调用请求流完结方法则标记客户端流消息推送结束等待服务端执行完成。等同于客户端发送批量消息服务端统一处理。
二、案例介绍
接下来 会提供三个案例用于大家理解第一个客户端流的基础用法第二个客户端流的优化版本第三个客户端的文件流式传输
三、服务端配置注意grpc相关配置参考我之前的文章
// 1.提供公共的实体proto文件
// 2.服务引用对应的proto文件
// 3.定义三个客户流方法// 公共messages.proto文件
syntax proto3;option csharp_namespace GrpcProject;package grpc.serviceing;// 请求体
message ServerRequest{string name 1;double height 2;int32 age 3;bool flag 4;float x 5;float y 6;float z 7;repeated string departments 8;
}message ServerFileRequest{bytes fileBytes 1;
}// 响应体
message ServerResponse{bool result 1;
}// clientstream.proto 定义service方法
syntax proto3;import google/protobuf/empty.proto;
import Protos/messages.proto;option csharp_namespace GrpcProject;package grpc.serviceing;service ClientStreamRpc{// 基础客户端流处理rpc StreamingFromClient (stream ServerRequest) returns (ServerResponse);// foreach 客户端流式处理 前提使用C#8 或者更高版本rpc StreamingClientForeach(stream ServerRequest) returns (ServerResponse);// 文件流传输rpc FileStreamFromClient(stream ServerFileRequest) returns (ServerResponse);
}
服务接口实现 /// summary/// 客户端流式处理/// /summarypublic class ClientStreamService : ClientStreamRpc.ClientStreamRpcBase{/// summary/// 基础访问流模式/// /summary/// param namerequestStream/param/// param namecontext/param/// returns/returnspublic override async TaskServerResponse StreamingFromClient(IAsyncStreamReaderServerRequest requestStream, ServerCallContext context){while (await requestStream.MoveNext()){await Console.Out.WriteLineAsync(\r\n-------------------------激光射线------------------------------\r\n);ServerRequest request requestStream.Current;await Handle(request);}return new ServerResponse();}/// summary/// foreach访问流模式/// /summary/// param namerequestStream/param/// param namecontext/param/// returns/returnspublic override async TaskServerResponse StreamingClientForeach(IAsyncStreamReaderServerRequest requestStream, ServerCallContext context){await foreach (var request in requestStream.ReadAllAsync()){await Console.Out.WriteLineAsync(\r\n-------------------------激光射线------------------------------\r\n);await Handle(request);}return new ServerResponse();}/// summary/// 读取文件流 组合成完整的文件。/// /summary/// param namerequestStream/param/// param namecontext/param/// returns/returnspublic override async TaskServerResponse FileStreamFromClient(IAsyncStreamReaderServerFileRequest requestStream, ServerCallContext context){ServerResponse serverResponse new ServerResponse();serverResponse.Result false;// 存储流MemoryStream ms new();await foreach (var request in requestStream.ReadAllAsync()){ms.Write(request.FileBytes.Span);await Console.Out.WriteLineAsync($记录字节大小{ms.Length} bytes);}string filePath Path.Combine(Directory.GetCurrentDirectory(), log.txt);using FileStream fileStream new FileStream(filePath, FileMode.OpenOrCreate, FileAccess.ReadWrite);fileStream.Position 0;await fileStream.WriteAsync(ms.ToArray());fileStream.Flush();fileStream.Close();serverResponse.Result true;return serverResponse;}private async Task Handle(ServerRequest request){if (request ! null){foreach (var prop in request.GetType().GetProperties()){if (prop.CanRead prop.GetValue(request) is not null){await Console.Out.WriteLineAsync($property name{prop.Name}value{prop.GetValue(request)});}}}}} await foreach (var request in requestStream.ReadAllAsync()) 版本是C#8及以上版本才支持这个需要注意
四、客户端配置
引用proto文件配置为客户端类型根据编译生成的函数进行传参调用 public partial class ClientStreamForm : Form{private readonly string _url;public ClientStreamForm(IConfiguration configuration){InitializeComponent();_url configuration.GetConnectionString(ConnectionString);}private async void button1_Click(object sender, EventArgs e){var channel GrpcChannel.ForAddress(_url);var client new ClientStreamRpc.ClientStreamRpcClient(channel);var streamingFromClient client.StreamingFromClient();for (int i 0; i 3; i){ServerRequest request new();request.Age i;request.X new Random(30).Next(50);request.Y new Random(60).Next(50);request.Z new Random(90).Next(50);request.Flag i % 2 0 ? true : false;request.Height 12;request.Departments.Add(${i});await streamingFromClient.RequestStream.WriteAsync(request);}await streamingFromClient.RequestStream.CompleteAsync();}private async void btnGrpcOptimize_Click(object sender, EventArgs e){var channel GrpcChannel.ForAddress(_url);var client new ClientStreamRpc.ClientStreamRpcClient(channel);var streamingFromClient client.StreamingClientForeach();var departments new Liststring(){one,two,three,four,five,six};ServerRequest request new();foreach (var department in departments){request.Age new Random(20).Next(100);request.X new Random(30).Next(50);request.Y new Random(60).Next(50);request.Z new Random(90).Next(50);request.Flag false;request.Height 12;request.Departments.Add(department);await streamingFromClient.RequestStream.WriteAsync(request);}await streamingFromClient.RequestStream.CompleteAsync();}private async void btnFile_Click(object sender, EventArgs e){var channel GrpcChannel.ForAddress(_url);var client new ClientStreamRpc.ClientStreamRpcClient(channel);var streamingFromClient client.FileStreamFromClient();var strMessage 伟大抗日战争的一周年纪念七月七日快要到了。全民族的力量团结起来坚持抗战坚持统一战线同敌人作英勇的战争快一年了。这个战争在东方历史上是空前的在世界历史上也将是伟大的全世界人民都关心这个战争。身受战争灾难、为着自己民族的生存而奋斗的每一个中国人无日不在渴望战争的胜利。然而战争的过程究竟会要怎么样能胜利还是不能胜利能速胜还是不能速胜很多人都说持久战但是为什么是持久战怎样进行持久战很多人都说最后胜利但是为什么会有最后胜利怎样争取最后胜利这些问题不是每个人都解决了的甚至是大多数人至今没有解决的。于是失败主义的亡国论者跑出来向人们说中国会亡最后胜利不是中国的。某些性急的朋友们也跑出来向人们说中国很快就能战胜无需乎费大气力。这些议论究竟对不对呢我们一向都说这些议论是不对的。可是我们说的还没有为大多数人所了解。一半因为我们的宣传解释工作还不够一半也因为客观事变的发展还没有完全暴露其固有的性质还没有将其面貌鲜明地摆在人们之前使人们无从看出其整个的趋势和前途因而无从决定自己的整套的方针和做法。现在好了抗战十个月的经验尽够击破毫无根据的亡国论也尽够说服急性朋友们的速胜论了。在这种情形下很多人要求做个总结性的解释。尤其是对持久战有亡国论和速胜论的反对意见也有空洞无物的了解。“卢沟桥事变以来四万万人一齐努力最后胜利是中国的。”这样一种公式在广大的人们中流行着。这个公式是对的但有加以充实的必要。抗日战争和统一战线之所以能够坚持是由于许多的因素全国党派从共产党到国民党全国人民从工人农民到资产阶级全国军队从主力军到游击队国际方面从社会主义国家到各国爱好正义的人民敌国方面从某些国内反战的人民到前线反战的兵士。总而言之所有这些因素在我们的抗战中都尽了他们各种程度的努力。每一个有良心的人都应向他们表示敬意。我们共产党人同其他抗战党派和全国人民一道唯一的方向是努力团结一切力量战胜万恶的日寇。今年七月一日是中国共产党建立的十七周年纪念日。为了使每个共产党员在抗日战争中能够尽其更好和更大的努力也有着重地研究持久战的必要。因此我的讲演就来研究持久战。和持久战这个题目有关的问题我都准备说到但是不能一切都说到因为一切的东西不是在一个讲演中完全说得了的。;var spanLength strMessage.Length / 10;for (int i 0; i 10; i){var startIndex spanLength * i;string spanMessage;if (i 9){spanMessage strMessage.Substring(startIndex);}else{spanMessage strMessage.Substring(startIndex, spanLength - 1);}var strBytes Encoding.UTF8.GetBytes(spanMessage);var byteString ByteString.CopyFrom(strBytes, 0, strBytes.Length);await streamingFromClient.RequestStream.WriteAsync(new ServerFileRequest() { FileBytes byteString });Task.Delay(1000).Wait();}await streamingFromClient.RequestStream.CompleteAsync();}}
IConfiguration 接口在program类中进行注入读取appsettings.json文件调用接口查看执行结果 客户端流基础模式 2.客户端流foreach模式 3.文件流处理模式
五、源码地址
链接https://pan.baidu.com/s/1PnLhysfGbVxC1ecpu7XReA 提取码l6w0
