प्रौद्योगिकी साझेदारी

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

1.RMI इति किम् ?

RMI (Remote Method Invocation) इति दूरस्थविधिआह्वानं भवति, यत् वितरितप्रोग्रामिङ्गस्य मूलभूतविचारः अस्ति । दूरस्थविधिआह्वानस्य कार्यान्वयनार्थं बहवः प्रौद्योगिकीः सन्ति, यथा CORBA तथा WebService, ययोः द्वयोः अपि प्रत्येकस्य प्रोग्रामिंगभाषायाः स्वतन्त्रता अस्ति । जावा आरएमआई एकं दूरस्थविधिआह्वानतन्त्रम् अस्ति यत् विशेषतया जावावातावरणस्य कृते डिजाइनं कृतम् अस्ति यत् इदं दूरस्थप्रक्रियाकॉल (RPC) कार्यान्वितुं प्रयुक्तं भवति । अस्य कार्यान्वयनम् JVM निर्भरं भवति, अतः एकस्मात् JVM तः अन्यतमं प्रति आह्वानं समर्थयति । जावा RMI इत्यस्मिन् दूरस्थः सर्वरः विशिष्टानि जावा पद्धतीनि कार्यान्वितं करोति तथा च क्लायन्ट् केवलं दूरस्थविधिं आह्वयितुं अन्तरफलकवर्गस्य परिभाषानुसारं तत्सम्बद्धान् पैरामीटर् प्रदातुं प्रवृत्तः भवति अतः विक्रमीकरण-दुर्बलतायाः सामान्य-शोषणं प्रायः RMI-सम्बद्धं भवति, तस्य च तात्पर्यम् । RMI यस्मिन् संचारप्रोटोकॉलस्य उपरि अवलम्बते सः JRMP (Java Remote Message Protocol, Java Remote Message Exchange Protocol) अस्ति ।

अन्तरक्रियाशील प्रक्रिया

अन्तरक्रियाप्रक्रियायाः संक्षेपेण सारांशः कर्तुं शक्यते यथा - १.

1. प्रथमं, RMI Registry सेवा आरभत यदा, भवान् तत् पोर्ट् निर्दिष्टुं शक्नोति यस्मिन् सेवा शृणोति, अथवा भवान् पूर्वनिर्धारित पोर्ट् (1099) उपयोक्तुं शक्नोति;
2. द्वितीयं, सर्वरपक्षः प्रथमं एकं कार्यान्वयनवर्गं उदाहरणं ददाति यत् स्थानीयरूपेण सेवां प्रदाति, ततः RMI द्वारा प्रदत्तस्य Naming/Context/Registry वर्गस्य bind अथवा rebind पद्धत्या RMI Registry मध्ये केवलं instantiated कार्यान्वयनवर्गं पञ्जीकरणं करोति तथा च बहिः उजागरयति जगत् नाम;
3. अन्ते, क्लायन्ट् स्थानीय-अन्तरफलकस्य उपयोगं करोति तथा च ज्ञातं नाम (अर्थात् RMI रजिस्ट्री द्वारा उजागरितं नाम) RMI द्वारा प्रदत्तस्य Naming/Context/Registry वर्गस्य लुकअप-विधिं उपयुज्य RMI सेवातः कार्यान्वयनवर्गं प्राप्तुं एवं प्रकारेण यद्यपि स्थानीयतया अस्य वर्गस्य कार्यान्वयनवर्गः नास्ति तथापि सर्वाणि मेथड्स् अन्तरफलके सन्ति, तथा च वस्तुनः मेथड्स् दूरतः आह्वयितुं शक्यन्ते

2. कोड अभियांत्रिकी

प्रयोगात्मकाः लक्ष्याः

सरलेन 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>

config

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 सेवां आह्वयति ।

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

config

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

र्मि-सामान्य

इदं सार्वजनिकं संकुलं यस्य सन्दर्भः सर्वरः क्लायन्ट् च द्वयोः अपि अवश्यं कर्तव्यः ।

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: एकः सरलः springboot डेमो यस्य केचन घटकाः उदाहरणार्थं: redis,solr,rockmq इत्यादयः ।

3. परीक्षणम्

• rmi-server सेवा आरभत
• 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_परिचय.htm
• https://docs.oracle.com/javase/8/docs/technotes/guides/rmi/index.html इति ग्रन्थः इति ग्रन्थः
• Spring Boot एकीकृत rmi त्वरित आरम्भ प्रदर्शन |