在多线程横行的今天,你是否还在为集合的线程安全问题而头疼?是否因为意外修改了共享数据而导致程序崩溃?今天我们来聊聊C#中一个被严重低估的"神器"——不可变集合(Immutable Collections),它能够从根本上解决这些痛点,让你的代码既安全又优雅。
c#// 传统做法:需要手动加锁
private static readonly object _lock = new object();
private static List<string> _sharedList = new List<string>();
public void AddItem(string item)
{
lock (_lock) // 每次操作都要加锁,性能开销大
{
_sharedList.Add(item);
}
}
c#public List<Product> GetProducts()
{
return _products; // 危险!外部可能会修改这个集合
}
// 调用方可能无意中修改了数据
var products = service.GetProducts();
products.Clear(); // 糟糕!原始数据被清空了
c#public List<Product> GetProducts()
{
return new List<Product>(_products); // 每次都要复制,内存浪费
}
说实话,我第一次在WPF项目里用ScottPlot的时候,差点把键盘砸了。明明官方Demo跑得好好的,一套进MVVM架构,各种问题就冒出来了:数据更新图表不刷新、UI线程卡死、内存泄漏... 后来在一个工业数据监控项目中,需要同时展示8个实时曲线图,这问题更严重了——CPU占用飙到80%,界面卡成PPT。
经过三个迭代版本的重构,我终于摸索出一套完全符合MVVM原则的ScottPlot使用方案。数据来得实在:重构后CPU占用降到15%以内,内存泄漏问题彻底消失,代码可测试性提升300%(单元测试覆盖率从0%到70%)。
读完这篇文章,你将掌握:
咱们直接开干!
ScottPlot本质上是个命令式绘图库,你得手动调Plot. Add. Scatter()、Plot.Refresh()这些方法。但MVVM强调的是声明式数据绑定——ViewModel里数据一变,View自动更新。这就像让一个习惯发号施令的将军去适应民主投票制度,天然有冲突。
我见过最常见的三种错误做法:
错误1:在ViewModel里直接操作WpfPlot控件
csharp// ❌ 这样做彻底违背了MVVM原则
public class BadViewModel
{
public WpfPlot MyPlot { get; set; } // 直接暴露UI控件
public void UpdateData()
{
MyPlot.Plot.Clear(); // ViewModel依赖View层
MyPlot.Plot. Add. Scatter(xData, yData);
MyPlot. Refresh();
}
}
这种写法的问题是ViewModel根本无法单元测试,而且View和ViewModel强耦合,换个UI框架就全废了。
错误2:在后台线程直接刷新图表
csharp// ❌ 跨线程操作UI会抛异常
Task.Run(() => {
wpfPlot. Refresh(); // System.InvalidOperationException
});
错误3:每次数据更新都重建整个图表
csharp// ❌ 性能杀手
private void OnDataChanged()
{
Plot.Clear();
Plot.Add.Scatter(allData); // 10万个点每次都重新添加
Plot.Refresh();
}
在我那个工业监控项目里,这种写法导致刷新一次耗时200ms+,1秒更新5次直接卡成幻灯片。
在正式给方案之前,咱们先理清几个关键点:
Behavior或附加属性做桥梁(推荐前者)新版本的DataSource系统虽然强大,但有个坑:如果你用ObservableCollection直接绑定,每次Add/Remove都会触发全量重绘。正确做法是用ScottPlot.DataSources. ScatterSourceDoubleArray,然后手动控制刷新时机。
DataSource必须在UI线程(或用锁保护)Refresh()调用必须在UI线程在现代应用开发中,高并发和高可用性是客户最为关注的性能指标。而Redis,作为一种优秀的内存数据库,凭借其卓越的性能优势与数据结构,成为了许多开发者的得力助手。然而,很多开发者在使用Redis的过程中,由于缺乏深入的理解,常常会陷入性能瓶颈和数据一致性的问题中。 本文将深入剖析如何在C#开发中高效使用Redis,提升你应用的性能与稳定性。
在开发过程中,尤其是面对用户请求激增时,后端数据库的响应速度往往成为了性能瓶颈。传统的关系型数据库在处理大量读写请求时,容易导致慢查询和锁竞争,这时Redis的引入便显得尤为重要。然而,许多开发者在使用Redis时,常常面临以下几个痛点:
针对以上问题,我们可以采取以下解决方案:
下面是一个完整的C# Redis使用示例,展示如何实现一个简单的Redis服务,以解决上述提到的问题。
c#using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace AppRedisService
{
/// <summary>
/// Redis缓存服务接口
/// </summary>
public interface IRedisService : IDisposable
{
/// <summary>
/// 连接状态
/// </summary>
bool IsConnected { get; }
// 字符串操作
Task<T?> GetAsync<T>(string key, CancellationToken cancellationToken = default) where T : class;
Task<string?> GetStringAsync(string key, CancellationToken cancellationToken = default);
Task<bool> SetAsync<T>(string key, T value, TimeSpan? expiry = null, CancellationToken cancellationToken = default);
Task<bool> SetStringAsync(string key, string value, TimeSpan? expiry = null, CancellationToken cancellationToken = default);
// 哈希操作
Task<T?> HashGetAsync<T>(string hashKey, string field, CancellationToken cancellationToken = default) where T : class;
Task<bool> HashSetAsync<T>(string hashKey, string field, T value, CancellationToken cancellationToken = default);
Task<Dictionary<string, T>> HashGetAllAsync<T>(string hashKey, CancellationToken cancellationToken = default) where T : class;
Task<bool> HashDeleteAsync(string hashKey, string field, CancellationToken cancellationToken = default);
// 列表操作
Task<long> ListPushAsync<T>(string key, T value, CancellationToken cancellationToken = default);
Task<T?> ListPopAsync<T>(string key, CancellationToken cancellationToken = default) where T : class;
Task<List<T>> ListRangeAsync<T>(string key, long start = 0, long stop = -1, CancellationToken cancellationToken = default) where T : class;
// 集合操作
Task<bool> SetAddAsync<T>(string key, T value, CancellationToken cancellationToken = default);
Task<bool> SetRemoveAsync<T>(string key, T value, CancellationToken cancellationToken = default);
Task<List<T>> SetMembersAsync<T>(string key, CancellationToken cancellationToken = default) where T : class;
Task<bool> SetContainsAsync<T>(string key, T value, CancellationToken cancellationToken = default);
// 通用操作
Task<bool> KeyExistsAsync(string key, CancellationToken cancellationToken = default);
Task<bool> KeyDeleteAsync(string key, CancellationToken cancellationToken = default);
Task<long> KeyDeleteAsync(IEnumerable<string> keys, CancellationToken cancellationToken = default);
Task<bool> KeyExpireAsync(string key, TimeSpan expiry, CancellationToken cancellationToken = default);
Task<TimeSpan?> KeyTimeToLiveAsync(string key, CancellationToken cancellationToken = default);
// 发布订阅
Task<long> PublishAsync<T>(string channel, T message, CancellationToken cancellationToken = default);
Task SubscribeAsync<T>(string channel, Func<string, T, Task> handler, CancellationToken cancellationToken = default) where T : class;
Task UnsubscribeAsync(string channel, CancellationToken cancellationToken = default);
// 事务操作
Task<bool> ExecuteTransactionAsync(Func<ITransaction, Task> operations, CancellationToken cancellationToken = default);
// 锁操作
Task<IDisposable?> AcquireLockAsync(string lockKey, TimeSpan expiry, CancellationToken cancellationToken = default);
}
}
说实话,我见过太多WinForm项目写着写着就变成了"意大利面条"——按钮点击事件里塞了几百行代码,窗体之间互相调用乱成一团,改一个小功能牵一发动全身。
前阵子接手一个老项目维护,光是一个btnSave_Click事件就写了800多行,里面又是数据校验、又是业务逻辑、还夹杂着UI更新。每次改需求都像在拆炸弹,小心翼翼生怕哪根线接错了。
这篇文章能帮你解决什么?
咱们开始吧。
很多开发者习惯把所有逻辑都塞进事件处理器:
csharpprivate void btnSubmit_Click(object sender, EventArgs e)
{
// 数据校验(50行)
// 业务计算(100行)
// 数据库操作(80行)
// UI状态更新(30行)
// 日志记录��20行)
// ... 还在继续
}
我统计过一个真实项目:单个事件处理器平均代码行数达到了247行,最长的一个居然有1200行。这种代码,测试怎么写?复用怎么搞?新人接手直接崩溃。
窗体A要通知窗体B更新数据,最常见的做法:
csharp// 在FormA中直接操作FormB
FormB formB = Application.OpenForms["FormB"] as FormB;
if (formB != null)
{
formB.RefreshData(); // 直接调用FormB的方法
formB.lblStatus.Text = "已更新"; // 甚至直接操作控件!
}
这种写法的问题在于:FormA必须知道FormB的存在,知道它有哪些方法、哪些控件。一旦FormB重��,FormA也得跟着改。耦合度高到离谱。
这是个隐藏很深的坑。事件订阅如果不取消,会导致对象无法被垃圾回收:
csharppublic class DataService
{
public event EventHandler DataChanged;
}
public partial class ChildForm : Form
{
private DataService _service;
public ChildForm(DataService service)
{
_service = service;
_service.DataChanged += OnDataChanged; // 订阅了
// 窗体关闭时忘记取消订阅...
}
}
我用内存分析工具检测过一个项目,因为事件未取消订阅导致的内存泄漏高达127MB,用户反馈程序用久了就变卡,根源就在这儿。
在工业4.0浪潮中,设备数据采集成为每个工厂数字化转型的必经之路。传统的数据采集方式往往需要复杂的配置和昂贵的软件授权,让众多开发者望而却步。今天,我将手把手教你用C#构建一个功能完整的OPC UA客户端,不仅能够实时读取设备数据,还支持树形节点浏览和数据写入。无论你是工控新手还是资深开发者,这套解决方案都将大大提升你的开发效率!
传统的OPC UA客户端往往采用一次性加载所有节点的方式,面对成千上万个数据点时,界面卡顿不可避免。用户体验极差,开发者也头疼。
工业现场的数据点有些只能读取,有些可以写入。如果客户端不能清晰区分,很容易造成误操作,严重时可能影响生产安全。
传统的表格式浏览方式对于层级复杂的设备数据结构来说,导航困难,查找效率极低。
我们的解决方案采用TreeView + DataGridView的双面板设计:
c#using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace AppOpcUaClient
{
// 节点信息类
public class OpcNodeInfo
{
public string NodeId { get; set; }
public string DisplayName { get; set; }
public string Value { get; set; }
public string DataType { get; set; }
public string Quality { get; set; }
public string Timestamp { get; set; }
public bool IsWritable { get; set; }
}
public class OpcTreeNodeInfo
{
public string NodeId { get; set; }
public Opc.Ua.NodeClass NodeClass { get; set; }
public bool IsLoaded { get; set; }
}
}