parkMonitor_V2.0/NettyCommunication/NettyTest/Program.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using DotNetty.Transport.Bootstrapping;
using DotNetty.Transport.Channels;
using DotNetty.Buffers;

using System.Threading;

namespace nettyCommunication
{
    class Program
    {
        private static Communication comm = null;
        private static Thread receiveMsg = null;
        private static bool connected { get; set; }
        static void Main(string[] args)
        {
            //持续进行连接尝试
            Task.Factory.StartNew(() =>
            {
                //初始化后与web持续连接
                int count = 0;
                while (true)
                {
                    try
                    {
                        if (count != 0)
                        {
                            Connections.close();
                            Thread.Sleep(100);
                        }
                        //Thread.Sleep(100);
                        Connections.Connection();
                        connected = true;
                        comm = new Communication();
                        count++;
                        break;
                    }
                    catch (Exception)
                    {
                        connected = false;
                        Console.WriteLine("服务没有开启,请检查服务器");
                    }
                    Thread.Sleep(200);
                }
                //持续判断连接状态并重连
                while (true)
                {
                    Console.WriteLine(Connections.isAlive() + ", " + receiveMsg.ThreadState.ToString());
                    if (Connections.isAlive())
                    {
                        if (!connected)
                        {
                            comm = new Communication();
                        }
                        connected = true;
                        if (receiveMsg.ThreadState == ThreadState.Aborted)
                        {
                            try
                            {
                                receiveMsg.Start();
                            }
                            catch (Exception ex) { Console.WriteLine(ex.Message); }
                        }
                    }
                    else
                    {
                        connected = false;
                        try
                        {
                            if (receiveMsg.ThreadState == ThreadState.WaitSleepJoin)
                            {
                                receiveMsg.Interrupt();
                            }
                        }
                        catch (Exception ex)
                        {
                            Console.WriteLine("连接断开，终止消息接收线程");
                        }
                        Console.WriteLine(" 连接关闭，需要重新连接注册");
                        try
                        {
                            Connections.close();
                            Thread.Sleep(100);
                            Connections.Connection();
                        }
                        catch (Exception)
                        {
                            Console.WriteLine("服务没有开启,请检查服务器");
                        }
                    }
                    Thread.Sleep(10000);
                }
            });
            //持续接收消息
            receiveMsg = new Thread(() =>
            {
                byte[] bytes = new byte[256];
                while (true)
                {
                    try
                    {
                        if (connected && comm != null)
                        {
                            MessageUTF8 msg = ((MessageUTF8)comm.ReceiveMessage(out bytes));
                        }
                    }
                    catch { Console.WriteLine("线程已中断"); }
                }
            });
            receiveMsg.Start();
            Console.ReadLine();
        }

        //public static async Task sendMessage(IChannelHandlerContext ctx,object message)
        //{
        //    AbstractMessage ms = (AbstractMessage)message;
        //    IByteBuffer initialMessage = Unpooled.Buffer(ClientSettings.Size);
        //    //byte[] messageByte = Encoding.UTF8.GetBytes(msg);
        //    byte[] byteMessage = JsonByByteToObjectTools.ObjToJsonByte(ms);
        //    initialMessage.WriteBytes(byteMessage);
        //    await ctx.WriteAndFlushAsync(initialMessage);
        //    ctx.Flush();
        //}


    }
}