SpringBoot—-JsonRpc跨语言远程调用协议 - Java天堂

来自 : www.javatt.com/p/29... 发布时间：2021-03-24

public void setMinRewardRate(BigDecimal minRewardRate) { this.minRewardRate = minRewardRate; public BigDecimal getMaxRewardRate() { return maxRewardRate; public void setMaxRewardRate(BigDecimal maxRewardRate) { this.maxRewardRate = maxRewardRate; public List Integer getStatusList() { return statusList; public void setStatusList(List Integer statusList) { this.statusList = statusList; @Override public String toString() { return \"ProductRpcReq [idList=\" + idList + \", minRewardRate=\" + minRewardRate + \", maxRewardRate=\" + maxRewardRate + \", statusList=\" + statusList + \"]\";

b）项目2-manager（rpc实现工程）

ProductRpcImpl.java

package com.imooc.rpc;import java.util.List;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.domain.Page;import org.springframework.data.domain.PageRequest;import org.springframework.data.domain.Pageable;import org.springframework.data.domain.Sort;import org.springframework.stereotype.Service;import com.googlecode.jsonrpc4j.spring.AutoJsonRpcServiceImpl;import com.imooc.api.ProductRpc;import com.imooc.api.domain.ProductRpcReq;import com.imooc.entity.Product;import com.imooc.service.ProductService; * rpc服务实现类 * @author zemel@AutoJsonRpcServiceImpl@Servicepublic class ProductRpcImpl implements ProductRpc{ private static Logger log = LoggerFactory.getLogger(ProductRpcImpl.class); @Autowired private ProductService productService; @Override public List Product query(ProductRpcReq req) { log.info(\"查询多个产品，请求:{}\", req); Pageable pageable = new PageRequest(0, 1, Sort.Direction.DESC, \"rewardRate\"); Page Product page = productService.query(req.getIdList(), req.getMinRewardRate(),  req.getMaxRewardRate(), req.getStatusList(), pageable); log.info(\"查询多个产品，结果:{}\", page); return page.getContent(); @Override public Product findOne(String id) { log.info(\"查询产品详情，请求:{}\", id); Product result = productService.findOne(id); log.info(\"查询产品详情，结果:{}\", result); return result;

RpcConfig.java

package com.imooc.config;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import com.googlecode.jsonrpc4j.spring.AutoJsonRpcServiceImplExporter; * rpc相关配置 * @author zemel@Configurationpublic class RpcConfig { @Bean public AutoJsonRpcServiceImplExporter rpcServiceImplExporter(){ return new AutoJsonRpcServiceImplExporter();

server.port=80server.servlet.contextPath=/manager# DataSource spring.datasource.url=jdbc:mysql://localhost/manager?characterEncoding=utf-8 useSSL=false serverTimezone=UTC spring.datasource.username=rootspring.datasource.password=#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driverspring.datasource.driver-class-name=com.mysql.jdbc.Driver#jackson自定义日期格式spring.jackson.date-format=yyyy-MM-dd HH:mm:ssspring.jackson.time-zone=GMT+8# JPAspring.jpa.show-sql=truespring.jpa.hibernate.ddl-auto=update# 配置swaggerswagger.groupName=managerswagger.basePackage=com.imooc.controller

c）rpc客户端-saller

ProductRpcService.java

package com.imooc.seller.service;import java.util.ArrayList;import java.util.List;import javax.annotation.PostConstruct;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.domain.Page;import org.springframework.data.domain.PageRequest;import org.springframework.data.domain.Pageable;import org.springframework.data.domain.Sort;import org.springframework.stereotype.Service;import com.imooc.api.ProductRpc;import com.imooc.api.domain.ProductRpcReq;import com.imooc.entity.Product;import com.imooc.entity.enums.ProductStatus; * 产品服务 * @author zemel@Servicepublic class ProductRpcService { private static Logger log = LoggerFactory.getLogger(ProductRpcService.class); @Autowired private ProductRpc productRpc; * 查询全部产品 * @return public List Product findAll(){ ProductRpcReq req = new ProductRpcReq(); List Integer status = new ArrayList ();// status.add(ProductStatus.IN_SELL.getCode());// req.setStatusList(status); log.info(\"rpc查询全部产品，请求:{}\", req); List Product result = productRpc.query(req); log.info(\"rpc查询全部产品，结果:{}\", result); return result; @PostConstruct public void testFindAll(){ findAll();