当前位置：首页 > news >正文

c# Grpc取消

news 来源：原创 2025/5/13 18:11:59

net6.0

通过CancellationTokenSource 客户端取消Grpc，服务端判断 IsCancellationRequested 是否取消。

proto:

syntax = "proto3";// 引用可空类型
import "google/protobuf/wrappers.proto";option csharp_namespace = "Grpc.Common";package greet;// The greeting service definition.
service Greeter {rpc StreamApi (HelloRequest) returns (stream HelloResponse);
}// The request message containing the user's name.
message HelloRequest {string name = 1;
}message HelloResponse {string message = 1;
}

服务端：

nuget包：Grpc.AspNetCore、Grpc.AspNetCore.Server.Reflection

GreeterService.cs

using Grpc.Core;
using Grpc.Common;public class GreeterService : Greeter.GreeterBase{private readonly ILogger<GreeterService> _logger;public GreeterService(ILogger<GreeterService> logger){_logger = logger;}public override async Task StreamApi(HelloRequest request, IServerStreamWriter<HelloResponse> responseStream, ServerCallContext context){try{for (var i = 0; i < 50; i++){if (context.CancellationToken.IsCancellationRequested){await responseStream.WriteAsync(new HelloResponse{Message = i.ToString()});await Task.Delay(1000 * 3);}}}catch (OperationCanceledException ex){throw;}}}

