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

基于C#和周立功USBCAN设备的完整上位机开发示例

news 2026/3/27 3:05:09

一、环境配置

驱动安装
- 下载安装ZLG官方驱动（需区分x86/x64）
- 确保zlgcan.dll位于应用程序目录或系统PATH

NuGet依赖

dotnet add package CanKit.Core
dotnet add package CanKit.Adapter.ZLG

二、核心代码实现

1. 设备管理类（DeviceManager.cs）

using CanKit.Core;
using CanKit.Core.Definitions;
using CanKit.Adapter.ZLG;
using System;
using System.Threading.Tasks;public class DeviceManager : IDisposable
{private ICanBus _bus;private readonly string _deviceId = "zlg://ZCAN_USBCANFD_200U?index=0#ch0";private const int BaudRate = 500_000; // 500kbpspublic event Action<CanFrame> FrameReceived;public event Action<string> StatusChanged;public async Task ConnectAsync(){try{_bus = await CanBus.OpenAsync(_deviceId, cfg => cfg.TimingClassic(BaudRate).EnableErrorInfo().SetAsyncBufferCapacity(512));_bus.FrameReceived += OnFrameReceived;StatusChanged?.Invoke("设备已连接");}catch (Exception ex){HandleError($"连接失败: {ex.Message}");}}private void OnFrameReceived(object sender, CanFrameReceivedEventArgs e){FrameReceived?.Invoke(e.Frame);}public async Task SendTestFrameAsync(){var frame = new CanClassicFrame(id: 0x123,data: new byte[] { 0x11, 0x22, 0x33, 0x44, 0x55, 0x66, 0x77, 0x88 },timestamp: DateTimeOffset.Now.ToUnixTimeMilliseconds());await _bus.TransmitAsync(frame);}public void Disconnect(){_bus?.Close();StatusChanged?.Invoke("设备已断开");}private void HandleError(string message){StatusChanged?.Invoke($"错误: {message}");// 记录日志到文件File.AppendAllText("error.log", $"{DateTime.Now}: {message}\n");}public void Dispose(){_bus?.Dispose();}
}

三、用户界面实现（WPF示例）

1. 主窗口XAML

<Window x:Class="USBCANApp.MainWindow"xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"Title="USBCAN上位机" Height="600" Width="1200"><DockPanel><!-- 状态栏 --><StatusBar DockPanel.Dock="Bottom"><TextBlock Text="{Binding Status}" Margin="5"/></StatusBar><!-- 数据监控区 --><TabControl><TabItem Header="实时数据"><DataGrid AutoGenerateColumns="False" ItemsSource="{Binding Frames}"><DataGrid.Columns><DataGridTextColumn Header="时间戳" Binding="{Binding Timestamp}"/><DataGridTextColumn Header="ID" Binding="{Binding Id:X}"/><DataGridTextColumn Header="数据" Binding="{Binding Data}"/></DataGrid.Columns></DataGrid></TabItem></TabControl><!-- 控制面板 --><StackPanel Orientation="Horizontal" VerticalAlignment="Top" DockPanel.Dock="Top"><Button Content="连接设备" Command="{Binding ConnectCommand}"/><Button Content="发送测试帧" Command="{Binding SendTestCommand}"/><Button Content="断开连接" Command="{Binding DisconnectCommand}"/></StackPanel></DockPanel>
</Window>

2. ViewModel实现

using System.Collections.ObjectModel;
using System.ComponentModel;
using System.Runtime.CompilerServices;public class MainViewModel : INotifyPropertyChanged
{private readonly DeviceManager _deviceManager = new DeviceManager();public ObservableCollection<CanFrame> Frames { get; } = new();public string Status { get; private set; } = "未连接";public ICommand ConnectCommand => new RelayCommand(async () => await ConnectAsync());public ICommand SendTestCommand => new RelayCommand(async () => await SendTestAsync());public ICommand DisconnectCommand => new RelayCommand(() => Disconnect());public MainViewModel(){_deviceManager.FrameReceived += OnFrameReceived;_deviceManager.StatusChanged += OnStatusChanged;}private async Task ConnectAsync(){await _deviceManager.ConnectAsync();Status = "已连接";}private async Task SendTestAsync(){await _deviceManager.SendTestFrameAsync();}private void Disconnect(){_deviceManager.Disconnect();Status = "已断开";}private void OnFrameReceived(CanFrame frame){Frames.Add(frame);}private void OnStatusChanged(string status){Status = status;}public event PropertyChangedEventHandler PropertyChanged;protected void OnPropertyChanged([CallerMemberName] string? propertyName = null){PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(propertyName));}
}

四、关键功能扩展

1. CAN FD支持

// 修改连接配置
var config = new ZCANChannelConfig
{canfd = new ZCAN_FDConfig{mode = ZCAN_FDMode.FD,nominal_bitrate = 5_000_000, // 5Mbpsdata_bitrate = 20_000_000    // 20Mbps}
};
await _bus.OpenAsync(_deviceId, config);

2. 数据滤波配置

// 添加范围滤波
_config.RangeFilter = new RangeFilter
{StartId = 0x100,EndId = 0x1FF,FilterType = FilterType.Standard
};// 或使用掩码滤波
_config.MaskFilter = new MaskFilter
{Acr = 0x18FF50E5,Amr = 0x1FFFFF00
};

3. 周期发送任务

var periodicTask = _bus.SchedulePeriodic(new CanClassicFrame(0x321, new byte[] { 0xAA, 0x55 }),interval: TimeSpan.FromMilliseconds(100)
);// 停止周期任务
periodicTask.Stop();

五、错误处理机制

1. 异常捕获

try
{await _bus.TransmitAsync(frame);
}
catch (CanTimeoutException ex)
{LogError($"发送超时: {ex.Message}");
}
catch (CanProtocolException ex)
{LogError($"协议错误: {ex.Message}");
}

2. 错误帧订阅

_bus.ErrorFrameReceived += (sender, error) =>
{var errorInfo = new StringBuilder();errorInfo.AppendLine($"错误码: 0x{error.ErrorInfo.ErrorFlag:X4}");errorInfo.AppendLine($"错误类型: {error.ErrorInfo.ErrorType}");errorInfo.AppendLine($"时间戳: {error.Timestamp}");File.AppendAllText("can_errors.log", errorInfo.ToString());
};

六、性能优化

双缓冲队列

private ConcurrentQueue<CanFrame> _buffer = new();// 接收线程
Task.Run(() => 
{while (true){var frame = _bus.Receive();_buffer.Enqueue(frame);}
});

硬件加速

_bus.SetHardwareFilter(new HardwareFilter
{FilterType = FilterType.Standard,StartId = 0x100,EndId = 0x1FF
});

七、部署与测试

1. 安装包配置

<!-- Inno Setup脚本 -->
[Files]
Source: "USBCANApp.exe"; DestDir: "{app}"; Flags: ignoreversion
Source: "zlgcan.dll"; DestDir: "{app}"; Flags: ignoreversion
Source: "error.log"; DestDir: "{app}"; Flags: ignoreversion[Icons]
Name: "{group}\USBCAN监控"; Filename: "{app}\USBCANApp.exe"

2. 压力测试

// 模拟高负载测试
Parallel.For(0, 1000, i =>
{var task = _bus.TransmitAsync(new CanClassicFrame(id: 0x200, data: new byte[8] { 0xAA, 0x55, 0xAA, 0x55, 0xAA, 0x55, 0xAA, 0x55 }));
});

参考代码基于C#的周立功USBCAN上位机程序例程 www.youwenfan.com/contentcnr/112207.html