本篇內容介紹了“java基于RMI遠程怎么調用”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

創(chuàng)新互聯(lián)是一家專業(yè)提供裕安企業(yè)網(wǎng)站建設,專注與成都網(wǎng)站建設、成都網(wǎng)站設計、H5高端網(wǎng)站建設、小程序制作等業(yè)務。10年已為裕安眾多企業(yè)、政府機構等服務。創(chuàng)新互聯(lián)專業(yè)的建站公司優(yōu)惠進行中。

簡介

Java RMI，即遠程方法調用(Remote Method Invocation)，一種用于實現(xiàn)遠程過程調用(RPCRemote procedure call)的Java API， 能直接傳輸序列化后的Java對象。它的實現(xiàn)依賴于Java虛擬機，因 此它僅支持從一個JVM到另一個JVM的調用。

1、服務端生成一個注冊表，并綁定一個端口
2、服務端將需要發(fā)布的服務接口，注冊到注冊表中
3、啟動服務等待消費者
4、消費者根據(jù)服務端的IP和端口獲取注冊表
5、消費者從注冊表中根據(jù)名稱獲取想要提供服務的service接口
6、消費者調用接口中的方法完成方法的調用

環(huán)境搭建

創(chuàng)建一個工程模塊

創(chuàng)建pojo類：

package cn.hu.rmi.pojo;

import java.io.Serializable;

/**
 * @Author: hu.chen
 * @Description: 因為需要序列化和反序列化，所以需要實現(xiàn)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 + '\'' +
                '}';
    }
}

創(chuàng)建user接口：

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;
}

服務提供者：

創(chuàng)建userservice的實現(xiàn)類

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: 所有的實現(xiàn)類都需要繼承 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);
    }
}

啟動并將實現(xiàn)類添加到注冊表中：

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: 創(chuàng)建注冊表對象，之后服務提供者暴露的服務都需要注冊到這個注冊表中
        Registry registry = LocateRegistry.createRegistry(8089);

        UserService userService=new UserServiceImpl();

        // 將需要提供的service服務注冊到注冊表中
        registry.rebind("userService",userService);


        System.err.println("服務提供者啟動成功");


    }
}

服務消費者：

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);
    }
}

啟動服務提供者，然后啟動服務消費者：

“java基于RMI遠程怎么調用”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關的知識可以關注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質量的實用文章！

本文標題：java基于RMI遠程怎么調用
本文網(wǎng)址：http://chinadenli.net/article18/gpcddp.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供用戶體驗、網(wǎng)站制作、網(wǎng)站改版、網(wǎng)站建設、網(wǎng)站維護、ChatGPT

廣告

聲明：本網(wǎng)站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)