Winform中使用Reactivex代替BeginInvoke/Invoke来更新UI数据

  1 public partial class ZSerialportForm : Form
  2 {
  3     private SerialPort sp;
  4     private byte[] buffer = new byte[1024];
  5     // 定义ReactiveX对象
  6     private IScheduler scheduler = new DispatcherScheduler(Dispatcher.CurrentDispatcher);
  7     public ZSerialportForm()
  8     {
  9         InitializeComponent();
 10     }
 11 
 12     private void ZSerialportForm_Load(object sender, EventArgs e)
 13     {
 14         cbb_serials.Items.AddRange(SerialPort.GetPortNames());
 15         if (cbb_serials.Items.Count > 0)
 16             cbb_serials.SelectedIndex = 0;
 17 
 18         btn_send.Enabled = false;
 19     }
 20 
 21     public static string GetHexStr(T[] data, int len = -1, string separator = " ")
 22         where T : IComparable, IFormattable, IConvertible, IComparable, IEquatable 23     {
 24         string hex = "";
 25         int upper = data.Length;
 26         if (len != -1) upper = len;
 27         for (int i = 0; i )
 28         {
 29             hex += data[i].ToString("x2", new NumberFormatInfo());
 30             hex += separator;
 31         }
 32 
 33         hex = hex.TrimEnd(separator.ToCharArray());
 34         return hex;
 35     }
 36 
 37     /// 

 38     /// 打开串口
 39     /// 
 40     private void btn_open_Click(object sender, EventArgs e)
 41     {
 42         if (btn_open.Text == "打开")
 43         {
 44             sp = new SerialPort(cbb_serials.Text, 9600);
 45             sp.ReceivedBytesThreshold = 1;
 46             sp.DataReceived += OnDataReceived;
 47             //sp.WriteTimeout = 50;
 48             //sp.ReadTimeout = 50;
 49             sp.Open();
 50             sp.DiscardInBuffer();
 51             sp.DiscardOutBuffer();
 52             btn_send.Enabled = true;
 53             btn_open.Text = "关闭";
 54         }
 55         else if (btn_open.Text == "关闭")
 56         {
 57             sp.Close();
 58             sp = null;
 59             btn_send.Enabled = false;
 60             btn_open.Text = "打开";
 61         }
 62     }
 63 
 64     /// 

 65     /// 读取串口
 66     /// 
 67     private void OnDataReceived(object sender, SerialDataReceivedEventArgs e)
 68     {
 69         if (e.EventType == SerialData.Chars)
 70         {
 71             int len = sp.Read(buffer, 0, sp.BytesToRead);
 72             string hex = GetHexStr(buffer, len);
 73             // 使用ReactiveX的方式更新UI数据
 74             scheduler.Schedule(() =>
 75             {
 76                 lb_read.Items.Add(hex);
 77                 lb_read.SetSelected(lb_read.Items.Count - 1, true);
 78             });
 79         }
 80     }
 81 
 82     /// 

 83     /// 发送数据
 84     /// 
 85     private void btn_send_Click(object sender, EventArgs e)
 86     {
 87         string[] strs = tb_send.Text.Split(‘ ‘);
 88         byte[] hexs = new byte[strs.Length];
 89         for (int i = 0; i )
 90         {
 91             hexs[i] = Byte.Parse(strs[i], NumberStyles.AllowHexSpecifier);
 92         }
 93 
 94         try
 95         {
 96             sp.Write(hexs, 0, hexs.Length);
 97         }
 98         catch (Exception exception)
 99         {
100             Console.WriteLine(exception);
101             throw;
102         }
103     }
104 
105     private void ZSerialportForm_FormClosed(object sender, FormClosedEventArgs e)
106     {
107         if (sp != null)
108             sp.Close();
109     }
110 }