program：

    public class Program{public static void Main(string[] args){var builder = WebApplication.CreateBuilder(args);// Additional configuration is required to successfully run gRPC on macOS.// For instructions on how to configure Kestrel and gRPC clients on macOS, visit https://go.microsoft.com/fwlink/?linkid=2099682// Add services to the container.builder.Services.AddGrpc();builder.Services.AddGrpcReflection();//添加gRPC反射var app = builder.Build();IWebHostEnvironment env = app.Environment;// Configure the HTTP request pipeline.app.MapGrpcService<GreeterService>();if (env.IsDevelopment()){//映射gRPC反射服务app.MapGrpcReflectionService();}app.MapGet("/", () => "Communication with gRPC endpoints must be made through a gRPC client. To learn how to create a client, visit: https://go.microsoft.com/fwlink/?linkid=2086909");app.Run();}}

客户端：

nuget包：Google.Protobuf、Grpc.Net.Client、Grpc.Net.ClientFactory、Grpc.Tools

GreeterService.cs

public class GreeterService
{private readonly GreeterClient _greeterClient;public GreeterService(GreeterClient greeterClient){_greeterClient = greeterClient;}private static CancellationTokenSource ProbeLoopCancellationTokenSource = new CancellationTokenSource();public async Task StreamApiAsync(HelloRequest request){using var call = _greeterClient.StreamApi(request, cancellationToken: ProbeLoopCancellationTokenSource.Token);await foreach (var response in call.ResponseStream.ReadAllAsync()){Console.WriteLine(response.Message);}}public async Task CancleAsync(){ProbeLoopCancellationTokenSource.Cancel();}
}

program:

    public class Program{public static void Main(string[] args){var builder = WebApplication.CreateBuilder(args);// Add services to the container.builder.Services.AddControllers();// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbucklebuilder.Services.AddEndpointsApiExplorer();builder.Services.AddSwaggerGen();builder.Services.AddTransient<GreeterService>();builder.Services.AddGrpcClient<GreeterClient>(options =>{options.Address = new Uri("http://localhost:5047");options.ChannelOptionsActions.Add(channelOption =>{channelOption.HttpHandler = new SocketsHttpHandler{EnableMultipleHttp2Connections = true};});//配置请求超时自动取消时间 发起请求到服务端后xxx秒后自动取消//options.CallOptionsActions.Add(callOptionsAction =>//{//    callOptionsAction.CallOptions = new CallOptions(deadline: DateTime.UtcNow.AddSeconds(xx));//});});var app = builder.Build();// Configure the HTTP request pipeline.if (app.Environment.IsDevelopment()){app.UseSwagger();app.UseSwaggerUI();}app.UseAuthorization();app.MapControllers();app.Run();}}

c# Grpc取消

net6.0 通过CancellationTokenSource 客户端取消Grpc，服务端判断 IsCancellationRequested 是否取消。 proto: syntax "proto3";// 引用可空类型 import "google/protobuf/wrappers.proto";option csharp_namespace "Grpc.Common"…...

编程日记 2025/5/13 18:11:59

Flask 是什么？

近期开发chatbot 程序，过程中要使用Flask，所以收集资料记录这个套件的信息： Flask 是什么？ Flask 是一个轻量级、模块化的 Python Web 框架，用于构建 Web 应用程序和 API。它被设计为简单、灵活且可扩展，…...

编程日记 2025/5/10 1:50:04

智能合约

06-智能合约 0 啥是智能合约？ 定义智能合约，又称加密合约，在一定条件下可直接控制数字货币或资产在各方之间转移的一种计算机程序。角色区块链网络可视为一个分布式存储服务，因为它存储了所有交易和智能合约的状态智能合约还…...

编程日记 2025/5/11 3:33:53

【机器学习】分类器

在机器学习(Machine Learning，ML)中，分类器泛指算法或模型，用于将输入数据分为不同的类别或标签。分类器是监督学习的一部分，它依据已知的数据集中的特征和标签进行训练，并根据这些学习到的知识对新的未标记数据进行分…...

编程日记 2025/5/5 12:46:10

ASP 快速参考

ASP 快速参考概述 ASP（Active Server Pages）是一种由微软开发的服务器端脚本环境，用于动态生成交互性网页。它允许开发者结合HTML、VBScript或JScript脚本语言来创建和运行动态网页或Web应用程序。本快速参考将提供ASP的基础知识、常用内置…...

编程日记 2025/4/30 11:59:27

支持向量机算法：原理、实现与应用

摘要： 本文深入探讨支持向量机（Support Vector Machine，SVM）算法，详细阐述其原理、数学模型、核函数机制以及在分类和回归问题中的应用方式。通过以 Python 和 C# 为例，展示 SVM 算法在不同编程环境下的具体…...

编程日记 2025/5/3 14:53:16

蓝桥杯分治

P1226 【模板】快速幂题目描述给你三个整数 𝑎,𝑏,𝑝a,b,p，求 𝑎𝑏 mod 𝑝abmodp。输入格式输入只有一行三个整数，分别代表 𝑎,𝑏,𝑝a,b,p。…...

编程日记 2025/5/6 22:27:18

群控系统服务端开发模式-应用开发-邮件工厂结构封装

首先在系统根目录下extend文件夹下创建邮件工厂文件夹并更名叫Mail。一、邮件发送父类在Mail目录下创建邮件发送父类并更名为MailSenderInterface.php，代码如下 <?php /*** 邮件发送父类* User: 龙哥三年风水* Date: 2024/12/5* Time: 14:22*/ namespace Ma…...

编程日记 2025/5/13 18:00:41

COCO数据集理解

COCO（Common Objects in Context）数据集是一个用于计算机视觉研究的广泛使用的数据集，特别是在物体检测、分割和图像标注等任务中。COCO数据集由微软研究院开发，其主要特点包括： 丰富的标签：COCO数据集包含…...

编程日记 2025/5/13 17:51:21

数据结构与算法学习笔记----堆

数据结构与算法学习笔记----堆 author: 明月清了个风 first publish time: 2024.12.2 revised: 2024.12.3 - 例题标题错误，已修改。 ps⛹从这里开始调整了文章结构，先讲解算法和数据结构基本原理，再给出例题，针对例题中的应用再…...

编程日记 2025/5/12 9:39:13

在玩“吃鸡”的时候游戏崩溃要如何解决？游戏运行时崩溃是什么原因？

“吃鸡”游戏崩溃问题深度解析与解决方案：原因、修复与预防在紧张刺激的“吃鸡”（即《绝地求生》）游戏中，突然遭遇游戏崩溃无疑会让玩家倍感沮丧。作为一名经验丰富的软件开发从业者，我深知游戏崩溃可能由多种因素引…...

编程日记 2025/5/11 22:03:46

AndroidAutoSize实战教程：今日头条屏幕适配方案详解

如何在项目中结合 AndroidAutoSize 来进行今日头条屏幕适配，我会具体讲解如何用 AndroidAutoSize 实现屏幕适配，并结合 Kotlin 代码举例分析。通过 AndroidAutoSize 库来实现屏幕适配，确保在不同的屏幕尺寸、分辨率、密度下，应用…...

编程日记 2025/5/11 9:12:13

学习threejs，通过设置纹理属性来修改纹理贴图的位置和大小

👨‍⚕️ 主页： gis分享者 👨‍⚕️ 感谢各位大佬点赞👍 收藏⭐ 留言📝 加关注✅! 👨‍⚕️ 收录于专栏：threejs gis工程师文章目录一、🍀前言1.1 ☘️Texture 贴图二、&#x1…...

编程日记 2025/5/6 8:08:59

目录 Aluciddreamer ZoeDepth 会自动下载模型： 图生全景图SD-T2I-360PanoImage： Aluciddreamer GitHub - luciddreamer-cvlab/LucidDreamer: Official code for the paper "LucidDreamer: Domain-free Generation of 3D Gaussian Splatting Sce…...

编程日记 2025/5/8 10:27:36

Delphi 实现键盘模拟、锁定键盘，锁定鼠标等操作

Delphi 模拟按键的方法 SendMessageA 说明: 调用一个窗口的窗口函数，将一条消息发给那个窗口。除非消息处理完毕，否则该函数不会返回SendMessage所包含4个参数: 1. hwnd 32位的窗口句柄窗口可以是任何类型的屏幕对象，因为Win32能够维护大多数…...

编程日记 2025/5/13 13:40:18

6. 一分钟读懂“抽象工厂模式”

6.1 模式介绍书接上文，工厂方法模式只能搞定单一产品族，遇到需要生产多个产品族时就歇菜了。于是，在需求的“花式鞭策”下，程序员们再次绷紧脑细胞，创造出了更强大的抽象工厂模式，让工厂一次性打包多个产品…...

编程日记 2025/5/7 15:23:58

（四）lerobot开源项目的主从臂的远程操作（带相机）（操作记录）

目录《项目简介》一、B站视频参考（推荐） 二、确定两个usb相机的端口号三、远程操作（带相机） 四、遇到问题《项目简介》项目地址：GitHub - huggingface/lerobot: 🤗 LeRobot: Making AI for Ro…...

编程日记 2025/5/12 15:10:46

离线安装ollama到服务器

搜了很多教程不满意,弄了半天才弄好，这里记录下，方便以后的人用，那个在线下载太慢，怕不是得下载到明年。一.从官网下在liunx版的tgz安装包 Releases ollama/ollama (github.com) 查看自己的服务器信息（参考 https:/…...

编程日记 2025/5/11 4:38:49

Vue前端开发-多级路由配置

在Vue 路由数组中，允许配置多级的路由对象结构，可以是二级、三级或者更多级别，最大级别原则上没有限制，但通常最大的是三或四级，这种路由结构，称之为多级路由。例如：一级路由地址/list&#x…...

编程日记 2025/5/12 15:11:04

Yocto bitbake and codeSonar

1 mdm 1.1 屏蔽mdm sysvinit的console输出 - uboot传入参数的时候传入consolenull，这样Linux启动信息没有了 - 还需要在Linux配置中去掉Support for console on AMBA serial port - 文件系统/etc/inittab文件里注释掉::respawn:/sbin/getty -L ttyS000 115200 vt100…...

编程日记 2025/4/27 3:43:10

sheng的学习笔记-【中】【吴恩达课后测验】Course 5 -序列模型 - 第二周测验 - 自然语言处理与词嵌入

课程5_第2周_测验题目录第一题 1.假设你为10000个单词学习词嵌入，为了捕获全部范围的单词的变化以及意义，那么词嵌入向量应该是10000维的。 A. 【】正确 B. 【】错误答案： B.【 √ 】错误第二题 2.什么是t-SNE&#xff1f…...

编程日记 2025/5/9 6:46:05

数字图像处理内容详解

1.对比度最大亮度 / 最小亮度 2.邻域 m邻接：对于像素p和q，如果p和q四临接，或p和q八临接且两者的四邻域的交集为空通路：如果俩点全部是K邻接（K代表4，8，m），则说明存在K…...

编程日记 2025/5/6 4:20:22

python通过ODBC连接神通数据库

1、安装神通数据库 2、安装python 3、安装pyodbc pip3 install pyodbc-5.2.0-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl 注：pyodbc要和python版本相对应 4、安装unixodbc 5、配置神通数据库ODBC数据源 6、示例代码如下 #!/usr/bin/python…...

编程日记 2025/5/12 17:32:25

QNX的PPS发布/订阅模型

参考资料： QNX官方文档以下摘自官网介绍： TheQNX NeutrinoPersistent Publish/Subscribe (PPS) service is a small, extensible publish/subscribe service that offers persistence across reboots. It’s designed to provide a simple and easy-to-use solution for b…...

编程日记 2025/5/11 7:49:15

Ubuntu——extrepo添加部分外部软件源

extrepo 是一个用于 Ubuntu 和其他基于 Debian 的系统的工具，它的主要作用是简化和管理外部软件源（repositories）的添加和更新。通过使用 extrepo，用户可以方便地添加、删除和管理第三方软件源，而不需要手动编辑源列表…...

编程日记 2025/5/12 15:57:57

java基础教程第16篇（正则表达式）

Java 正则表达式正则表达式定义了字符串的模式。正则表达式可以用来搜索、编辑或处理文本。正则表达式并不仅限于某一种语言，但是在每种语言中有细微的差别。 Java 提供了 java.util.regex 包，它包含了 Pattern 和 Matcher 类，用于处理正…...

编程日记 2025/5/10 21:44:54

【Shell 脚本实现 HTTP 请求的接收、解析、处理逻辑】

以下是一个实现客户端对 Shell HTTP 服务发起 POST 请求并传入 JSON 参数的完整示例。Shell 服务会解析收到的 JSON 数据，根据内容执行操作。服务端脚本：http_server.sh 以下脚本使用 netcat (nc) 来监听 HTTP 请求，并通过 jq 工具解析 JSO…...

编程日记 2025/5/12 17:30:35

Leetcode 每日一题 290.单词规律

目录一、问题分析二、解题思路三、代码实现四、复杂度分析五、总结在编程的世界里，我们常常会遇到各种有趣的字符串匹配问题。今天要探讨的就是这样一个问题：给定一种规律 pattern 和一个字符串 s，判断 s 是否遵循与 pattern 相同…...

编程日记 2025/5/7 8:03:02

图像滤波和卷积的不同及MATLAB应用实例

滤波与卷积在图像处理中都是非常重要的运算，但它们有着明显的区别。以下是滤波与卷积的主要不同点，并附带一个MATLAB实例来展示两者在图像处理中的效果差异。一、滤波与卷积的不同定义与目的： 1）滤波：滤波是一种信…...

编程日记 2025/5/2 9:21:16

【AI模型对比】AI新宠Kimi与ChatGPT的全面对比：技术、性能、应用全揭秘

文章目录 Moss前沿AI技术背景Kimi人工智能的技术积淀ChatGPT的技术优势详细对比列表模型研发Kimi大模型的研发历程ChatGPT的发展演进参数规模与架构Kimi大模型的参数规模解析ChatGPT的参数体系模型表现与局限性Kimi大模型的表现ChatGPT的表现结论：如何选择适合自…...

编程日记 2025/5/13 2:31:22

详细解读CMA实验室认可

CMA实验室认可，即中国计量认证（China Metrology Accreditation）的实验室资质认定，以下是对其的详细解读： 一、定义与目的 CMA认证是经省级以上人民政府计量行政部门对实验室的计量检定、测试能力和可靠性考核合格后进…...

编程日记 2025/5/13 9:35:58

H5与支付宝小程序通信，调起扫一扫

1.public/index.html加入代码 <script>if (navigator.userAgent.indexOf(AliApp) > -1) {document.writeln(<script src"https://appx/web-view.min.js" > < / script>);}window.$my my </script>2.vue其他具体页面加入代码 metho…...

编程日记 2025/5/9 4:07:06

Lighthouse（灯塔）—— Chrome 浏览器性能测试工具

1.认识 Lighthouse Lighthouse 是 Google 开发的一款开源性能测试工具，用于分析网页或 Web 应用的性能、可访问性、最佳实践、安全性以及 SEO 等关键指标。开发人员可以通过 Lighthouse 快速了解网页的性能瓶颈，并基于优化建议进行改进。核心功能&…...

编程日记 2025/5/12 0:29:46

深入浅出机器学习中的梯度下降算法

大家好，在机器学习中，梯度下降算法（Gradient Descent）是一个重要的概念。它是一种优化算法，用于最小化目标函数，通常是损失函数。梯度下降可以帮助找到一个模型最优的参数，使得模型的预测更加准…...

编程日记 2025/5/10 9:01:42

AIGC 012-Video LDM-更进一步，SD作者将LDM扩展到视频生成任务！

AIGC 012-Video LDM-Stable Video diffusion前身，将LDM扩展到视频生成任务！ 文章目录 0 论文工作1论文方法实验结果 0 论文工作 Video LDM作者也是Stable diffusion的作者，作者在SD的架构上进行扩展，实现了视频的生成。后续在Vid…...

编程日记 2025/5/8 17:51:32

Rust常用命令总结

安装Rust 检查并更新Ubuntu的软件包 $ sudo apt update $ sudo apt upgrade安装相关依赖：安装GCC、G、MAKE、curl $ sudo apt install build-essential $ sudo apt install curl安装Rust $ curl --proto https --tlsv1.2 -sSf https://sh.rustup.rs | sh执行命令…...

编程日记 2025/5/13 12:56:49

docker部署RustDesk自建服务器

客户端： Releases rustdesk/rustdesk GitHub 服务端： 项目官方地址：GitHub - rustdesk/rustdesk-server: RustDesk Server Program 1、拉取RustDesk库 docker pull rustdesk/rustdesk-server:latest 阿里云库： docker pu…...

编程日记 2025/5/13 7:26:26

QT4和 QT5 槽函数连接的区别

正常连接方式 //QT4官方用列QLabel *label new QLabel;QScrollBar *scrollBar new QScrollBar;QObject::connect(scrollBar, SIGNAL(valueChanged(int)),label, SLOT(setNum(int)));//QT5官方用列QLabel *label new QLabel;QLineEdit *lineEdit new QLineEdit;QObject::c…...

编程日记 2025/5/13 2:23:40

【C++】入门【六】

本节目标一、继承的概念及定义二、基类和派生类对象赋值转换三、继承中的作用域四、派生类的默认成员函数五、继承与友元六、继承与静态成员七、复杂的菱形继承及菱形虚拟继承八、继承的总结和反思九、笔试面试题一、继承的概念及定义 1.继承的概念继承是面向对象…...

编程日记 2025/5/13 6:23:29

Ansible 运维工具

安装 apt install ansible /etc/ansible/hosts , 指定密码或密钥访问分组机器 [k8s_masters] master0.c0.k8s.sb[k8s_nodes] node0.c0.k8s.sb node1.c0.k8s.sb[k8s:children] k8s_masters k8s_nodes[k8s_masters:vars] ansible_ssh_usersbadmin ansible_ssh_pass"***&q…...

编程日记 2025/5/10 22:42:02

【分布式】分布式缓存

一、什么是分布式缓存分布式缓存是一种将缓存数据存储在多个节点上的缓存方案。它通过将数据分散存储在多个节点的内存中，以提高系统的读取性能、降低数据库压力和提高系统可扩展性。二、分布式缓存的优点优点明细提高性能：分布式缓存可以将数据缓…...

编程日记 2025/4/28 5:45:30

uni-app简洁的移动端登录注册界面

非常简洁的登录、注册界面模板，使用uni-app编写，直接复制粘贴即可，无任何引用，全部公开。废话不多说，代码如下： login.vue文件 <template><view class"content"><view class&quo…...

编程日记 2025/5/10 4:26:40

传奇996_47——前端ui

方式一： 后端写ui，前端通过触发函数进行截取。然后获取标签名进行补充或附加动画这种方式很好用。问题1：获取不到标签名，标签名就是标签id，当id数字时不需要处理即可直接获取到，但是id如果时汉字就会获取…...

编程日记 2025/5/7 17:17:12

nlp培训重点

1. SGD梯度下降公式当梯度大于0时，变小，往左边找梯度接近0的值。当梯度小于0时，减去一个负数会变大，往右边找梯度接近0的值，此时梯度从负数到0上升 2.Adam优化器实现原理 #coding:utf8import torch import torch.n…...

编程日记 2025/5/13 10:02:46

ARM A32多数据处理汇编指令理解分享

ARM A32多数据处理汇编指令理解分享 1 多数据存储指令1.1 push指令1.2 STMFD/STMDB指令1.3 STMED/STMDA指令1.4 STMFA/STMIB指令1.5 STMEA/STMIA指令 2 多数据加载指令2.1 pop指令2.2 LDMFD/LDMIA指令2.3 LDMFA/LDMDA指令2.4 LDMEA/LDMDB指令2.5 LDMED/LDMIB指令在ARM A32多数…...

编程日记 2025/5/4 4:38:24

【人工智能】Transformers之Pipeline（二十七）：蒙版生成（mask-generation）

目录一、引言二、蒙版生成（mask-generation） 2.1 概述 2.2 facebook/sam-vit-base 2.3 pipeline参数 2.3.1 pipeline对象实例化参数 2.3.2 pipeline对象使用参数 2.3.3 pipeline对象返回参数 2.4 pipeline实战 2.5 模型排…...

编程日记 2025/5/11 14:54:25

数据挖掘之逻辑回归

逻辑回归（Logistic Regression）是数据挖掘中一种经典且广泛应用的算法，主要用于解决分类问题。尽管名字中带有“回归”，它的核心目标却是预测离散的类别，而不是连续的数值。逻辑回归凭借其简单、高效、易于解释的特性&…...

编程日记 2025/5/10 11:28:15

PH热榜 | 2024-12-05

1. Oopsie 标语：用AI和会话回放调试Flutter和React Native应用介绍：Zipy推出的Oopsie是一款你唯一需要的AI赋能移动端调试工具，它能提供▶️会话回放、🤖错误监控、💡AI生成的概要分析，以及&#x1f525…...

编程日记 2025/5/10 17:21:36

docker-常用应用部署dockerfile模板

文章目录概述Springboot-Djava.security.egdfile:/dev/./urandom参数说明 vue应用部署nginx.conf配置Dockerfile 概述本文列举了Java开发中常用如SpringBoot、Vue前端等类型的应用Docker部署所需的DockerFile Springboot FROM anapsix/alpine-java:8_server-jre_unlimited…...

编程日记 2025/5/11 17:55:35

LabVIEW中“this VI‘s owning library is missing”错误及解决

问题描述当加载或打开一个VI时，如果其所属的项目库未加载到内存，LabVIEW将提示错误：“this VIs owning library is missing”（该VI的所属库不存在）。该问题通常发生在以下情况下： 项目库文件丢失或路径…...

编程日记 2025/5/13 15:47:58

相关文章：