70 lines
		
	
	
		
			2.2 KiB
		
	
	
	
		
			C#
		
	
	
	
	
	
			
		
		
	
	
			70 lines
		
	
	
		
			2.2 KiB
		
	
	
	
		
			C#
		
	
	
	
	
	
| /*
 | |
|  * Backgroudn worker
 | |
|  */
 | |
| using System;
 | |
| using System.Collections.Generic;
 | |
| using System.ComponentModel;
 | |
| using System.Linq;
 | |
| using System.Text;
 | |
| 
 | |
| namespace Project
 | |
| {
 | |
|     public partial class fMain
 | |
|     {
 | |
|         DateTime redisTryTime = DateTime.Parse("1982-11-23");
 | |
|         Boolean bBW = true;
 | |
|         private void bw_DoWork(object sender, DoWorkEventArgs e)
 | |
|         {
 | |
|             while (bBW)
 | |
|             {
 | |
|                 //if (redisConnection == null)
 | |
|                 //{
 | |
|                 //    var ts = DateTime.Now - redisTryTime;
 | |
|                 //    if (ts.TotalMinutes > 5)
 | |
|                 //    {
 | |
|                 //        Console.WriteLine("redis conn : 10.131.36.57:6379");
 | |
|                 //        try
 | |
|                 //        {
 | |
|                 //            redisConnection = StackExchange.Redis.ConnectionMultiplexer.Connect("10.131.36.57:6379");
 | |
|                 //        }
 | |
|                 //        catch (Exception ex)
 | |
|                 //        {
 | |
| 
 | |
|                 //        }
 | |
|                 //    }
 | |
|                 //}
 | |
|                 //else
 | |
|                 //{
 | |
|                 //    if (redisConnection.IsConnected)
 | |
|                 //    {
 | |
|                 //        if (this.db == null)
 | |
|                 //        {
 | |
|                 //            try
 | |
|                 //            {
 | |
|                 //                Console.WriteLine("redis connected setting db");
 | |
|                 //                this.db = redisConnection.GetDatabase();
 | |
|                 //                var getStr = this.db.StringGet("test");
 | |
|                 //                Console.WriteLine(getStr);
 | |
|                 //            }
 | |
|                 //            catch (Exception ex)
 | |
|                 //            {
 | |
|                 //                Pub.log.AddE("REDIS " + ex.Message);
 | |
|                 //            }
 | |
| 
 | |
|                 //        }
 | |
|                 //    }
 | |
|                 //    else
 | |
|                 //    {
 | |
|                 //        Console.WriteLine("resetting redis connection");
 | |
|                 //        redisConnection.Dispose();
 | |
|                 //        redisConnection = null;
 | |
|                 //    }
 | |
|                 //}
 | |
| 
 | |
| 
 | |
|                 System.Threading.Thread.Sleep(5000);
 | |
|             }
 | |
|         }
 | |
|     }
 | |
| }
 | 
