tormakris/cloudnet-compose
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge pull request #51 from mbelsak/master

Browse Source 
Establishe redis connection after its lost after a few minutes
This commit is contained in:
Mano Marks 2017-01-20 17:03:47 -08:00 committed by GitHub
commit 96e20cf595
1 changed files with 29 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
worker/src/Worker/Program.cs
View File

@ -17,19 +17,43 @@ namespace Worker
try try
{ {
var pgsql = OpenDbConnection("Server=db;Username=postgres;"); var pgsql = OpenDbConnection("Server=db;Username=postgres;");
var redis = OpenRedisConnection("redis").GetDatabase(); var redisConn = OpenRedisConnection("redis");
var redis = redisConn.GetDatabase();
// Keep alive is not implemented in Npgsql yet. This workaround was recommended:
// https://github.com/npgsql/npgsql/issues/1214#issuecomment-235828359
var keepAliveCommand = pgsql.CreateCommand();
keepAliveCommand.CommandText = "SELECT 1";
var definition = new { vote = "", voter_id = "" }; var definition = new { vote = "", voter_id = "" };
while (true) while (true)
{ {
// Reconnect redis if down
if (redisConn == null || !redisConn.IsConnected) {
Console.WriteLine("Reconnecting Redis");
redis = OpenRedisConnection("redis").GetDatabase();
}
string json = redis.ListLeftPopAsync("votes").Result; string json = redis.ListLeftPopAsync("votes").Result;
if (json != null) if (json != null)
{ {
var vote = JsonConvert.DeserializeAnonymousType(json, definition); var vote = JsonConvert.DeserializeAnonymousType(json, definition);
Console.WriteLine($"Processing vote for '{vote.vote}' by '{vote.voter_id}'"); Console.WriteLine($"Processing vote for '{vote.vote}' by '{vote.voter_id}'");
// Reconnect DB if down
if (!pgsql.State.Equals(System.Data.ConnectionState.Open))
{
Console.WriteLine("Reconnecting DB");
pgsql = OpenDbConnection("Server=db;Username=postgres;");
}
else
{ // Normal +1 vote requested
UpdateVote(pgsql, vote.voter_id, vote.vote); UpdateVote(pgsql, vote.voter_id, vote.vote);
} }
} }
else
{
keepAliveCommand.ExecuteNonQuery();
}
}
} }
catch (Exception ex) catch (Exception ex)
{ {
@ -84,7 +108,7 @@ namespace Worker
{ {
try try
{ {
Console.Error.WriteLine("Connected to redis"); Console.Error.WriteLine("Connecting to redis");
return ConnectionMultiplexer.Connect(ipAddress); return ConnectionMultiplexer.Connect(ipAddress);
} }
catch (RedisConnectionException) catch (RedisConnectionException)