Comment appeler Java à distance basé sur RMI
Introduction
Java RMI, Remote Method Invocation, une API Java utilisée pour implémenter un appel de procédure à distance (RPCRemote procédure call), qui peut transmettre directement des objets Java sérialisés. Son implémentation repose sur la machine virtuelle Java, elle ne prend donc en charge que les appels d'une JVM à une autre.
1. Le serveur génère un registre et lie un port
2 Le serveur enregistre l'interface de service qui doit être publiée dans le registre
3. Démarre le service et attend le consommateur
4. du serveur et du port pour obtenir le registre
5. Le consommateur obtient l'interface de service qu'il souhaite fournir des services à partir du registre en fonction de son nom
6. Le consommateur appelle la méthode dans l'interface pour terminer l'appel de la méthode
Configuration de l'environnement.
Créer un module d'ingénierie
Créer une classe pojo :
package cn.hu.rmi.pojo; import java.io.Serializable; /** * @Author: hu.chen * @Description: 因为需要序列化和反序列化,所以需要实现Serializable接口 * @DateTime: 2021/12/26 5:05 PM **/ public class User implements Serializable { private Integer id; private String name; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } @Override public String toString() { return "User{" + "id=" + id + ", name='" + name + '\'' + '}'; } }
Créer une interface utilisateur :
package cn.hu.rmi.service; import cn.hu.rmi.pojo.User; import java.rmi.Remote; import java.rmi.RemoteException; /** * @Author: hu.chen * @Description: 需要提供服务的接口需要继承 Remote 并且所有的方法都需要抛出 RemoteException 异常 * @DateTime: 2021/12/26 5:06 PM **/ public interface UserService extends Remote { /** * 所有的方法都需要抛出 RemoteException 异常 * @param id * @return * @throws RemoteException */ User getUserById(Integer id) throws RemoteException; }
Fournisseur de services :
创建userservice的实现类 package cn.hu.rmi.service.impl; import cn.hu.rmi.pojo.User; import cn.hu.rmi.service.UserService; import java.rmi.RemoteException; import java.rmi.server.UnicastRemoteObject; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; /** * @Author: hu.chen * @Description: 所有的实现类都需要继承 UnicastRemoteObject 这个类 * @DateTime: 2021/12/26 5:07 PM **/ public class UserServiceImpl extends UnicastRemoteObject implements UserService { private static Map<Integer,User> userMap=new ConcurrentHashMap<>(8); static { User user1=new User(); user1.setId(1); user1.setName("张三"); User user2=new User(); user2.setId(2); user2.setName("李四"); userMap.put(user1.getId(),user1); userMap.put(user2.getId(),user2); } public UserServiceImpl() throws RemoteException { super(); } @Override public User getUserById(Integer id) throws RemoteException { return userMap.get(id); } }
Démarrer et ajouter la classe d'implémentation au registre
package cn.hu.rmi.server; import cn.hu.rmi.service.UserService; import cn.hu.rmi.service.impl.UserServiceImpl; import java.rmi.RemoteException; import java.rmi.registry.LocateRegistry; import java.rmi.registry.Registry; /** * @Author: hu.chen * @Description: 服务端(服务提供者) * @DateTime: 2021/12/26 5:11 PM **/ public class RmiServer { public static void main(String[] args) throws RemoteException { // 1: 创建注册表对象,之后服务提供者暴露的服务都需要注册到这个注册表中 Registry registry = LocateRegistry.createRegistry(8089); UserService userService=new UserServiceImpl(); // 将需要提供的service服务注册到注册表中 registry.rebind("userService",userService); System.err.println("服务提供者启动成功"); } }
Consommateur du service :
package cn.hu.rmi.client; import cn.hu.rmi.pojo.User; import cn.hu.rmi.service.UserService; import java.rmi.NotBoundException; import java.rmi.RemoteException; import java.rmi.registry.LocateRegistry; import java.rmi.registry.Registry; /** * @Author: hu.chen * @Description: 客户端(服务消费者) * @DateTime: 2021/12/26 5:18 PM **/ public class RmiClient { public static void main(String[] args) throws RemoteException, NotBoundException { //1: 获取远程的注册表 Registry registry = LocateRegistry.getRegistry("127.0.0.1", 8089); UserService userService= (UserService) registry.lookup("userService"); User userById = userService.getUserById(1); System.err.println(userById); } }
Démarrez le fournisseur de services, puis démarrez le consommateur de services :
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Outils d'IA chauds

Undresser.AI Undress
Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover
Outil d'IA en ligne pour supprimer les vêtements des photos.

Undress AI Tool
Images de déshabillage gratuites

Clothoff.io
Dissolvant de vêtements AI

AI Hentai Generator
Générez AI Hentai gratuitement.

Article chaud

Outils chauds

Bloc-notes++7.3.1
Éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise
Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1
Puissant environnement de développement intégré PHP

Dreamweaver CS6
Outils de développement Web visuel

SublimeText3 version Mac
Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Sujets chauds

Guide de la racine carrée en Java. Nous discutons ici du fonctionnement de Square Root en Java avec un exemple et son implémentation de code respectivement.

Guide du nombre parfait en Java. Nous discutons ici de la définition, comment vérifier le nombre parfait en Java ?, des exemples d'implémentation de code.

Guide du générateur de nombres aléatoires en Java. Nous discutons ici des fonctions en Java avec des exemples et de deux générateurs différents avec d'autres exemples.

Guide de Weka en Java. Nous discutons ici de l'introduction, de la façon d'utiliser Weka Java, du type de plate-forme et des avantages avec des exemples.

Guide du numéro Armstrong en Java. Nous discutons ici d'une introduction au numéro d'Armstrong en Java ainsi que d'une partie du code.

Guide du nombre de Smith en Java. Nous discutons ici de la définition, comment vérifier le numéro Smith en Java ? exemple avec implémentation de code.

Dans cet article, nous avons conservé les questions d'entretien Java Spring les plus posées avec leurs réponses détaillées. Pour que vous puissiez réussir l'interview.

Java 8 présente l'API Stream, fournissant un moyen puissant et expressif de traiter les collections de données. Cependant, une question courante lors de l'utilisation du flux est: comment se casser ou revenir d'une opération FOREAK? Les boucles traditionnelles permettent une interruption ou un retour précoce, mais la méthode Foreach de Stream ne prend pas directement en charge cette méthode. Cet article expliquera les raisons et explorera des méthodes alternatives pour la mise en œuvre de terminaison prématurée dans les systèmes de traitement de flux. Lire plus approfondie: Améliorations de l'API Java Stream Comprendre le flux Forach La méthode foreach est une opération terminale qui effectue une opération sur chaque élément du flux. Son intention de conception est
