WebSocket使用SuperWebSocket结合WindowsService实现实时消息
2024-09-26 22:01:28
SuperWebSocket在WebService中的应用
最开始使用是寄托在IIS中，发布之后测试时半个小时就会断开，所以改为WindowsService
1. 新建Windows服务项目【TestWindowsService】，重命名Service1为MyWebSocketService
2. 打开MyWebSocketService设计视图，右键，添加安装程序，自动添加ProjectInstaller.cs。
打开设计视图，选中ServiceInstaller1，右键修改属性：
- ServiceName（服务名）:这里改为我们刚重命名的MyWebSocketService
- StartType（启动方式）:改为自动启动Automatic
- DelayedAutoStart（延迟加载）
选中serviceProcessInstaller1，右键修改属性：
- Account（账户类型）：这里改为LocalSystem
3. 添加安装和卸载文件。注意添加文件请使用ANSI编码。推荐使用EditPlus等工具新建文件，然后通过项目添加现有项。
注意替换TestWindowsService.exe和MyWebSocketService。右键属性，设置复制到输出目录。
Install.bat:
%SystemRoot%\Microsoft.NET\Framework\v4.0.30319\installutil.exe TestWindowsService.exe
sc config MyWebSocketService start= auto
Net Start MyWebSocketService
pause
Uninstall.bat
%SystemRoot%\Microsoft.NET\Framework\v4.0.30319\installutil.exe /u TestWindowsService.exe
4. 添加App.config，配置IP和Port。
IP地址为本地连接地址，端口号自定义。确保端口号不被占用。
<configuration>
<startup>
<supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" />
</startup>
<appSettings>
<add key="APWebSocketIP" value="192.168.1.199"/>
<add key="APWebSocketPort" value="8200"/>
</appSettings>
</configuration>
5. 修改MyWebSocketService服务代码。
推荐手动加载dll，通过Nuget加载时，添加依赖的Log4net版本与SuperWebSocket中调用的Log4net版本存在冲突。
log4net版本为1.2.11.0
项目右键，管理Nuget程序包，搜索SuperWebSocket，注意作者为Kerry Jiang。
WebSocketServer server;
protected override void OnStart(string[] args)
{
var ip = ConfigurationManager.AppSettings["APWebSocketIP"];
var port = ConfigurationManager.AppSettings["APWebSocketPort"];
//WebSocket服务器端启动
server = new WebSocketServer();
if (!server.Setup(ip, int.Parse(port)))
{
//Debug.Write("WebSocket服务器端启动失败");
//处理启动失败消息
return;
}
//新的会话连接时
server.NewSessionConnected += server_NewSessionConnected;
//会话关闭
server.SessionClosed += server_SessionClosed;
//接收到新的消息时
server.NewMessageReceived += server_NewMessageReceived;
if (!server.Start())
{
//Debug.Write(string.Format("开启WebSocket服务侦听失败:{0}:{1}", server.Config.Ip, server.Config.Port));
//处理监听失败消息
return;
}
}
string KSessionId;
string VSessionId;
Dictionary<string, List<string>> msgDictionary = new Dictionary<string, List<string>>();
private void server_NewMessageReceived(WebSocketSession session, string value)
{
Debug.WriteLine("接收到新的消息：{0} 来自：{1} 时间:{2:HH:MM:ss}", value, session.RemoteEndPoint, DateTime.Now);
if (value.StartsWith("K"))
{
KSessionId = session.SessionID;
//页面已链接
if (!String.IsNullOrEmpty(VSessionId))
SendMsgToRemotePoint(VSessionId, string.Format("考场发来消息：{0}", value));
//页面未链接
else
{
AddMsgToSessionId(VSessionId);
}
}
else if (value.StartsWith("S"))
{
VSessionId = session.SessionID;
//考场已链接
if (!String.IsNullOrEmpty(KSessionId))
SendMsgToRemotePoint(KSessionId, string.Format("学生A发来消息：{0}", value));
//考场已断开
else
{
AddMsgToSessionId(KSessionId);
}
}
}
/// <summary>
/// 添加会话消息
/// </summary>
/// <param name="value"></param>
private void AddMsgToSessionId(string value)
{
if (value != null)
{
//消息列表包含页面会话ID
if (msgDictionary.ContainsKey(value))
{
msgDictionary[value].Add(value);
}
//消息列表不包含页面会话ID
else
msgDictionary.Add(value, new List<string>() { value });
}
}
/// <summary>
/// 会话关闭
/// </summary>
/// <param name="session"></param>
/// <param name="value"></param>
private void server_SessionClosed(WebSocketSession session, SuperSocket.SocketBase.CloseReason value)
{
Debug.WriteLine("会话关闭，关闭原因：{0} 来自：{1} 时间:{2:HH:MM:ss}", value, session.RemoteEndPoint, DateTime.Now);
if (session.SessionID == KSessionId)
SendMsgToRemotePoint(VSessionId, "考场已断开");
else if (session.SessionID == VSessionId)
SendMsgToRemotePoint(KSessionId, "学生A已断开");
}
/// <summary>
/// 新的会话链接
/// </summary>
/// <param name="session"></param>
private void server_NewSessionConnected(WebSocketSession session)
{
Debug.WriteLine("新的会话连接 来自：{0} SessionID:{1} 时间:{2:HH:MM:ss}", session.RemoteEndPoint, session.SessionID, DateTime.Now);
if (msgDictionary.ContainsKey(session.SessionID))
msgDictionary[session.SessionID].ForEach(item => session.Send(item));
}
/// <summary>
/// 发送消息到
/// </summary>
/// <param name="sessionId"></param>
/// <param name="msg"></param>
private void SendMsgToRemotePoint(string sessionId, string msg)
{
var allSession = server.GetAppSessionByID(sessionId);
if (allSession != null)
allSession.Send(msg);
}
6.添加log4net配置文件log4net.config。查看日志。
由于SuperWebSocket已经有日志功能，只需要添加配置文件，即可查看日志。
<?xml version="1.0" encoding="utf-8" ?>
<log4net>
<appender name="errorAppender" type="log4net.Appender.RollingFileAppender">
<filter type="log4net.Filter.LevelMatchFilter">
<levelToMatch value="ERROR" />
</filter>
<filter type="log4net.Filter.DenyAllFilter" />
<File value="Logs\err.log" />
<appendToFile value="true" />
<rollingStyle value="Date" />
<datePattern value="yyyyMMdd" />
<layout type="log4net.Layout.PatternLayout">
<conversionPattern value="%date [%thread] %-5level %logger - %message%newline" />
</layout>
</appender>
<appender name="infoAppender" type="log4net.Appender.RollingFileAppender">
<filter type="log4net.Filter.LevelMatchFilter">
<levelToMatch value="INFO" />
</filter>
<filter type="log4net.Filter.DenyAllFilter" />
<File value="Logs\info.log" />
<appendToFile value="true" />
<rollingStyle value="Date" />
<datePattern value="yyyyMMdd" />
<layout type="log4net.Layout.PatternLayout">
<conversionPattern value="%date [%thread] %-5level %logger - %message%newline" />
</layout>
</appender>
<appender name="debugAppender" type="log4net.Appender.RollingFileAppender">
<filter type="log4net.Filter.LevelMatchFilter">
<levelToMatch value="DEBUG" />
</filter>
<filter type="log4net.Filter.DenyAllFilter" />
<File value="Logs\debug.log" />
<appendToFile value="true" />
<rollingStyle value="Date" />
<datePattern value="yyyyMMdd" />
<layout type="log4net.Layout.PatternLayout">
<conversionPattern value="%date [%thread] %-5level %logger - %message%newline" />
</layout>
</appender>
<appender name="perfAppender" type="log4net.Appender.RollingFileAppender">
<filter type="log4net.Filter.LevelMatchFilter">
<levelToMatch value="INFO" />
</filter>
<filter type="log4net.Filter.DenyAllFilter" />
<File value="Logs\perf.log" />
<appendToFile value="true" />
<rollingStyle value="Date" />
<datePattern value="yyyyMMdd" />
<layout type="log4net.Layout.PatternLayout">
<conversionPattern value="%date %logger - %message%newline" />
</layout>
</appender>
<root>
<level value="ALL" />
<appender-ref ref="errorAppender" />
<appender-ref ref="infoAppender" />
<appender-ref ref="debugAppender" />
</root>
<logger name="Performance" additivity="false">
<level value="ALL" />
<appender-ref ref="perfAppender" />
</logger>
</log4net>
在html中使用WebSocket
1.首先考虑浏览器兼容问题。一些低版本浏览器不支持。
2.创建websocket对象，设置ip和端口。
var ws;
var url = "ws://192.168.1.199:8200";
$("#btnConnection").click(function () {
if ("WebSocket" in window) {
ws = new WebSocket(url);
}
else if ("MozWebSocket" in window) {
ws = new MozWebSocket(url);
}
else
alert("浏览器版本过低，请升级您的浏览器。\r\n浏览器要求：IE10+/Chrome14+/FireFox7+/Opera11+");
//注册各类回调
ws.onopen = function () {
$("#msg").append("连接服务器成功<br/>");
ws.send("S:学生A已链接");
}
ws.onclose = function () {
$("#msg").append("与服务器断开连接<br/>");
}
ws.onerror = function () {
$("#msg").append("数据传输发生错误<br/>");
}
ws.onmessage = function (receiveMsg) {
$("#msg").append(receiveMsg.data + "<br/>");
}
});
这里模拟一个学生A和考场的交互。
首先连接考场。
接着连接考生。
考场发送消息，通知学生开始考试。
学生接到消息，开始答题。
考试收到考生开始答题消息。
发布
1.首先拷贝TestWebService中的bin\Debug|Release中生成的文件到服务器。通过开始→运行→cmd→ipconfig，查看服务器的本地链接地址（192开头）。修改App.config中的IP和端口号。
2.双击Install.bat文件，等待安装服务。
3.修改html中的WebSocket对象的ip和端口号。这里的ip为服务器固定ip，与WebSocket配置不同。
4.如果涉及到读写文件，请在服务器端类360安全卫士等软件添加信任。
通过Install.bat无法启动时，可以查看本地日志文件和控制面板的事件管理器，定位详细错误。
源代码下载：TestWebSocket.zip
转载请注明出处：http://xcong.cnblogs.com
最新文章
- 弹出页面遮罩层，以及web端和移动端阻止遮罩层的滑动。
- [ASP.net MVC] 将HTML转成PDF档案，使用iTextSharp套件的XMLWorkerHelper (附上解决显示中文问题)
- JavaScript_Html5_LocalStorage项目demo
- 【转】又一波你可能不知道的 Linux 命令行网络监控工具
- 【转】shell 教程——05 第一个Shell脚本
- 学习Java第一篇——Java 安装及环境搭配
- 创建一个vue项目()
- CSS3效果：animate实现点点点loading动画效果（二）
- CPP之内存分配
- get请求中的url encode问题
- 不知道哪里alert undefined 用下面的语句是js报错.F12能提示报错的地方window.alert=function(aa){ if (typeof (aa)"undefined"){ throw "就是这";}};
- umeng推送， 生产环境deviceToken失效可能原因
- PHP搞笑注释代码-佛祖配美女
- kettle 合并记录
- 一步一步部署WPF浏览器应用程序
- [转载] 无所不能的“蚂蚁”--Ant
- django Multi-table inheritance ---- 用于实现基表-子表
- PHP归档phar性能測试
- msvcr100.dll问题描述及修复方式
- 软件安全攻防--缓冲区溢出和shellcode
热门文章
- 第五篇：CUDA 并行程序中的同步
- centos-iptables-scripts
- iOS UILable 高度自适
- 《从零开始学Swift》学习笔记（Day 66）——Cocoa Touch设计模式及应用之通知机制
- 用Dialog 做自定义动画，加播放监听
- jquery如何把一个html元素替换成另外一个html元素？
- [算法][LeetCode]Search a 2D Matrix——二维数组的二分查找
- angular4 在页面跳转的时候传递多个参数到新页面
- 页面加载异常 清除浏览器静态文件 js css 缓存 js动态加载js css文件,可以配置文件后辍，防止浏览器缓存
- JavaScript自定义函数