Technology sharing

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

1. Quid est RMI?

RMI ( Methodus remota Invocatio ) est methodus invocationis remota, quae est idea fundamentalis in programmatione distributa. Multae technologiae sunt ad vocationis methodum remotam exsequendam, sicut CORBA et WebService, quae utraque independentes sunt ab omni lingua programmandi. Java RMI methodus vocationis remota est mechanismum ad environment Javae specialiter destinatum. Est Java API ad modum procedendi remotis instrumenti adhibitis (RPC). Exsequens est JVM dependens, sic sustinet ab uno JVM ad alium vocat. In Java RMI, instrumentum servientis remotum modos specificas Javae et interfaces praebet. Cliens tantum opus est parametris correspondentibus secundum definitionem classis interfaciei ut methodum remotam appellet. Solet itaque abusio vulnerabilities deserializationis saepe involvit RMI, et id quid significat. Communicatio protocollo quod RMI innititur est JRMP (Nuntius Protocol remotus Java, Nuntius Protocol remotus Java).

interactive processus

Processus commercii breviter perstringi potest:

1. Primum, incipe RMI Subcriptio officium.
2. Secundo, ministri lateris primum instantiat genus exsequendum quae localiter officia praebet, ac deinde mandare iustam exsecutionem instantium classis ad RMI Subcriptio per modum ligandi vel rescindendi Denominationis/Context/Registry classium a RMI provisum et eam extrinsecus exponit. mundi nomen;
3. Demum, cliens utitur loci interface et noto nomine (hoc est, nomine RMI Registry exposito) ut exsequenda classis a RMI Muneris utendo speculandi methodo nominationis/Context/Regiae classis a RMI provideatur. Ita, quamvis genus hoc localiter non exsequendum sit, omnes modi interfaciendi sunt, et res remotae modos dici possunt;

2. Code engineering

Experimentalis proposita

Experimentum simplici rmi servitii et per clientem vocant

rmi-servo

Hoc est a servo-side project quod maxime praebet rmi ministerium interface

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>

aboutaboutconfig

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

servitium

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

dao

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

mapper

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

exemplar

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

application.properties " "

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

rmi-clientem

Hoc est consilium clientis, quod maxime vocat officium remotum 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>

controller

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

aboutaboutconfig

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

application.properties " "

server.port=8081

rmi-communis

Haec sarcina publica est quam servi et clientes debent referri.

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

Superius in quibusdam codicibus clavis tantum.

codice repositio

• GitHub - Harries/springboot-demo: simplex springboot demo cum quibusdam componentibus verbi: redis, solr, rockmq et cetera.

3. Test

• Satus Rmi-servo ministerium
• Satus Rmi-clientis ministerium
• Visita http://127.0.0.1:8081/mos/1000001
• reditus{"firstName":"John","lastName":"Smith","socialSecurityCode":"123-456-7890"}

4. Quotes

• https://www.tutorialspoint.com/java_rmi/java_rmi_introduction.htm
• https://docs.oracle.com/javase/8/docs/technotes/guides/rmi/index.html
• Spring Boot integrated rmi quick start demo |