Winform中使用Fleck实现Websocket服务端并读取SQLite数据库中数据定时循环群发消息

场景

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

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

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

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

在上面实现Websocket客户端的基础上，如何实现Websocket服务端，并实现定时给所有的客户端群发消息。

群发的消息从SQLite中读取，循环进行群发。

注：

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

实现

1、Fleck

GitHub - statianzo/Fleck: C# Websocket Implementation

新建Winform项目，并使用Nuget引入依赖

搜索Fleck

按照官网说明，快速实现Websocket服务端只需要

var server = new WebSocketServer("ws://0.0.0.0:8181");
server.Start(socket =>
{
? socket.OnOpen = () => Console.WriteLine("Open!");
? socket.OnClose = () => Console.WriteLine("Close!");
? socket.OnMessage = message => socket.Send(message);
});

并且官方提供了一些示例demo，比如群发消息的实现，这里是在控制台项目中的示例

??????????? var allSockets = new List<IWebSocketConnection>();
??????????? var server = new WebSocketServer("ws://0.0.0.0:8181");
??????????? server.Start(socket =>
??????????????? {
??????????????????? socket.OnOpen = () =>
??????????????????????? {
??????????????????????????? Console.WriteLine("Open!");
??????????????????????????? allSockets.Add(socket);
??????????????????????? };
??????????????????? socket.OnClose = () =>
??????????????????????? {
??????????????????????????? Console.WriteLine("Close!");
??????????????????????????? allSockets.Remove(socket);
??????????????????????? };
??????????????????? socket.OnMessage = message =>
??????????????????????? {
??????????????????????????? Console.WriteLine(message);
??????????????????????????? allSockets.ToList().ForEach(s => s.Send("Echo: " + message));
??????????????????????? };
??????????????? });

demo位置

2、这里基于Winform设计窗体布局如下

3、启动服务端/开始监听按钮点击事件

新建WebSocketServer服务端对象，便于停止监听

public WebSocketServer wsServer= null;

新建一个list用来存储所有的客户端连接信息

private List<IWebSocketConnection> allSockets = new List<IWebSocketConnection>();

然后在开始监听按钮的点击事件中

??????? private void button_start_listen_Click(object sender, EventArgs e)
??????? {
??????????? try
??????????? {
??????????????? allSockets.Clear();
??????????????? string wsAddress = textBox_server_address.Text.Trim();
??????????????? wsServer = new WebSocketServer(wsAddress);??? //创建webscoket服务端实例
??????????????? wsServer.Start(socket => {
??????????????????? socket.OnOpen = () =>
??????????????????? {
??????????????????????? //Console.WriteLine("Open");
??????????????????????? allSockets.Add(socket);
??????????????????? };
??????????????????? socket.OnClose = () =>
??????????????????? {
??????????????????????? //Console.WriteLine("Close");
??????????????????????? allSockets.Remove(socket);
??????????????????? };
??????????????????? socket.OnMessage = message => {
??????????????????????? //Console.WriteLine(message);??????????????????
??????????????????? };
??????????????????? socket.OnError = message =>
??????????????????? {
??????????????????????? //Console.WriteLine(message);
??????????????????? };
??????????????? });
??????????????? textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":监听成功");
??????????????? textBox_log.AppendText("\r\n");
??????????? }
??????????? catch (Exception exception)
??????????? {
??????????????? textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":监听异常:" + exception.Message);
??????????????? textBox_log.AppendText("\r\n");
??????????? }?????????
??????? }

在建立连接和关闭事件中分别对客户端的list进行添加和删除。

4、停止监听的按钮点击事件中

遍历所有客户端的list，循环进行关闭，并销毁服务端对象

??????? private void button_stop_listen_Click(object sender, EventArgs e)
??????? {
??????????? allSockets.ToList().ForEach(s => s.Close());
??????????? wsServer.Dispose();
??????????? textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":监听停止");
??????????? textBox_log.AppendText("\r\n");
??????? }

