1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

var connections = {};
var connectionIDCounter = 0;
 
wss.on('connection', function connection(ws) {
 
  ws.id = connectionIDCounter ++;
  connections[ws.id] = ws;
 
  ws.on('message', function incoming(message) {
 
  });
 
  ws.on('close', function close() {
      delete connections[ws.id];
  });
 
  ws.on('error', function(error) {
      delete connections[ws.id];
  });
 
});

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

set_update_connection("wss://адрес");
 
function set_update_connection(url) {
    ws = new WebSocket(url);
 
    ws.on('open', function() { });
 
    ws.on('message', function message(data, flags) {
 
    });
 
    ws.on('error', function() {
        //console.log('socket error');
        reconect();
    });
 
    ws.on('close', function() {
        //console.log('socket close');
        reconect();
    });
 
    function reconect() {
        setTimeout(function(){
            set_update_connection(url);
        }, 5000);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

var connection_bitcoin=create_connection("user","pass","name");
global.name // this our database
 
function create_connection(user, password, name_connection) {
  var connection = mysql.createConnection({
      host     : 'localhost',
      user     : user,
      password : password,
      database : user
  });
 
  if(name_connection=="1") {
      global.1=connection;
  } else if(name_connection=="2"){
      global.2=connection
  }
 
  connection.connect(function(err) {              // The server is either down
    if(err) {                                     // or restarting (takes a while sometimes).
      console.log('error when connecting to db:', err);
      setTimeout(function(){
          create_connection(user,password, connection);
      }, 1000); // We introduce a delay before attempting to reconnect,
    }                                     // to avoid a hot loop, and to allow our node script to
  });                                     // process asynchronous requests in the meantime.
                                          // If you're also serving http, display a 503 error.
  connection.on('error', function(err) {
    console.log('db error', err);
    setTimeout(function(){
          create_connection(user,password, connection);
     }, 1000);
  });
  return connection;
}

1
2
3
4

process.on('uncaughtException', function (err) {
  console.error((new Date).toUTCString() + ' uncaughtException:', err.message)
  console.error(err.stack)
})