기술나눔

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

1.RMI란 무엇인가요?

RMI(Remote Method Invocation)는 분산 프로그래밍의 기본 개념인 원격 메소드 호출(Remote Method Invocation)입니다. CORBA, WebService 등 원격 메서드 호출을 구현하는 기술은 많이 있으며, 둘 다 각 프로그래밍 언어에 독립적입니다. Java RMI는 Java 환경을 위해 특별히 설계된 원격 메소드 호출 메커니즘으로, RPC(원격 프로시저 호출)를 구현하는 데 사용되며 직렬화된 Java 객체와 분산 가비지 수집을 직접 전송할 수 있습니다. 구현은 JVM에 따라 다르므로 한 JVM에서 다른 JVM으로의 호출을 지원합니다. Java RMI에서는 원격 서버가 특정 Java 메소드를 구현하고 인터페이스를 제공하기만 하면 클라이언트는 원격 메소드를 호출하기 위해 인터페이스 클래스의 정의에 따라 해당 매개변수를 제공하기만 하면 됩니다. 따라서 역직렬화 취약점의 일반적인 악용에는 종종 RMI가 포함되며 이것이 의미하는 바입니다. RMI가 사용하는 통신 프로토콜은 JRMP(Java Remote Message Exchange Protocol)입니다. 이 프로토콜은 Java용으로 사용자 정의되었으며 서버와 클라이언트 모두 Java로 작성되어야 합니다.

대화형 프로세스

상호작용 프로세스는 다음과 같이 간략하게 요약될 수 있습니다.

1. 먼저 RMI 레지스트리 서비스를 시작합니다. 시작할 때 서비스가 수신하는 포트를 지정하거나 기본 포트(1099)를 사용할 수 있습니다.
2. 둘째, 서버측에서는 먼저 로컬에서 서비스를 제공하는 구현 클래스를 인스턴스화한 후, RMI가 제공하는 Naming/Context/Registry 클래스의 바인딩 또는 리바인드 메소드를 통해 방금 인스턴스화된 구현 클래스를 RMI 레지스트리에 등록하고 외부에 노출시킨다. 세계.이름;
3. 마지막으로 클라이언트는 RMI가 제공하는 Naming/Context/Registry 클래스의 조회 메소드를 사용하여 RMI 서비스에서 구현 클래스를 가져오기 위해 로컬 인터페이스와 알려진 이름(즉, RMI 레지스트리에 의해 노출된 이름)을 사용합니다. 이렇게 하면 이 클래스의 구현 클래스가 로컬에 없지만 모든 메서드가 인터페이스에 있고 개체의 메서드를 원격으로 호출할 수 있습니다.

2. 코드 엔지니어링

실험 목표

간단한 rmi 서비스를 실험하고 클라이언트를 통해 호출하십시오.

rmi-서버

rmi 서비스 인터페이스를 주로 제공하는 서버사이드 프로젝트입니다.

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>rmi</artifactId>
        <groupId>com.et</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
 
    <artifactId>rmi-server</artifactId>
 
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
 
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-autoconfigure</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>com.et</groupId>
            <artifactId>rmi-common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.h2database</groupId>
            <artifactId>h2</artifactId>
            <version>1.4.200</version>
        </dependency>
    </dependencies>
</project>

설정

package com.et.rmi.server.config;
 
import com.et.rmi.server.dao.CustomerRepository;
 
import com.et.rmi.server.model.Customer;
import com.et.rmi.server.service.CustomerServiceImpl;
import om.et.rmi.common.CustomerService;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.context.annotation.Bean;
import org.springframework.remoting.rmi.RmiServiceExporter;
import org.springframework.stereotype.Component;
 
import java.util.logging.Logger;
 
@Component
public class RmiServerApplicationRunner implements ApplicationRunner {
 
    private CustomerRepository repository;
    private CustomerServiceImpl customerService;
    private final Logger log = Logger.getLogger(this.getClass().getName());
 
    public RmiServerApplicationRunner(CustomerServiceImpl customerService) {
        this.customerService = customerService;
    }
 
    @Override
    public void run(ApplicationArguments args) throws Exception {
        Customer customer1 = new Customer("John", "Smith", "123-456-7890");
        customerService.saveCustomer(customer1);
        customerService.getCustomers().forEach(System.out::println);
    }
 
