C# 消息队列、多线程、回滚、并行编程、异步编程、反射

消息队列

消息队列是一种在应用程序之间传递消息的异步通信机制。它可以使应用程序解耦并提高系统的可伸缩性和可靠性。在 C# 中,你可以使用多个消息队列技术,其中一种广泛使用的技术是 RabbitMQ。

RabbitMQ 是一个开源的消息代理,实现了高级消息队列协议(AMQP),提供了强大的功能来处理消息传递。以下是一个使用 RabbitMQ 的 C# 示例:
 

using RabbitMQ.Client;
using RabbitMQ.Client.Events;// 创建连接和通道
var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{// 声明队列channel.QueueDeclare(queue: "hello",durable: false,exclusive: false,autoDelete: false,arguments: null);// 发布消息var message = "Hello, RabbitMQ!";var body = Encoding.UTF8.GetBytes(message);channel.BasicPublish(exchange: "",routingKey: "hello",basicProperties: null,body: body);Console.WriteLine(" [x] Sent {0}", message);
}

以上示例演示了如何创建一个 RabbitMQ 连接,声明队列,并发布一条消息到该队列。 

多线程

多线程允许在同一时间执行多个独立的任务,以提高程序的效率和响应性。在 C# 中,你可以使用 System.Threading.Thread 命名空间来处理多线程编程。以下是一个简单的多线程示例:
 

