Winform中使用Websocket4Net实现Websocket客户端并定时存储接收数据到SQLite中

场景

SpringBoot+Vue整合WebSocket实现前后端消息推送：

SpringBoot+Vue整合WebSocket实现前后端消息推送_websocket vue3.0 springboot 往客户端推送-CSDN博客

上面实现ws推送数据流程后，需要在windows上使用ws客户端定时记录收到的数据到文件中，这里

文件使用SQLite数据库进行存储。

Winform中操作Sqlite数据增删改查、程序启动时执行创建表初始化操作：

Winform中操作Sqlite数据增删改查、程序启动时执行创建表初始化操作_winform sqllite-CSDN博客

Sqlite的操作参考如上。

注：

博客：
霸道流氓气质_C#,架构之路,SpringBoot-CSDN博客

实现

1、引入WebSocket4Net依赖

使用Nuget搜索并安装WebSocket4Net

2、设计页面布局如下

3、websocket客户端实现

声明客户端对象

public static WebSocket4Net.WebSocket webSocket4NetClient = null;

ws连接按钮的点击事件中

            try {var wsAddresss = textBox_ws_address.Text.Trim();webSocket4NetClient = new WebSocket4Net.WebSocket(wsAddresss);webSocket4NetClient.Opened += WebSocket4Net_Opened;webSocket4NetClient.Error += Websocket_Error;webSocket4NetClient.Closed += new EventHandler(Websocket_Closed);webSocket4NetClient.MessageReceived += WebSocket4Net_MessageReceived;webSocket4NetClient.Open();textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":ws开始连接");textBox_log.AppendText("\r\n");} catch (Exception exception) {textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":ws连接异常:"+ exception.Message);textBox_log.AppendText("\r\n");}

这里未添加对ws地址的校验，只关注中间ws相关的代码

                webSocket4NetClient = new WebSocket4Net.WebSocket(wsAddresss);webSocket4NetClient.Opened += WebSocket4Net_Opened;webSocket4NetClient.Error += Websocket_Error;webSocket4NetClient.Closed += new EventHandler(Websocket_Closed);webSocket4NetClient.MessageReceived += WebSocket4Net_MessageReceived;webSocket4NetClient.Open();

然后编写其各种事件的具体实现。

实现方法中具体逻辑根据业务进行确定。

