Utilisation de l'API de blocage Mysql avec Boost :: asio

Question

Je suis en train de créer un serveur monovis aync qui reçoit des données des clients. Il traite les données, puis les enregistre dans la base de données MySQL. Le problème est que l'API MySQL C ne prend pas en charge les appels non bloquants et asio n'aime pas principalement les appels bloquants. Donc je pense quelque chose comme deferToThread() de Python Twisted comme la sémantique. Y a-t-il quelqu'un qui a déjà développé une telle chose? Ou devrais-je l'implémenter?

Answer 1

Il y avait a post à la liste de diffusion Asio au cours de l'été décrivant une classe de service asynchrone générique qui semble être utile pour vous. Ce code pseudo est de l'e-mail de l'auteur I lié:

// Create a command processor with 5 threads allocated 
// to processing the commands. 
async_command_processor processor(io_service, 5); 

// Execute the command asynchronously and call the 
// MyCommandComplete callback when completed. 
processor.async_execute(MyCommand, MyCommandComplete); 

Answer 2

pour "tirer et oublier" un fil. Vous pouvez créer une classe avec opérateur() et des variables membres avec des données à écrire. Dans le gestionnaire de données asio accept, créez l'une de ces classes, puis passez-la à un thread boost. Le thread Boost copiera cette classe en interne et démarrera le thread. Si vous faites attention à la façon dont vous écrivez l'opérateur(), il devrait se terminer lorsque l'écriture sql est terminée et libérer ses données d'écriture. Vous pouvez appeler boost :: thread :: detach pour oublier le thread et le laisser terminer puis mourir. De cette façon, vous lancez de nouveaux threads qui écrivent à mysql depuis vos gestionnaires asio. Je ne suis pas sûr de ce qu'il advient des données de membre lorsque la classe de threads est hors de portée. vérifiez les documents d'amplification, cela pourrait poser un problème si le thread d'amplification n'est pas terminé et que le thread a encore besoin de données qui ont disparu. Peut-être que les pointeurs partagés peuvent aider ici.

Answer 3

Peut-être que vous serez intéressé par cette bibliothèque client MySQL asynchrone basée Asio nommé Amy: https://github.com/liancheng/amy

Cité du README GitHub:

Amy est un en-tête conforme à la norme C++ 11 A synchrone Ma bibliothèque client basée sur Boost.Asio. Il vous permet de travailler avec MySQL de manière asynchrone et bloquante.