Calculer Girl
  1. Calculer Girl
  3. R serveur de diffusion de données
Intereting Posts
Comment combiner l’authentification proxy et de base dans Apache effacer le répertoire de données Zookeeper Symfony: Apache vs serveur PHP intégré Comment faire une requête HTTP HEAD à partir de la ligne de commande Windows? Lire les données binarys de stdin sur Win32 et les écrire dans un fichier L’exportation de la firebase database mysql vers csv via php s’arrête après 4 kb Genymotion Android Emulater Disappear Bon tutoriel sur le développement de pilotes de filtres Windows? L’application Ruby en cours d’exécution sur Apache Fonction qui affiche un type de fichier Comment exécuter une application node.js en tant que service d’arrière-plan? Comment installer un banc Apache sur Windows 7? Passenger + nginx: Hébergement d’une application Rails dans un sous-répertoire lancer du mastic à partir d’un script shell Files d’attente de messages Linux – Plusieurs récepteurs

R serveur de diffusion de données

J’essaie d’écrire le démon dans R tel qu’il transmettrait les données à un canal de données et tout pair connecté à ce canal obtiendrait la dernière valeur transmise. J’ai changé le code du serveur à partir d’ ici , donc mon côté serveur a l’air: 

server <- function(){ writeLines("Listening...") con <- socketConnection(host="localhost", port = 6011, blocking=TRUE, server=TRUE, open="r+") while(TRUE){ broadcast_msg <- as.character(Sys.time()) writeLines(broadcast_msg, con) Sys.sleep(1) } close(con) } server()

Côté client, connectez-vous et lisez les lignes: 

 con <- socketConnection(host="localhost", port = 6011, blocking=TRUE, server=FALSE, open="r+") server_resp_update <- readLines(con, 1) server_resp_update <- readLines(con, 1) server_resp_update <- readLines(con, 1)

Le code ci-dessus a deux problèmes:

  1. Daemon attend que le pair se connecte. Cependant, je veux qu’il diffuse les données dans tous les cas.
  2. Lorsque je me connecte et lis les données avec le client plusieurs fois, je reçois les premières lignes envoyées au début après la connexion, mais pas la dernière valeur actualisée.

Il y avait une question similaire dans Python et la réponse était d’inverser le problème en faisant:

  1. Attendez une connexion
  2. Donner un message
  3. allez à l’étape 1

Dans mon cas 2. Donner un message implique un calcul lourd et je ne veux pas le faire pour chaque demande de pair – je veux que le démon le fasse une fois par seconde pour tous ceux qui ont besoin du message.

J’ai réussi à faire fonctionner ce schéma en utilisant un fichier txt, c.-à-d. Que le démon ré-écrit une nouvelle valeur dans le fichier toutes les secondes et que le client lit le fichier quand cela est nécessaire. Pas d’attente pour les pairs impliqués. Cependant, écrire / lire un fichier n’est pas aussi rapide qu’une connexion par socket peut être.