建立连接事件实现

        private void WebSocket4Net_Opened(object sender, EventArgs e){//允许跨线程调用Control.CheckForIllegalCrossThreadCalls = false;textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":ws建立连接成功");textBox_log.AppendText("\r\n");//向服务端发送消息//webSocket4NetClient.Send("Client准备发送数据！");}

收到消息事件实现

        private void WebSocket4Net_MessageReceived(object sender, MessageReceivedEventArgs e){//允许跨线程调用Control.CheckForIllegalCrossThreadCalls = false;//textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":收到消息:");//textBox_log.AppendText("\r\n");receviceString = e.Message;}

出错事件实现

        private void Websocket_Error(object sender, EventArgs e){//允许跨线程调用Control.CheckForIllegalCrossThreadCalls = false;textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":Websocket_Error:"+e);textBox_log.AppendText("\r\n");}

连接关闭事件实现

        private void Websocket_Closed(object sender, EventArgs e){//允许跨线程调用Control.CheckForIllegalCrossThreadCalls = false;textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":Websocket_Closed");textBox_log.AppendText("\r\n");}

ws连接关闭按钮点击实现

        private void button_ws_disconnec_Click(object sender, EventArgs e){webSocket4NetClient.Close();}

4、定时存储实现

在上面收到消息时将数据赋值给变量

receviceString

声明变量

private string receviceString = String.Empty;

添加Timer定时器

Timer _timer = new Timer();

定时存储按钮点击事件实现

        private void button_start_store_Click(object sender, EventArgs e){if (webSocket4NetClient.State != WebSocket4Net.WebSocketState.Open && webSocket4NetClient.State != WebSocket4Net.WebSocketState.Connecting){textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":Websocket连接异常");textBox_log.AppendText("\r\n");}else {//清空数据库SQLiteDataReader reader = Global.Instance.sqlLiteHelper.ExecuteQuery("SELECT* FROM positions;");if (reader.HasRows){while (reader.Read()){Global.Instance.sqlLiteHelper.ExecuteQuery("DELETE FROM positions WHERE timestamp = " + reader.GetString(reader.GetOrdinal("timestamp")) + ";");}}_timer.Interval = (int)numericUpDown_rate.Value;_timer.Tick += _timer_Tick;_timer.Start();textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":定时存储已经启动!!");textBox_log.AppendText("\r\n");}}

首先判断ws是否连接上，如果连接上则将库清空，然后获取设置的定时频率并启动定时器

定时器具体实现

        private void _timer_Tick(object sender, EventArgs e) {try{if (webSocket4NetClient.State != WebSocket4Net.WebSocketState.Open && webSocket4NetClient.State != WebSocket4Net.WebSocketState.Connecting){textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":Websocket连接异常");textBox_log.AppendText("\r\n");}else {if (!String.IsNullOrEmpty(receviceString)){//获取ws数据并存储进数据库TimeSpan ts = DateTime.Now.ToUniversalTime() - new DateTime(1970, 1, 1, 0, 0, 0, 0, DateTimeKind.Utc);string timeSpan = Convert.ToInt64(ts.TotalSeconds).ToString();//插入数据Global.Instance.sqlLiteHelper.InsertValues("positions", new string[] { timeSpan, receviceString });receviceString = String.Empty;}}}catch (Exception exception){textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":定时存储执行异常：" + exception.Message);textBox_log.AppendText("\r\n");}        }

首页也要判断是否连接，然后判断receviceString是否为空，避免ws未传输数据，会定时存储空数据。

不为空则将时间和收到的数据存储进数据库。

停止定时存储按钮点击事件

        private void button_stop_store_Click(object sender, EventArgs e){//停止定时器_timer.Tick -= _timer_Tick;_timer.Stop();textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":定时存储已经停止!!！");textBox_log.AppendText("\r\n");receviceString = String.Empty;}

5、运行效果

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

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

相关文章

RT_Thread 调试笔记：信号量，互斥量，事件集 的创建和使用流程

RT_Thread 调试笔记：信号量，互斥量，事件集 的创建和使用流程

说明：记录日常使用 RT_Thread 开发时做的笔记。 持续更新中，欢迎收藏。 1. 信号量 1. 使用流程 /* 信号量的定义和使用流程 *//*step1： 定义用于接收消息的信号量*/ static struct rt_semaphore rx_sem; 或者 static rt_sem_t rx_sem;/*…
阅读更多...
vue3 的内置组件汇总

vue3 的内置组件汇总

官方给出的说明： Fragment: Vue 3 组件不再要求有一个唯一的根节点，清除了很多无用的占位 div。Teleport: 允许组件渲染在别的元素内，主要开发弹窗组件的时候特别有用。Suspense: 异步组件，更方便开发有异步请求的组件。 一、fr…
阅读更多...
模仿Activiti工作流自动建表机制，实现Springboot项目启动后自动创建多表关联的数据库与表的方案

模仿Activiti工作流自动建表机制，实现Springboot项目启动后自动创建多表关联的数据库与表的方案

文/朱季谦 熬夜写完，尚有不足，但仍在努力学习与总结中，而您的点赞与关注，是对我最大的鼓励！ 在一些本地化项目开发当中，存在这样一种需求，即开发完成的项目，在第一次部署启动时&…
阅读更多...
基于SpringBoot的个人理财系统

基于SpringBoot的个人理财系统

文章目录 项目介绍主要功能截图部分代码展示设计总结项目获取方式🍅 作者主页：超级无敌暴龙战士塔塔开 🍅 简介：Java领域优质创作者🏆、 简历模板、学习资料、面试题库【关注我，都给你】 🍅文末获取源码联系🍅 项目介绍 基于SpringBoot的个人理财系统,java项目。…
阅读更多...
3C电子制造：智慧物流引领产业升级

3C电子制造：智慧物流引领产业升级

在当今科技飞速发展的时代，3C电子制造行业正面临着一系列挑战和机遇。市场需求的多变和技术革新的加速，使得企业必须不断创新和升级。在这个过程中，智慧物流成为了一个关键的环节，它能够有效地提高生产效率、降低成本并增强企业的…
阅读更多...
Docker学习与应用（二）-docker常用命令

Docker学习与应用（二）-docker常用命令

注：此为笔者学习狂神说Docker的笔记，其中包含个人的笔记和理解，更多详细资讯请出门左拐B站：狂神说!!! Docker的常用命令 帮助命令 docker version # 显示docker的版本信息 docker info # 显示docker的系统信息&am…
阅读更多...
【学习笔记】1、数字逻辑概论

【学习笔记】1、数字逻辑概论

1.1 数字信号 数字信号，在时间和数值上均是离散的。数字信号的表达方式：二值数字逻辑和逻辑电平描述的数字波形。 （1） 数字波形的两种类型 数值信号又称为“二值信号”。数字波形又称为“二值位形图”。 什么是一拍 一定的时…
阅读更多...
新手可理解的PyTorch 损失函数：优化机器学习模型的关键

新手可理解的PyTorch 损失函数：优化机器学习模型的关键

目录 torch.nn子模块Loss Functions详解 nn.L1Loss 用途 用法 使用技巧 注意事项 代码示例 nn.MSELoss 用途 用法 使用技巧 注意事项 代码示例 nn.CrossEntropyLoss 用途 用法 使用技巧 注意事项 代码示例 使用类别索引 使用类别概率 nn.CTCLoss 用途 …
阅读更多...
【Pytorch】学习记录分享13——OCR(Optical Character Recognition,光学字符识别)

【Pytorch】学习记录分享13——OCR(Optical Character Recognition,光学字符识别)

[TOC](OCR(Optical Character Recognition,光学字符识别)) 1. OCR资源汇总 OCR(Optical Character Recognition,光学字符识别)指提取图像中的文字信息，通常包括文本检测和文本识别。 文字检测：将图片中的文字区域位置检测出来（如图1(b)所示…
阅读更多...
Dash+Plotly | Web应用开发(1)

Dash+Plotly | Web应用开发(1)

本文为https://github.com/CNFeffery/DataScienceStudyNotes的学习笔记，部分源码来源于此仓库。 本期内容主要为基础概念、web布局方法和交互回调。 文章目录 Dash的主要模块Highlightlayoutcallback 惰性交互阻止初次回调忽略回调匹配错误控制部分回调输出不更新获…
阅读更多...
【总线接口】1.以Xilinx开发板为例，直观的认识硬件板卡和接口

【总线接口】1.以Xilinx开发板为例，直观的认识硬件板卡和接口

初接触硬件，五花八门的总线、接口一定会让你有些疑惑，我尝试用一系列文章来解开你的疑惑 系列文章 【总线接口】1.以Xilinx开发板为例，直观的认识硬件接口 【总线接口】2.学习硬件这些年接触过的硬件接口、总线 大汇总 【总线接口】…
阅读更多...
【STM32】STM32学习笔记-DMA数据转运+AD多通道(24)

【STM32】STM32学习笔记-DMA数据转运+AD多通道(24)

00. 目录 文章目录 00. 目录01. DMA简介02. DMA相关API2.1 DMA_Init2.2 DMA_InitTypeDef2.3 DMA_Cmd2.4 DMA_SetCurrDataCounter2.5 DMA_GetFlagStatus2.6 DMA_ClearFlag 03. DMA数据单通道接线图04. DMA数据单通道示例05. DMA数据多通道接线图06. DMA数据多通道示例一07. DMA数…
阅读更多...
关于一个热成像仪的总结（一）硬件篇电源电路

关于一个热成像仪的总结（一）硬件篇电源电路

1、电源部分 电源部分电路原理是这样的通过3.7V的锂电池供电，用Type-C选用TP4056作为充电电路给电池充电。使用MP2161开关电源作为5转3.3V 电源为MCU供电。 1-1电池 待定 1-2充电管理芯片TP4056 参考datasheet：https://atta.szlcsc.com/upload/publi…
阅读更多...
数据传输：连接数字世界的纽带

数据传输：连接数字世界的纽带

在当今数字化时代，数据传输已经成为了我们日常生活和工作中不可或缺的一部分。无论是通过互联网发送电子邮件、传输文件，还是在智能手机上浏览网页、观看视频，都离不开数据传输的支持。本文将对数据传输进行深度分析，探讨其原理、…
阅读更多...
Vue 3中toRaw和markRaw的使用

Vue 3中toRaw和markRaw的使用

Vue 3的响应性系统 在Vue 3中，响应性系统是构建动态Web应用程序的关键部分。Vue使用响应性系统来跟踪依赖关系，使数据更改能够自动更新视图。这使得Vue应用程序在数据变化时能够高效地更新DOM。Vue 3引入了新的Proxy对象来替代Vue 2中的Object.definePro…
阅读更多...
vue3+echart绘制中国地图并根据后端返回的坐标实现涟漪动画效果

vue3+echart绘制中国地图并根据后端返回的坐标实现涟漪动画效果

1.效果图 2.前期准备 main.js app.use(BaiduMap, {// ak 是在百度地图开发者平台申请的密钥 详见 http://lbsyun.baidu.com/apiconsole/key */ak: sRDDfAKpCSG5iF1rvwph4Q95M6tDCApL,// v:3.0, // 默认使用3.0// type: WebGL // ||API 默认API (使用此模式 BMapBMapGL) });i…
阅读更多...
CSDN博客重新更新

CSDN博客重新更新

说来惭愧，好久没更新博客文章，导致个人博客网站：https://lenky.info/ 所在的网络空间和域名都过期了都没发觉，直到有个同事在Dim上问我我的个人博客为啥打不开了。。。幸好之前有做整站备份，后续慢慢把内容都迁回CSDN上…
阅读更多...
学习笔记——C++运算符之比较运算符

学习笔记——C++运算符之比较运算符

作用&#xff1a;用于表达式的比较&#xff0c;并返回一个真值或假值 比较运算符有以下符号&#xff1a; #include<bits/stdc.h> using namespace std; int main(){//int a10;int b20;cout<<(ab)<<endl;//0//!cout<<(a!b)<<endl;//1//>cout&…
阅读更多...
第十二章 编写测试报告/项目总结（笔记）

第十二章 编写测试报告/项目总结（笔记）

一、编写测试报告 测试报告的侧重点是什么&#xff1f; 结果分析 1.bug数据统计&#xff0c;bug状态&#xff0c;bug严重级别统计&#xff0c;测试各阶段统计 2.需求覆盖率&#xff0c;用例数&#xff0c;用例执行率&#xff0c;通过率&#xff0c;bug关闭率&#xff0c;bug遗…
阅读更多...
CSS实现瀑布流

CSS实现瀑布流

column 多行布局实现瀑布流 1.column 实现瀑布流主要依赖两个属性。 2.column-count 属性&#xff0c;是控制屏幕分为多少列。 3.column-gap 属性&#xff0c;是控制列与列之间的距离。 <!DOCTYPE html> <html lang"en"> <head><meta charset&q…
阅读更多...
最新文章

Copyright @ 2022~2023