Client TCP acceptant des objets

Question

J'écris un programme Java qui doit accepter en continu des objets sérialisés tout au long de l'exécution de l'application. Les objets sont envoyés par un serveur comme demandé par l'utilisateur.

Mon application principale initialise le client tcp (extension thread) dans sa méthode d'exécution, mais j'essaie de lire les objets de la ligne à partir d'une fonction.

pseudocode suit:

*tcp client extends thread 

*global vars: ip, port, socket, oi stream, oo stream, object reference 

*run() 
     make connection 

*getObject() 
     object reference = (object).readobject() 
     return object 

Ma principale application appelle client.getObject() dans une boucle de mise à jour. il peut y avoir ou non un objet en attente.

Est-ce que je vais dans le mauvais sens?

Answer 1

Essayez-vous de faire un comportement de serveur «classique» ou des E/S non bloquantes? Si c'est la première, je recommanderais une file d'attente de blocage sur le serveur pour accepter les demandes entrantes et un groupe de threads pour les traiter. Demandez au serveur d'attribuer un thread pour traiter la requête quand elle arrive jusqu'à ce que le pool de threads soit épuisé; Mettre en file d'attente les requêtes jusqu'à ce que les threads soient libérés et renvoyés au pool.

Les E/S non bloquantes sont entièrement différentes. Regardez comment Netty et node.js sont conçus et mis en œuvre pour cela.

Je n'aurais jamais de classe étendre Thread - il est peu probable que vous ajouterez un nouveau comportement significatif. Implémentez Runnable à la place et donnez-le à une instance Thread pour exécuter.

Answer 2

Je suggère que votre méthode run() lit tous les objets et les ajoute à une file d'attente. getOject() prend l'objet suivant de la file d'attente. Vous pouvez également avoir un int queueLength() pour vérifier comment vous attendez.