Pair-à-Pair de JMS et le PublishSubscribe |
|
|
Pair-à-Pair (P2P)
|
Le problème avec une limite générique comme le calcul de réseau du Pair-à-Pair (P2P) est qu'il signifie inévitablement différentes choses aux personnes différentes, et ainsi vous trouverez la limite appliquée à une variété de systèmes. Par exemple, vous trouverez la limite appliquée à :
Systèmes centralisés où chaque pair se relie à un serveur qui coordonne et contrôle la communication.
Systèmes décentralisés, où les pairs courent indépendamment sans besoin de services centralisés.
Les systèmes sponsorisés où les pairs se relient à un serveur afin de découvrir d'autres pairs, mais contrôlent alors la communication eux-mêmes.
Le projet JXTA définit un ensemble de protocoles qui peuvent être employés pour construire des systèmes de pair-à-pair en utilisant des approches centralisées, sponsorisées et décentralisées l'unes des. J2EE est prévu pour le serveur-côté calculant, qui suggère qu'il approprié plus à un système centralisé de pair-à-pair. Une bonne manière d'obtenir une meilleure appréciation des différences est d'étudier une application simple d'exemple. Cet premier article présentera une demande très simple de causerie de JMS d'échange des messages entre les utilisateurs. Le choix d'une application de causerie est délibéré parce que le projet JXTA fournit déjà une application de démonstration appelée le myJXTA (qui est également connu par son ancien nom d'InstantP2P) qui inclut des possibilités sophistiquées de causerie.
|
code d'exemple de Pair-à-pair en utilisant JMS
|
L'application de causerie de JMS a été déployée et examiné en utilisant le Java 2 SDK, la version 1.3 d'édition d'entreprise ainsi ceci sont l'environnement qui sera assumé. Pour courir l'exemple de JMSChat vous devez avoir installé la dernière version du Java 2 SDK, la version 1.3 d'édition d'entreprise. Vous devriez d'abord installer la version priée du Java 2 SDK, édition standard, sinon déjà installé. Les liens aux endroits appropriés sont donnés ci-dessous :
Cette section contient des instructions sur la façon dont créer et exécuter un programme simple de causerie de JMS. C'est une adaptation de l'édition/souscrit (publication/sous-marin) l'exemple fourni par le cours d'instruction de JMS. Avant que vous puissiez courir l'exemple, vous devez s'assurer que votre environnement est placé convenablement. Le tableau 1 montre comment placer les variables d'environnement nécessaires pour courir des applications de J2EE sur Windows et des plateformes d'UNIX.
Java 2 SDK, version 1.3 d'édition d'entreprise. Et le Java 2 SDK, édition standard
|
Inscription du programme de client de causerie
|
Le client de JMSChat est un programme multi-fileté de Java qui emploie une publication/matière secondaire pour des messages à diffusion générale à tous les abonnés à la matière. Il emploie les fils séparés pour les messages de édition à la matière et pour recevoir des messages de la matière. Ces fils sont mis en application par la classe de JMSChatThread.
Le fil de édition fait ce qui suit :
- Exécute une consultation de JNDI du TopicConnectionFactory et de la matière
Crée un raccordement et une session
Crée un TopicPublisher
Crée un TextMessage
Édite des messages à la matière
Ferme le raccordement, qui clôture automatiquement la session et le TopicPublisher
Le fil de réception fait ce qui suit :
Exécute une consultation de JNDI du TopicConnectionFactory et de la matière
Crée un raccordement et une session
Crée un TopicSubscriber
Commence le raccordement, faisant commencer la livraison de message
Détecte à l'oreille les messages édités à la matière
Ferme le raccordement, qui clôture automatiquement la session et le TopicSubscriber
|
Éditer/souscrire (publication/sous-marin)
|
Une publication/application secondaire a les caractéristiques suivantes :
- Une publication/producteur secondaire est éditeur
- Un message peut avoir les abonnés multiples
- Une publication/destination secondaire est une matière
- Une publication/consommateur secondaire est un abonné
Une application de bulletin d'email peut employer une édition/souscrit le modèle. Chacun qui est intéressé par le bulletin devient un abonné, et quand un nouveau message est édité (dire que le chef de l'heure envoie la nouvelle information), que le message est envoyé à tous les abonnés.
|
Inscription de la publication/des programmes secondaires de client. Le programme de édition (SimpleTopicPublisher.java) exécute les étapes suivantes :
Exécute la consultation de JNDI api du TopicConnectionFactory et des matières.
Crée les raccordements et des sessions.
- Crée le TopicPublisher.
- Crée le TextMessage.
Édite un ou plusieurs messages aux matières.
Ferme le raccordement, qui clôture automatiquement la session et le TopicPublisher.
Le programme de réception (SimpleTopicSubscriber.java) exécute les étapes suivantes :
Exécute la consultation de JNDI api du TopicConnectionFactory et des matières.
- Crée le raccordement et des sessions.
- Crée le TopicSubscriber.
Crée un exemple de la classe de TextListener et l'enregistre en tant qu'auditeur de message pour un TopicSubscriber.
Commence le raccordement, faisant commencer la livraison de message.
Détecte à l'oreille les messages édités à la matière, s'arrêtant quand l'utilisateur écrit les lettres (caractères) q ou Q (stoppé).
Ferme le raccordement, qui clôture automatiquement la session et le TopicSubscriber.
L'auditeur de message (TextListener.java) suit ces étapes :
Quand le message arrive, la méthode d'onMessage s'appelle automatiquement.
La méthode d'onMessage convertit le message entrant en TextMessage et montre son contenu approprié.
|
|
|
Keywords:
JMS Peer-to-Peer and the PublishSubscribe,jms web services,jms sample code,open source jms,jms web service,websphere mq jms,file sharing peer,jms api,jms architecture,jms examples,jms session,jms jdbc,peer music,jndi jms,jms database,bea jms,ibm jms,using jms,jms connection,jms queue,peer software,remote jms,p2p peer,peer program,peer network,java to,c# to.
|