RPC快速入门

概述

关于rpc，只需要知道他是一种协议，项目之间能够远程调用函数。

快速入门

我们前边下载好的两个包，在idea中打开之后，我们创建这么几个文件夹。

至于是干什么的，以后细说。创建好之后我们在product-client子包中创建RemoteProductService接口：

package com.example.product.feign;

import com.example.product.feign.common.CommonResult;
import com.example.product.feign.entity.Price;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;

import java.util.List;

@FeignClient(value = "product-service")
public interface RemoteProductService {

    @GetMapping("/hello")
    String hello();
    
}

然后再product-service的controller中创建HelloController类并实现接口RemoteProductService：

package com.example.product.controller;

import com.example.product.feign.common.CommonResult;
import com.example.product.feign.entity.Price;
import com.example.product.feign.RemoteProductService;
import com.example.product.service.ProductService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
public class ProductController implements RemoteProductService {

    @Autowired
    private ProductService productService;


    @GetMapping("/hello")
    @Override
    public String hello() {
        return "hello world";
    }

}

完成之后，需要打开product的pom.xml文件，将下面几行注释掉，然后install，完成之后打开注释再次install。
![[Pasted image 20240326095803.png]]
接下来就是对order的操作，我们需要再order的pom.xml文件中导入

<dependency>
    <groupId>com.example</groupId>
    <artifactId>product-client</artifactId>
    <version>0.0.1-SNAPSHOT</version>
</dependency>

这个就是我们刚刚打包的jar包，然后在order-service中导入依赖，等待依赖导入完成。完成之后在controller下创建一个controller进行测试：

<dependency>
    <groupId>com.example</groupId>
    <artifactId>product-client</artifactId>
</dependency>

package com.example.order.controller;

import com.example.order.param.OrderParam;
import com.example.order.service.OrderService;
import com.example.order.vo.OrderResultVO;
import com.example.product.feign.RemoteProductService;
import com.example.product.feign.common.CommonResult;
import com.example.product.feign.entity.Price;
import lombok.extern.slf4j.Slf4j;
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import java.util.List;

@RestController
@Slf4j
public class OrderController {

    @Resource
    private RemoteProductService remoteProductService;

    @GetMapping("/test")
    public String test(){
        log.info(remoteProductService.toString());
        return remoteProductService.hello();
    }

}

然后我们启动项目使用ApiPost软件进行接口的测试，记得启动本地的nacos。
我们先测试product的端口（9094):

然后呢测试order的端口（9093）：