    @Bean
    public RmiServiceExporter customerServiceExporter() {
        RmiServiceExporter customerServiceExporter = new RmiServiceExporter();
        customerServiceExporter.setRegistryPort(1199);
        customerServiceExporter.setServiceName("customerService");
        customerServiceExporter.setServiceInterface(CustomerService.class);
        customerServiceExporter.setService(customerService);
        log.info("Started RMI Server");
        return customerServiceExporter;
    }
}

서비스

package com.et.rmi.server.service;
 
import com.et.rmi.server.dao.CustomerRepository;
 
import com.et.rmi.server.mapper.CustomerMapper;
import com.et.rmi.server.model.Customer;
import om.et.rmi.common.CustomerDTO;
import om.et.rmi.common.CustomerService;
import org.springframework.stereotype.Service;
 
import java.util.List;
 
@Service
public class CustomerServiceImpl implements CustomerService {
 
    private CustomerRepository repository;
 
    public CustomerServiceImpl(CustomerRepository repository) {
        this.repository = repository;
    }
 
    @Override
    public CustomerDTO getCustomer(long id) {
        Customer customer = repository.findById(id).orElseThrow(IllegalArgumentException::new);
        CustomerMapper mapper = new CustomerMapper();
        CustomerDTO dto = mapper.mapToDTO(customer);
        System.out.println(dto);
        return dto;
    }
 
    public List<Customer> getCustomers() {
        return (List<Customer>)repository.findAll();
    }
    public void saveCustomer(Customer customer) {
        repository.save(customer);
    }
}

다오

package com.et.rmi.server.dao;
 
import com.et.rmi.server.model.Customer;
import org.springframework.data.repository.CrudRepository;
import org.springframework.stereotype.Repository;
 
import java.util.Optional;
 
@Repository
public interface CustomerRepository extends CrudRepository<Customer, Long> {
    Optional<Customer> findById(long id);
}

매퍼

package com.et.rmi.server.mapper;
 
import com.et.rmi.server.model.Customer;
 
import om.et.rmi.common.CustomerDTO;
 
public class CustomerMapper {
 
    public CustomerMapper() {
    }
 
    public CustomerDTO mapToDTO(Customer customer){
        CustomerDTO dto = new CustomerDTO();
        dto.setFirstName(customer.getFirstName());
        dto.setLastName(customer.getLastName());
        dto.setSocialSecurityCode(customer.getSocialSecurityCode());
        return dto;
    }
}

모델

package com.et.rmi.server.model;
 
 
import javax.persistence.*;
 
@Entity
@SequenceGenerator(name = "CUST_SEQ", initialValue = 1_000_001)
public class Customer {
 
