标签：== splay type sre efault struct 当面付 out ssl
1，首先客户有一堆自动售货机的设备，设备连接socket服务端后 定时发送设备实时状态作为心跳信息，并且服务端需要下发信息予以确认。
2，需要知道设备的实时在线状态
3，设备需要实现微信，支付宝扫码支付需求，当客户买东西的时候选择扫码支付时，设备上报产品价格信息，支付方式，服务器下发微信或者支付宝的当面付二维码。
4，当客户扫码支付后，服务器需要下发支付结果。
5，设备上报出货成功或失败信息，服务器予以回复确认
6，设备上报现金收款的收款或者退款信息，服务器保存并且下发回复确认。
7，服务器后台需要能够主动的向设备推送广告信息，并且能够实现掉线设备的广告推送
1，想要服务稳定可靠，那么首先考虑的是程序的运行方式，当然是以一个windows服务为宿主的方式来运行最为可靠，那么我们可以使用TopShelf来构建这样一个服务宿主
2，实现设备的在线状态实时可知，我们需要定时的去判断这个设备是否在定时给服务器发送心跳信息，这个项目中我们以超时未发送心跳信息为标准来衡量他是否在线。
3，设备数据上报涉及到粘包的处理，设备上报的数据是怎么样一个协议，如何来解决粘包的问题，这里我们借助Newlife网络库的管道模式来处理粘包
4，微信支付宝的扫码支付如何及时知道客户付款状态，并且及时的下发给设备。
1，首先使用的网络库是Newlife 新生命团队的网络库
2，构建windows服务使用的是TopShelf
3，状态的信息保存使用Redis,这里我们使用CSRedisCore 这个类库
4，微信支付宝本次使用的是PaySharp这个库,二维码生成使用QrCoder库
1,首先创建一个windows服务，引入Topshelf后
static void Main(string[] args) { var rc = HostFactory.Run(x => //1 { x.Service<DianSocketMain>(s => //2 { s.ConstructUsing(name =>new DianSocketMain()); //3 s.WhenStarted(tc => tc.Start()); //4 s.WhenStopped(tc => tc.Stop()); //5 }); x.RunAsLocalSystem(); //6 x.SetDescription("售货机socket服务端"); //7 x.SetDisplayName("Vending machine socket"); //8 x.SetServiceName("Vendingmachinesocket"); //9 x.OnException(s => { LogerHelper.WriteErroLog("test",s.Message); }); }); //10 }
DianSocketMain类就是具体的Socket服务端，来看下是如何启动一个基本的socket服务端
public class DianSocketMain { /// <summary> ///网络库服务端 20181225 /// </summary> private NetServer _newLifeServer; /// <summary> /// /// </summary> public void Start() { try { try { //redis初始化 string redisHost = CoomHelper.GetAppSettings("RedisHost", "127.0.0.1:6379"); string redisPwd = CoomHelper.GetAppSettings("RedisPwd", ""); string prefix = "{device_server}:"; string redisConn = $"{redisHost},password={redisPwd},defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix={prefix}"; var csredis = new CSRedis.CSRedisClient(redisConn); RedisHelper.Initialization(csredis); } catch (Exception e) { XTrace.WriteLine(e.Message); } //启动客户端 StartNewLifeListenClient(); } catch (Exception e) { XTrace.WriteException(e); } } /// <summary> /// 停止win服务 /// </summary> public void Stop() { try { if (_newLifeServer != null) { _newLifeServer.Dispose(); } } catch (Exception e) { XTrace.WriteException(e); } } /// <summary> /// 监听客户端 /// </summary> private void StartNewLifeListenClient() { try { XTrace.WriteLine("当前tcp端口号为：" + 9046); //创建监听地址和端口 IPAddress ipAddress = IPAddress.Parse("127.0.0.1"); var svr = new NetServer(ipAddress, 9046, NetType.Tcp) { Log = XTrace.Log, SessionTimeout = 60 }; svr.Add<ReciveFilter>();//粘包处理管道 svr.Received += new EventHandler<ReceivedEventArgs>(NewlifeRecive);//数据接收 //svr.Error += new EventHandler<ExceptionEventArgs>(NewlifeError);//错误处理 //svr.OnDisposed+=new EventHandler(); svr.Start(); _newLifeServer = svr; //XTrace.WriteLine("会话超时时间为："+svr.SessionTimeout); } catch (Exception ex) { XTrace.WriteLine(ex.Message); } } /// <summary> /// 数据接收 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void NewlifeRecive(object sender, ReceivedEventArgs e) { INetSession session = (INetSession)sender; var pk = e.Message as Packet; if (pk.Count == 0) { XTrace.WriteLine("数据包解析错误"); return; } } }
这里包含的一个有redis的初始化，粘包处理，数据接收的一个基本服务端，下面我们再讲如何解决粘包的问题。
使用NewLife网络库构建可靠的自动售货机Socket服务端（一）
标签：== splay type sre efault struct 当面付 out ssl
原文地址：https://www.cnblogs.com/yushuo/p/10283622.html