using System;
using System.Threading;public class Program
{public static void Main(){// 创建并启动新线程Thread newThread = new Thread(WorkerMethod);newThread.Start();// 在主线程中执行其他任务for (int i = 0; i < 5; i++){Console.WriteLine("Main thread executing...");Thread.Sleep(1000);}// 等待新线程结束newThread.Join();Console.WriteLine("Main thread finished.");}public static void WorkerMethod(){for (int i = 0; i < 5; i++){Console.WriteLine("Worker thread executing...");Thread.Sleep(2000);}}
}

以上示例创建了一个新线程并在后台执行 WorkerMethod 方法。同时,主线程也在执行自己的任务。两个线程交替输出消息,直到达到各自执行次数的上限。 

多线程处理逻辑

在多线程编程中,处理逻辑涉及管理线程之间的同步、协作和临界区等问题。C# 提供了几种机制来处理这些问题,如锁 (lock)、互斥体 (Mutex) 和信号量 (Semaphore)。以下是一个使用 lock 实现同步访问共享资源的示例:
 

using System;
using System.Threading;public class Program
{private static object lockObj = new object();private static int counter = 0;public static void Main(){Thread thread1 = new Thread(IncrementCounter);Thread thread2 = new Thread(IncrementCounter);thread1.Start();thread2.Start();thread1.Join();thread2.Join();Console.WriteLine("Final counter value: " + counter);}public static void IncrementCounter(){for (int i = 0; i < 100000; i++){lock (lockObj){counter++;}}}
}

 以上示例创建了两个线程来同时递增一个共享计数器变量。为了确保线程安全,我们使用 lock 语句将对共享资源的访问限制在一次只有一个线程进行。最终输出的计数器值应该是 200,000。

回滚

回滚是指撤销或取消已经执行的操作以返回到先前的状态。在 C# 中,你可以使用事务 (Transaction) 来实现回滚操作。事务允许你将多个相关操作包装在一起,并要么全部成功,要么全部失败。如果发生失败,可以回滚整个事务以恢复到初始状态。

以下是一个使用 TransactionScope 的回滚示例:
 

using System;
using System.Transactions;public class Program
{public static void Main(){using (var scope = new TransactionScope()){try{// 执行一些数据库操作或其他事务性操作// 提交事务scope.Complete();}catch (Exception ex){// 回滚事务Console.WriteLine("An error occurred: " + ex.Message);}}}
}

在以上示例中,我们使用 TransactionScope 来创建一个新的事务范围。在事务范围内执行的操作将受到该事务的管理。如果出现异常或未调用 scope.Complete(),事务将自动回滚。 

并行编程

并行编程是指同时执行多个任务以提高程序性能的编程范例。在 C# 中,你可以使用 TaskParallel 类来实现并行编程。以下是一个使用 Parallel.ForEach 进行并行迭代的示例:
 

using System;
using System.Threading.Tasks;public class Program
{public static void Main(){int[] numbers = { 1, 2, 3, 4, 5 };Parallel.ForEach(numbers, number =>{Console.WriteLine("Processing number: " + number);// 执行一些操作});}
}

以上示例使用 Parallel.ForEach 方法在多个线程中并行迭代给定的集合。每个数字都被发送到不同的线程进行处理,从而加快整体处理速度。 

异步编程

异步编程允许在等待某些长时间运行的操作完成时释放主线程,以避免阻塞用户界面或其他任务。在 C# 中,你可以使用 asyncawait 关键字来实现异步编程。以下是一个异步方法的示例:
 

using System;
using System.Net.Http;
using System.Threading.Tasks;public class Program
{public static async Task Main(){await DoSomethingAsync();}public static async Task DoSomethingAsync(){HttpClient httpClient = new HttpClient();string result = await httpClient.GetStringAsync("https://www.example.com");Console.WriteLine(result);}
}

以上示例中的 DoSomethingAsync 方法执行了一个 HTTP 请求,并在等待请求完成时释放主线程。这样可以确保应用程序在请求期间仍然响应其他操作。 

反射

反射是一种在运行时检查和修改类型、对象和成员信息的能力。在 C# 中,你可以使用 System.Reflection 命名空间中的类来实现反射。以下是一个使用反射获取和调用方法的示例:
 

using System;
using System.Reflection;public class Program
{public static void Main(){Type type = typeof(MyClass);// 获取方法信息MethodInfo methodInfo = type.GetMethod("MyMethod");// 创建实例object instance = Activator.CreateInstance(type);// 调用方法methodInfo.Invoke(instance, null);}
}public class MyClass
{public void MyMethod(){Console.WriteLine("Hello from MyMethod!");}
}

以上示例使用反射获取了 MyClass 类的 MyMethod 方法的信息,并通过反射调用该方法。这使得我们可以在运行时动态地发现和调用类型和成员。 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/626388.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Vue中的全局组件与局部组件

聚沙成塔每天进步一点点 本文内容 ⭐ 专栏简介1. 全局组件的原理2. 局部组件的原理3. 组件注册的影响与考虑因素全局组件的使用场景&#xff1a;局部组件的使用场景&#xff1a; 4. 组合使用全局组件与局部组件 ⭐ 写在最后 ⭐ 专栏简介 Vue学习之旅的奇妙世界 欢迎大家来到 Vu…

个人网站制作 Part 6 添加高级特性(页面动画、服务端集成) | Web开发项目

文章目录 &#x1f469;‍&#x1f4bb; 基础Web开发练手项目系列&#xff1a;个人网站制作&#x1f680; 添加页面动画&#x1f528;使用CSS动画&#x1f527;步骤 1: 添加动画效果 &#x1f528;使用JavaScript实现动画&#x1f527;步骤 2: 使用JavaScript添加动画 &#x1…

笔记本电脑如何连接显示屏?

目录 1.按下快捷键 winP,选择扩展 2.连接显示器&#xff0c;连好接线 3.笔记本驱动有问题&#xff0c;显示错误如下&#xff1a; 4.驱动已经下载完成&#xff0c; 按下快捷键&#xff0c;还是显示第3步中的错误 5.驱动已经下载完成&#xff0c; 按下快捷键&#xff0c;参照…

步进电机基本原理详解

步进电机基本原理 步进电机是一种将电脉冲信号转换成相应角位移或线位移的电动机。 区别于以电压或电流作为控制信号&#xff0c;被控制量是转速的电动机。 每输入一个脉冲信号&#xff0c;转子就转动一个角度或前进一步&#xff0c;其输出的角位移或线位移与输入的脉冲数成正…

C++(9.5)——浅谈new和delete的实现原理

(注:本文是针对上篇文章中C内存管理的两个关键字)两个关键字原理的解析&#xff0c;对于这两个关键字的使用并没有什么影响&#xff0c;如果只想得知两个关键字的使用方法&#xff0c;则可以直接跳过本篇文章&#xff09; 目录 1. 引入&#xff1a; 2.operator new 与 operat…

实战 php 使用 wkhtmltopdf 生成pdf的全过程

公司里边有生成pdf报告的业务需求,之前有过尝试用tcpdf,直接生成的pdf的过程,但是pdf报告的内容数据,根据不同内容的变化,都是各种各样的bug,一直处理修修补补的状态,让后台开发人员很是头疼. 经过思索和甄选,总结出我们的业务中是由于样式不可控导致的,当时从逻辑上就思考到用…

医院如何选择高效的内外网数据交换方案 替代U盘进行跨网传输?

医院信息网络是所有网络中安全性要求较高的网络之一&#xff0c;因此很多医院基于信息安全相关要求&#xff0c;会使用防火墙将网络隔离成内网和外网。内网用于日常医疗信息交换&#xff0c;外网可以及时获取Internet信息资源。但是网络隔离后&#xff0c;医院仍存在将报告资料…

原子类-数组类型原子类

数组类型原子类 AtomicIntegerArray:整型数组原子类 AtomicLongrArray:长整型数组原子类 AtomicReferenceArray:用类型数组原子类 常用API简介 数组类型原子类常用API简介 public final int get(int i) //获取 index=i 位置元素的值 public final int getAndSet(int i, in…

[数据集][目标检测]茶叶病害数据集VOC+YOLO格式883张8类别

数据集格式&#xff1a;Pascal VOC格式YOLO格式(不包含分割路径的txt文件&#xff0c;仅仅包含jpg图片以及对应的VOC格式xml文件和yolo格式txt文件) 图片数量(jpg文件个数)&#xff1a;883 标注数量(xml文件个数)&#xff1a;883 标注数量(txt文件个数)&#xff1a;883 标注类别…

哪些药物可能对发作性睡病有帮助?

发作性睡病是一种慢性睡眠障碍&#xff0c;其症状包括不可抗拒的短期睡眠发作、猝倒、睡眠麻痹和睡眠幻觉等。治疗发作性睡病的方法包括药物治疗和非药物治疗&#xff0c;其中药物治疗是重要的手段之一。 目前治疗发作性睡病的药物主要包括中枢兴奋剂、抗抑郁药和镇静催眠药等…

【NI国产替代】PXI-6254,32 AI(16位,1 MS/s),48 DIO,PXI多功能I/O模块

32 AI&#xff08;16位&#xff0c;1 MS/s&#xff09;&#xff0c;48 DIO&#xff0c;PXI多功能I/O模块 PXI-6254提供模拟输入、关联数字I/O、两个32位计数器/定时器以及模拟和数字触发。该设备为从实验室自动化、研究、设计验证/测试到制造测试等各种应用提供了低成本的可靠D…

Mybatis基础---------增删查改

增删改 1、新建工具类用来获取会话对象 import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.ibatis.session.SqlSessionFactoryBuilder; import org.apache.ibatis.io.Resources;import java.io.IOExcept…

Java运算符作用及解析

Java运算符是对变量或者常量进行操作的符号。以下是Java中常见运算符的解析&#xff1a; 赋值运算符&#xff1a;如“”&#xff0c;将右侧的值赋给左侧的变量。一元运算符&#xff1a;如“”“-”“!”&#xff0c;用于对变量进行操作。算术运算符&#xff1a;如“”“-”“*…

典型场景解析|PolarDB分布式版如何支撑SaaS多租户?

SaaS多租户背景 很多平台类应用或系统&#xff08;如电商CRM平台、仓库订单平台等等&#xff09;&#xff0c;它们的服务模型是围绕用户维度&#xff08;这里的用户维度可以是一个卖家或品牌&#xff0c;可以是一个仓库等&#xff09;展开的。因此&#xff0c;这类型的平台业务…

【原创】docker +宝塔+安装zabbix

Zabbix: Zabbix可以监控各种网络服务、服务器和网络设备&#xff0c;而无需在目标设备上安装客户端。它的强大之处在于自带的Web界面&#xff0c;能够提供实时监控和各种报警功能。方法1&#xff1a; 步骤 创建Docker Compose文件: 首先&#xff0c;你需要创建一个docker-comp…

C技能树-学习笔记(1-2)C语言概述和数据类型

参考&#xff1a;https://edu.csdn.net/skill/c 1、输出 “Hello, World!” 字符串&#xff0c;请选出错误答案。 2、错误的print函数。 for … in …&#xff1a;是python的语法&#xff0c;C语言的写法是for (;&#x1f609; 3、C标准 没有C19标准。 4、了解C编译管道 …

AI嵌入式K210项目(4)-FPIOA

文章目录 前言一、FPIOA是什么&#xff1f;二、FPIOA代码分析总结 前言 磨刀不误砍柴工&#xff0c;在正式开始学习之前&#xff0c;我们先来了解下K210自带的FPIOA&#xff0c;这个概念可能与我们之前学习STM32有很多不同&#xff0c;STM32每个引脚都有特定的功能&#xff0c…

嵌入式培训机构四个月实训课程笔记(完整版)-C++和QT编程第三天-C++类和对象高级应用(物联技术666)

链接:https://pan.baidu.com/s/1YRXI0WiABUlYaQXQDNfbyA?pwd=1688 提取码:1688 上午:类和对象高级应用(续) 下午:派生和继承 教学内容: 1、友元 类的私有成员只能在类定义的范围内使用,也就是说私有成员只能通过它的成员函数来访问但是,有时候需要在类的外部访问…

关于前端面试中forEach方法的灵魂7问?

目录 前言 一、forEach方法支持处理异步函数吗&#xff1f; 二、forEach方法在循环过程中能中断吗&#xff1f; 三、forEach 在删除自己的元素后能重置索引吗&#xff1f; 四、forEach 的性能相比for循环哪个好&#xff1f; 五、使用 forEach 会不会改变原来的数组&#…

xshell:关于ssh用户身份验证不能选择password的解决方法

接下来我将告诉大家如何进行修改让其能够进行密码登录 我使用的软件是VM VirtualBox管理器 进行用户名密码登录后 输入 cd /etc/ 切换到etc目录下 cd /etc/ 切换到etc目录后输入ls ls 切换到ssh目录下 cd ssh 进入文件 sshd_config vi sshd_config 找到指定部分进行修改 如何…