    @Id
    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "CUST_SEQ")
    private long id;
    private String firstName;
    private String lastName;
    private String socialSecurityCode;
 
    public Customer() {
    }
 
    public Customer(String firstName, String lastName, String socialSecurityCode) {
        this.firstName = firstName;
        this.lastName = lastName;
        this.socialSecurityCode = socialSecurityCode;
    }
 
    public long getId() {
        return id;
    }
 
    public String getFirstName() {
        return firstName;
    }
 
    public void setFirstName(String firstName) {
        this.firstName = firstName;
    }
 
    public String getLastName() {
        return lastName;
    }
 
    public void setLastName(String lastName) {
        this.lastName = lastName;
    }
 
    public String getSocialSecurityCode() {
        return socialSecurityCode;
    }
 
    public void setSocialSecurityCode(String socialSecurityCode) {
        this.socialSecurityCode = socialSecurityCode;
    }
 
    @Override
    public String toString() {
        return "Customer{" +
                "id=" + id +
                ", firstName='" + firstName + ''' +
                ", lastName='" + lastName + ''' +
                ", socialSecurityCode='" + socialSecurityCode + ''' +
                '}';
    }
}

애플리케이션.속성

spring.jpa.show-sql=false
spring.jpa.hibernate.ddl-auto=update
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.H2Dialect

rmi-클라이언트

이것은 주로 원격 rmi 서비스를 호출하는 클라이언트 프로젝트입니다.

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>rmi</artifactId>
        <groupId>com.et</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
 
    <artifactId>rmi-cilent</artifactId>
 
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
 
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-autoconfigure</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.et</groupId>
            <artifactId>rmi-common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>

제어 장치

package com.et.rmi.client.controller;
 
 
import om.et.rmi.common.CustomerDTO;
import om.et.rmi.common.CustomerService;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.remoting.rmi.RmiProxyFactoryBean;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
 
@Controller
@RequestMapping(value = "customers")
public class CustomerController {
 
    private RmiProxyFactoryBean proxyFactoryBean;
 
    public CustomerController(RmiProxyFactoryBean proxyFactoryBean) {
        this.proxyFactoryBean = proxyFactoryBean;
    }
 
    @RequestMapping(value = "{id}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
    public ResponseEntity<CustomerDTO> getCustomer(@PathVariable long id) {
        CustomerService service = (CustomerService) proxyFactoryBean.getObject();
        CustomerDTO dto = service.getCustomer(id);
        return ResponseEntity.ok(dto);
    }
}

설정

package com.et.rmi.client.config;
 
import om.et.rmi.common.CustomerService;
import org.springframework.context.annotation.Bean;
import org.springframework.remoting.rmi.RmiProxyFactoryBean;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
 
import java.util.logging.Logger;
 
@Component
public class Config {
 
    public final Logger log = Logger.getLogger(this.getClass().getName());
 
    @Bean
    public RmiProxyFactoryBean proxyFactoryBean() {
        String remoteHost = System.getProperty("RMI_SERVER_HOST");
        if(StringUtils.isEmpty(remoteHost)){
            remoteHost="127.0.0.1";
        }
        String rmiHost = String.format("rmi://%s:1199/customerService", remoteHost);
        log.info("RMI Host name is " + rmiHost);
        RmiProxyFactoryBean proxy = new RmiProxyFactoryBean();
        proxy.setServiceInterface(CustomerService.class);
        proxy.setServiceUrl(rmiHost);
        proxy.afterPropertiesSet();
        return proxy;
    }
}

애플리케이션.속성

server.port=8081

rmi-공통

이는 서버와 클라이언트가 모두 참조해야 하는 공개 패키지입니다.

package om.et.rmi.common;
 
import java.io.Serializable;
 
public class CustomerDTO implements Serializable {
 
    private String firstName;
    private String lastName;
    private String socialSecurityCode;
 
    public CustomerDTO() {
    }
 
    public String getFirstName() {
        return firstName;
    }
 
    public void setFirstName(String firstName) {
        this.firstName = firstName;
    }
 
    public String getLastName() {
        return lastName;
    }
 
    public void setLastName(String lastName) {
        this.lastName = lastName;
    }
 
    public String getSocialSecurityCode() {
        return socialSecurityCode;
    }
 
    public void setSocialSecurityCode(String socialSecurityCode) {
        this.socialSecurityCode = socialSecurityCode;
    }
 
    @Override
    public String toString() {
        final StringBuffer sb = new StringBuffer("CustomerDTO{");
        sb.append("firstName='").append(firstName).append(''');
        sb.append(", lastName='").append(lastName).append(''');
        sb.append(", socialSecurityCode='").append(socialSecurityCode).append(''');
        sb.append('}');
        return sb.toString();
    }
}

package om.et.rmi.common;
 
public interface CustomerService {
    CustomerDTO getCustomer(long id);
}

위의 내용은 일부 키 코드일 뿐입니다. 모든 코드는 아래 코드 저장소를 참조하세요.

코드 저장소

• GitHub - Harries/springboot-demo: redis, solr, rockmq 등의 일부 구성 요소가 포함된 간단한 springboot 데모입니다.

3. 테스트

• rmi 서버 서비스 시작
• rmi-client 서비스 시작
• http://127.0.0.1:8081/customers/1000001을 방문하세요.
• 반품{"firstName":"John","lastName":"Smith","socialSecurityCode":"123-456-7890"}

4. 견적

• 한국어: 한국어: https://www.tutorialspoint.com/java_rmi/java_rmi_introduction.htm
• 한국어: 한국어: https://docs.oracle.com/javase/8/docs/technotes/guides/rmi/index.html
• Spring Boot 통합 RMI 빠른 시작 데모 Harries Blog™ |