signalr服务端-基础搭建
2024-10-18 20:18:48
signalr 支持 iis托管、winform、windowsservices、wpf 托管 这里我采用winfrom托管
首先画一个这样的窗体
在服务项目通过项目管理包安装signalr类库
安装后 如果客户端是web程序 则将js移动到客户端 编写客户端的时候使用
这次我安装缺少一个
程序集 我在官网下载手动引用上去了
新建一个类 该类用于自定义找到signalr回话的id 默认是随机的一个guid维护。。实现这个类 就可以根据用户id 直接发送给指定用户
/// <summary>
/// 自定义维护每个用户会话id的实现类
/// </summary>
public class UserIdProvider:IUserIdProvider
{
public string GetUserId(IRequest request)
{
return request.QueryString["Uid"];
}
}
新建一个signalr启动类。并将自定义维护会话注入
public class Startup
{
public void Configuration(IAppBuilder app)
{
//注入signlar自定义维护会话id
GlobalHost.DependencyResolver.Register(typeof(IUserIdProvider), () => new UserIdProvider());
app.UseCors(CorsOptions.AllowAll);
app.MapSignalR();
}
}
新建一个服务器的在线用户信息管理类
/// <summary>
/// 在线用户信息管理类
/// </summary>
public class User
{
/// <summary>
/// 用户id
/// </summary>
public string Uid { get; set; }
/// <summary>
/// 用户名字
/// </summary>
public string UName { get; set; }
/// <summary>
/// 上线时间
/// </summary>
public DateTime Date { get; set; }
/// <summary>
/// 头像
/// </summary>
public string HeadPath { get; set; }
/// <summary>
/// 当前用户所在机构id
/// </summary>
public string OrganId{ get; set; }
/// <summary>
/// 当前用户所在部门id
/// </summary>
public string Depid { get; set; }
}
引入redis客户端 消息队列管理以及在线用户管理
编写接口层 如果不使用redis可以切换成其他存储
public interface IDeposit
{
Task<bool> RemoveKey(string key);
Task<bool> SetAsync(string key, object value, TimeSpan? timeOut = null);
Task<T> GetAsync<T>(string key);
Task<bool> ListLeftPush(string key, object value, TimeSpan? ts = null);
Task<bool> ListRightPush(string key, object value, TimeSpan? ts = null);
Task<T> ListLeftPop<T>(string key);
Task<T> ListRightPop<T>(string key);
bool HashSet(string keyA, string keyB, object value);
T HashGet<T>(string keyA, string keyB);
}
}
编写实现层
public class RedisManager:IDeposit
{
private ConnectionMultiplexer _redis;
private object _locker = new object();
public ConnectionMultiplexer Manager
{
get
{
if (_redis == null)
{
lock (_locker)
{
if (_redis != null) return _redis;
_redis = GetManager();
return _redis;
}
}
return _redis;
}
}
public IDatabase DB
{
get
{
return Manager.GetDatabase();
}
}
private ConnectionMultiplexer GetManager()
{
ConfigurationOptions co = new ConfigurationOptions()
{
EndPoints =
{
{ConfigHelper.GetRedisIp, ConfigHelper.GetRedisPort }
}
};
return ConnectionMultiplexer.Connect(co);
}
public async Task<bool> RemoveKey(string key)
{
return await DB.KeyDeleteAsync(key);
}
public async Task<bool> SetAsync(string key, object value, TimeSpan? timeOut=null)
{
Type t = value.GetType();
bool isOk;
if (t.IsClass && t != typeof(string))
{
var str = JsonConvert.SerializeObject(value);
isOk = Manager.GetDatabase().StringSet(key, str);
}
else
{
isOk = Manager.GetDatabase().StringSet(key,value.ToString());
}
//设置key的失效时间
if (isOk && timeOut != null)
{
DB.KeyExpire(key, timeOut);
}
return isOk;
}
public async Task<T> GetAsync<T>(string key)
{
try
{
if (DB.KeyExists(key))
{
Type t = typeof(T);
string str = DB.StringGet(key);
if (t.IsClass&&t!=typeof(string))
{
return JsonConvert.DeserializeObject<T>(str);
}
else
{
return (T)Convert.ChangeType(str, t);
}
}
else
{
return default(T);
}
}
catch (Exception e)
{
throw e;
}
}
/// <summary>
/// 左侧入队
/// </summary>
/// <param name="key"></param>
/// <param name="value"></param>
/// <param name="ts"></param>
/// <returns></returns>
public async Task<bool> ListLeftPush(string key,object value,TimeSpan?ts=null) {
Type t = value.GetType();
bool isOk;
long oldLength = DB.ListLength(key);
;
if (t.IsClass && t != typeof(string))
{
var str = JsonConvert.SerializeObject(value);
length = DB.ListLeftPush(key, str);
}else{
length = DB.ListLeftPush(key, value.ToString());
}
isOk=oldLength < length;
//设置key的失效时间
if (isOk && ts != null)
{
DB.KeyExpire(key, ts);
}
return isOk;
}
//右侧入队
public async Task<bool> ListRightPush(string key, object value, TimeSpan? ts = null)
{
Type t = value.GetType();
bool isOk;
long oldLength = DB.ListLength(key);
;
if (t.IsClass && t != typeof(string))
{
var str = JsonConvert.SerializeObject(value);
length = DB.ListRightPush(key, str);
}
else
{
length = DB.ListRightPush(key, value.ToString());
}
isOk= oldLength < length;
//设置key的失效时间
if (isOk && ts != null)
{
DB.KeyExpire(key, ts);
}
return isOk;
}
/// <summary>
/// 左侧出队
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="key"></param>
/// <returns></returns>
public async Task<T> ListLeftPop<T>(string key)
{
Type t = typeof(T);
if (DB.KeyExists(key))
{
var values = DB.ListLeftPop(key);
if (t.IsClass && t != typeof(string))
{
return JsonConvert.DeserializeObject<T>(values); ;
}
else
{
return (T)Convert.ChangeType(values, t);
}
}
else
{
return default(T);
}
}
/// <summary>
/// 右侧出队
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="key"></param>
/// <returns></returns>
public async Task<T> ListRightPop<T>(string key)
{
Type t = typeof(T);
if (DB.KeyExists(key))
{
var values = DB.ListRightPop(key);
if (t.IsClass && t != typeof(string))
{
return JsonConvert.DeserializeObject<T>(values); ;
}
else
{
return (T)Convert.ChangeType(values, t);
}
}
else
{
return default(T);
}
}
public bool HashSet(string keyA, string keyB, object value)
{
if (DB == null) return false;
var t = value.GetType();
bool isOk;
if (t.IsClass && t != typeof(string))
{
var str = JsonConvert.SerializeObject(value);
isOk= DB.HashSet(keyA, keyB, str);
}
else
{
isOk= DB.HashSet(keyA,keyB, value.ToString());
}
return isOk;
}
public T HashGet<T>(string keyA, string keyB)
{
if (DB == null) return default(T);
var t = typeof(T);
var values = DB.HashGet(keyA,keyB);
if (string.IsNullOrEmpty(values)) return default(T);
if (t.IsClass && t != typeof(string))
{
return JsonConvert.DeserializeObject<T>(values); ;
}
else
{
return (T)Convert.ChangeType(values, t);
}
}
}
编写帮助类
public class DepositHelper
{
public static IDeposit rm = new RedisManager();
public Task<bool> RemoveKey(string key)
{
return rm.RemoveKey(key);
}
public static Task<bool> SetAsync(string key, object value, TimeSpan? timeOut = null)
{
return rm.SetAsync(key, value, timeOut);
}
public static Task<T> GetAsync<T>(string key)
{
return rm.GetAsync<T>(key);
}
public static Task<bool> ListLeftPush(string key, object value, TimeSpan? ts = null)
{
return rm.ListLeftPush(key, value, ts);
}
public static Task<bool> ListRightPush(string key, object value, TimeSpan? ts = null)
{
return rm.ListRightPush(key, value, ts);
}
public static Task<T> ListLeftPop<T>(string key)
{
return rm.ListLeftPop<T>(key);
}
public static Task<T> ListRightPop<T>(string key)
{
return rm.ListRightPop<T>(key);
}
public static bool HashSet(string keyA, string keyB, object value)
{
return rm.HashSet(keyA, keyB, value);
}
public static T HashGet<T>(string keyA, string keyB)
{
return rm.HashGet<T>(keyA, keyB);
}
}
编写在线用户信息管理类
以后再写了
最新文章
- oracle使用sqlplus创建表空间
- [No00003B]string格式的日期时间字符串转为DateTime类型
- 部署Linux下的man慢查询中文帮助手册环境
- 【地图API】收货地址详解2
- Meteor 加入账户系统
- android 打包签名
- 【Xamarin挖墙脚系列：在VMware11中安装Mac10.11 EI Captain后的vmware tools】
- 【转】jsp 表单form传值
- C++ 版本的split_string
- （转）多个mapreduce工作相互依赖处理方法完整实例（JobControl）
- Python函数篇（二）之递归函数、匿名函数及高阶函数
- memocache工作原理
- a标签一个有利于SEO的属性rel="nofollow"
- ShellExecuteEX打开iqy文件导致excel hang的原因分析
- XE5 Android 开发数据访问手机端[转]
- 计算机硬件的五大单元 & CPU的种类 & 计算机的运行流程
- 【比赛游记】THUSC2018酱油记
- appserv - 最简单的绑定路径
- TortoiseGit-2.0.0.0-64bit问题
- Docker 镜像构建的时候，应该小心的坑