Make shard processes use the same pool

Question

I want to create a pool in my shard manager (server.js) and pass it to shard processes (bot.js). Here is my sharding manager (server.js):

var clientMysqlEvent = require('./database/botpool.js').connection;
const flatted = require('flatted');
const clientMysqlEventserialized = flatted.stringify(clientMysqlEvent);
const { ShardingManager } = require('discord.js');
  const shard = new ShardingManager('./bot.js', {
    token: config.token,
    respawn: true,
  });
  shard.spawn({ amount: splen, delay: 100, timeout: 120000 }); 
    //console.log(`[DEBUG/SHARD] Shard ${shard.id} connected to Discord's Gateway.`)
    // Sending the data to the shard.
    shard.on("ready", () => {
      console.log(`[SHARD] Shard ${formatedShardId} connected to Discord's Gateway.`)
      // Sending the data to the shard.
      shard.send({type: "shardId", data: {shardId: shard.id, shardTotal: splen}});
      shard.send({type: "myDb", data: {dbManager: clientMysqlEventserialized}});
});

botpool.js:

const mysql  = require('mysql');
    var connection = mysql.createPool({
      connectionLimit : 20,
      host     : 'localhost',
      user     : 'user',
      password : 'pass',
      database : 'db'
    });
    connection.on('release', function (connection1) {
        console.log('BOT: Connection %d released', connection1.threadId);
      });
    connection.on('acquire', function (connection1) {
        console.log('BOT: Connection %d acquired', connection1.threadId);
      });
    connection.on('connection', function (connection1) {
        console.log('BOT: Connection %d connected', connection1.threadId);
      });
    connection.on('enqueue', function () {
        console.log('BOT: Waiting for available connection slot');
      });
    exports.connection = connection;

Shard process (bot.js):

const flatted = require('flatted');
var mysql = null;
process.on('message', message => {
  if (!message.type) return false;
  if (message.type == "shardId") {
    console.log(`The shard id is: ${message.data.shardId + Number(1)}`);
    console.log(`Total shard number is: ${message.data.shardTotal}`)
    clientShardId = message.data.shardId + Number(1)
    totalShardIds = message.data.shardTotal
    console.log("Captured data: "+clientShardId+"/"+totalShardIds)
    client.user.setPresence({ activities: [{ name: `${config.activities} [${message.data.shardId + Number(1)} / ${message.data.shardTotal}]` }] });
} else if (message.type == "myDb") {
    //mysql = message.data.dbManager;
    mysql = flatted.parse(message.data.dbManager);
    //console.log("mysql:")
    //console.log(mysql)
};
})

Sadly this approach doesn't do what I want and shard process (bot.js) creates its own pool.

BlackInk7777 · Accepted Answer · 2024-02-03 02:58:27Z

0

Let me try to solve your problem but I can't confirm if it is correct. The reason your approach is not working is that you are creating the pool connection in the shard manager and then trying to send the connection object to the shard process. However, the connection object cannot be serialized and sent over the IPC channel.

According to the above point of view, you can try:

Create the pool connection in the shard process (bot.js) instead of the shard manager (server.js).
Send the database connection configuration (such as the host, user, password, and database name) to the shard process.
Use the database connection configuration in the shard process to create the pool connection.

answered Feb 3, 2024 at 2:58

BlackInk7777

487 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Hasan Kayra Over a year ago

Thanks for your reply but i am pretty sure this would still create a new pool for every process and won't make processes share the same pool.

Collectives™ on Stack Overflow

Make shard processes use the same pool

1 Answer 1

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related