5、单次群发按钮点击事件

??????? private void button_single_mass_Click(object sender, EventArgs e)
??????? {
??????????? if (null != wsServer)
??????????? {
??????????????? string message = textBox_message.Text.Trim();
??????????????? allSockets.ToList().ForEach(s => {
??????????????????? if (s.IsAvailable)
??????????????????? {
??????????????????????? s.Send(message);
??????????????????? }
??????????????? });
??????????? }
??????????? else {
??????????????? textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":wsServer未启动");
??????????????? textBox_log.AppendText("\r\n");
??????????? }
??????? }

判断服务端对象不为空，遍历所有客户端list,判断如果可用则调用send方法，发送string类型的消息。

6、加载数据按钮实现

用来从SQLite中读取需要循环群发的消息内容

首先声明string的list用来存储加载的数据

private List<string> loadDataList = new List<string>();

然后按钮的点击事件中

??????? private void button_load_data_Click(object sender, EventArgs e)
??????? {
??????????? try
??????????? {
??????????????? if (null == wsServer)
??????????????? {
??????????????????? textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":wsServer未启动");
??????????????????? textBox_log.AppendText("\r\n");
??????????????? }
??????????????? else
??????????????? {
??????????????????? loadDataList.Clear();
??????????????????? SQLiteDataReader reader = Global.Instance.sqlLiteHelper.ExecuteQuery("SELECT* FROM positions;");
??????????????????? if (reader.HasRows)
??????????????????? {
??????????????????????? while (reader.Read())
??????????????????????? {
??????????????????????????? string data = reader.GetString(reader.GetOrdinal("data"));
??????????????????????????? loadDataList.Add(data);
??????????????????????? }
??????????????????? }
??????????????????? textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":加载数据完成，共("+ loadDataList.Count+")条。");
??????????????????? textBox_log.AppendText("\r\n");
??????????????? }
??????????? }
??????????? catch (Exception exception)
??????????? {
??????????????? textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":加载数据异常：" + exception.Message);
??????????????? textBox_log.AppendText("\r\n");
??????????? }
??????? }

7、定时群发实现

首先新建定时器以及加载的数据的索引

Timer _timerMass = new Timer();

private int index = 0;

定时群发按钮点击事件实现

??????? private void button_start_mass_Click(object sender, EventArgs e)
??????? {
??????????? if (null == wsServer) {
??????????????? textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":wsServer未启动");
??????????????? textBox_log.AppendText("\r\n");
??????????? } else {
??????????????? _timerMass.Interval = (int)numericUpDown_mass.Value;
??????????????? _timerMass.Tick += _timer_Tick_Mass;
??????????????? _timerMass.Start();
??????????????? textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":定时群发已经启动!!");
??????????????? textBox_log.AppendText("\r\n");
??????????? }
??????? }

定时器执行方法具体实现

??????? private void _timer_Tick_Mass(object sender, EventArgs e)
??????? {
??????????? if (loadDataList.Count>0) {
??????????????? if (index > loadDataList.Count - 1)
??????????????? {
??????????????????? index = 0;
??????????????? }
??????????????? string data = loadDataList[index];
??????????????? allSockets.ToList().ForEach(s => {
??????????????????? if (s.IsAvailable) {
??????????????????????? s.Send(data);
??????????????????? }?????????????
??????????????? });
??????????????? index++;
??????????? }
??????? }

8、停止定时群发按钮点击事件实现

??????? private void button_stop_mass_Click(object sender, EventArgs e)
??????? {
??????????? //停止定时器
??????????? _timerMass.Tick -= _timer_Tick_Mass;
??????????? _timerMass.Stop();
??????????? textBox_log.AppendText(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":定时群发已经停止!!！");
??????????? textBox_log.AppendText("\r\n");
??????????? index = 0;
??????? }