首页 > 编程语言> 文章详细

Java实现远程服务生产与消费(RPC)的4种方法-RMI,WebService,HttpClient,RestTemplate

2019-04-30 15:44:20 阅读：206 来源： 互联网

标签：服务 String RestTemplate public RPC new rmi 远程 WebService

一. 通过rmi实现远程服务的生产与消费
- 远程服务提供者实现.
  - 创建rmi-provider项目(Maven)
- 远程服务消费者实现
  - 创建rmi-consumer项目
二. 通过WebService实现远程服务的生产与消费
三. 通过HttpClient实现远程服务的生产与消费
- 远程服务提供者实现
- 远程服务消费者实现
四. 通过spring提供的RestTemplate实现远程服务的生产与消费
- 远程服务消费者实现.

本文将通过具体的远程服务发布与消费案例展示4种RPC远程调用方法.

一. 通过rmi实现远程服务的生产与消费

Java自身提供了java.rmi包, 方便开发者进行远程服务的部署与消费, 下面将通过具体案例进行讲解.

远程服务提供者实现.

创建rmi-provider项目(Maven)

创建UserService接口.

//将要发布的服务的接口
public interface UserService extends Remote {
    public String helloRmi(String name) throws RemoteException;
}

创建UserServiceImpl实现类

注意, UserServiceImpl除了实现UserService接口外, 还要继承UnicastRemoteObject类, 你可以理解为它是一个发布出去供他人调用的类, 当UserServiceImpl实现了这个类后, UserServiceImpl就能被发布出去供别人调用.

//将要发布的服务的实现类
public class UserServiceImpl extends UnicastRemoteObject implements UserService {
    public UserServiceImpl() throws RemoteException {
        super();
    }

    public String helloRmi(String name) throws RemoteException {
        return "hello " + name;
    }
}

发布远程服务

public static void main(String[] args) {
    try {
        //完成远程服务的发布
        LocateRegistry.createRegistry(8888);//将远程服务发布在本地的8888端口
        String name = "rmi://localhost:8888/rmi";//发布的远程服务被访问的url
        UserService userService = new UserServiceImpl();//创建一个提供具体服务的远程对象
        Naming.bind(name, userService);//给远程服务绑定一个url
        System.out.println("--- 已发布rmi远程服务 ---");
    } catch (Exception e) {
        e.printStackTrace();
    }
}

远程服务消费者实现

创建rmi-consumer项目

把rmi-provider项目种的UserService接口与UserServiceImpl实现类复制到本rmi-consumer项目中.(这一步可以进行优化解耦, 我们可以多创建一个rmi-resource项目, 让rmi-provider和rmi-consumer共同依赖rmi-resource项目, 然后把资源文件比如远程服务所用到的UserService等放入rmi-resource项目中)
远程服务消费者对远程服务发起调用.

public static void main(String[] args) {
    try {
        //发布远程服务的访问url
        String name = "rmi://localhost:8888/rmi";
        //通过发布远程服务的url, 获取远程服务的代理对象
        UserService userService = (UserService) Naming.lookup(name);
        System.out.println("获得的远程服务的代理对象:" + userService.getClass().getName());
        String result = userService.helloRmi("rmi");//拿到远程方法调用的结果
        System.out.println("result: " + result);

    }catch (Exception e) {
        e.printStackTrace();
    }
}

//最后输出
获得的远程服务的代理对象:com.sun.proxy.$Proxy0
result: hello rmi

通过最后的输出我们看到获得的远程服务对象是动态代理产生的.

二. 通过WebService实现远程服务的生产与消费

WebService协议是RPC的一种具体实现, 服务提供方和消费方通过http + xml进行通信.

远程服务提供者实现.

首先创建远程服务接口UserService及其实现类UserServiceImpl.

注意, 使用WebService时需要对远程服务加上注解@WebService

@WebService
public interface UserService {
    public String sayHello(String name);
}

@WebService
public class UserServiceImpl implements UserService {
    @Override
    public String sayHello(String name) {
        return "hello " + name + "~";
    }
}

发布远程服务, 过程和rmi差不多, 需要提供远程服务的访问地址和具体的远程服务实现类, 使用Endpoint类的publish()方法进行发布, 这都是JDK封装好的.

public class WsProviderApp {
    public static void main(String[] args) {
        //发布的WebService的被访问地址
        String address = "http://localhost:9999/ws";
        //创建远程服务对象
        UserService userService = new UserServiceImpl();
        //发布服务
        Endpoint.publish(address, userService);
        System.out.println("远程服务已经发布...");
    }
}

查看远程服务文档wdsl

和rmi不同的是, WebService发布后, 调用者可以通过查看它的文档对远程服务发起调用.
查看的方法是在浏览器中输入远程服务的访问地址加上?wdsl, 比如本案例中是http://localhost:9999/ws?wsdl
注意, 在客户端调用远程方法时需要用工具对wdsl文档进行解析, 并获得调用远程方法的工具类. 具体操作见下一段.

远程服务消费者实现.

首先根据文档获得调用远程服务的工具类, JDK已经为我们封装好了获取的工具, 它在bin目录下, 名字是wsimport
打开命令行, 在命令行中输入解析命令

wsimport -keep -d C:\githubRepositories\shopping\ws-consumer\src\main\java -p com.shenghao.client http://localhost:9999/ws?wsdl

解释:
1. wsimport 是命令的名字
2. -keep 用于保留生成的类, 如果没有该指令会只生成class文件
3. -d 后面接项目中存放这些工具类的包, 填绝对路径
4. -p 填wdsl文档的地址

可以看到命令执行完后, 指定的包中出现一堆相关的类, 最直接调用到的类是UserServiceImplService. 下面演示对远程方法进行调用.

public static void main(String[] args) {
    //创建服务类对象
    UserServiceImplService service = new UserServiceImplService();
    //获得远程服务的代理对象
    UserServiceImpl userService = service.getUserServiceImplPort();
    System.out.println(userService.getClass().getName());
    //对远程服务对象的方法进行调用
    String result = userService.sayHello("炭烧生蚝");
    System.out.println(result);
}

//结果输出
com.sun.proxy.$Proxy32
hello 炭烧生蚝~

三. 通过HttpClient实现远程服务的生产与消费

这里我们换一个案例进行演示. 假设现在有一套用户系统和一套订单系统, 要实现用户系统访问订单系统以获得某个用户的订单信息.

远程服务提供者实现

提供远程服务的过程和响应web请求很相似, 只不过响应的不是<html>标签, 而是json字符串. 微信小程序前后端通信也是这个原理.

创建名为order-sys的Maven项目, 指定打包为war包.

点击这里查看pom.xml文件, 常规操作

4.3.18.RELEASE 1.2 2.5 2.0 2.9.0 jstl jstl ${jstl.version} javax.servlet servlet-api ${servlet-api.version} provided javax.servlet jsp-api ${jsp-api.version} provided org.springframework spring-webmvc ${spring.version} com.fasterxml.jackson.core jackson-databind ${jackson.version} order org.apache.tomcat.maven tomcat7-maven-plugin 2.2 /order 7070

创建订单类

public class Order {
    private String id;
    private Double total;
    private String date;

    //get / set ...
}

对外提供服务, 发布时打包发布到Tomcat上

@Controller
public class OrderController {
    /**
     * 接收http请求, 响应订单集合, 异步响应
     * 将list集合序列化为json串响应
     * @param uid
     * @return
     */
    @RequestMapping("/loadOrderList2")
    @ResponseBody
    public List<Order> loadOrderList2(String uid){
        System.out.println("uid: " + uid);

        //模拟订单数据
        Order o1 = new Order();
        o1.setId("111");
        o1.setTotal(333.33);
        o1.setDate("2019-4-29");

        Order o2 = new Order();
        o2.setId("222");
        o2.setTotal(444.44);
        o2.setDate("2019-5-29");

        Order o3 = new Order();
        o3.setId("333");
        o3.setTotal(555.55);
        o3.setDate("2019-6-29");

        List<Order> list = new ArrayList<>();
        list.add(o1);
        list.add(o2);
        list.add(o3);

        return list;
    }
}

远程服务消费者实现

在服务消费端使用HttpClient发送请求, 可以理解为模拟浏览器发送post/get请求. HttpClient为我们封装了拼接一个请求的细节, 使得发送一个请求变得容易.

public static void main(String[] args) throws IOException {
    //发送远程的http请求的地址
    String url = "http://localhost:7070/order/loadOrderList2";
    //创建HttpClient对象
    CloseableHttpClient client = HttpClients.createDefault();
    //创建HttpPost对象, 发送post请求
    HttpPost method = new HttpPost(url);
    //封装发送到服务提供者的参数
    NameValuePair id = new BasicNameValuePair("uid", "10001");
    List<NameValuePair> params = new ArrayList<>();
    params.add(id);
    //封装请求体数据
    method.setEntity(new UrlEncodedFormEntity(params, "UTF-8"));
    //发送具体的http请求
    HttpResponse response = client.execute(method);

    //获得服务提供者响应的具体数据
    HttpEntity entity = response.getEntity();
    //获得http的响应体
    InputStream is = entity.getContent();

    int len = 0;
    char[] buf = new char[1024];
    //使用字符流读
    InputStreamReader reader = new InputStreamReader(is);
    StringBuffer sb = new StringBuffer();
    while((len = reader.read(buf)) != -1){
        sb.append(String.valueOf(buf, 0, len));
    }
    System.out.println(sb);

    //将响应回来的json字符串解析为Order集合
    List<Order> list = JSON.parseArray(sb.toString(), Order.class);
    for(Order o : list){
        System.out.println(o.getId() + "\t" + o.getTotal() + "\t" + o.getDate());
    }
}

四. 通过spring提供的RestTemplate实现远程服务的生产与消费

通过一个红包系统和订单系统进行演示, 红包系统访问订单系统, 获得某个用户的订单信息, 派发红包.
订单系统继续沿用HttpClient中的订单系统, 通过访问loadOrderList2方法能返回一个订单集合Json字符串.

远程服务消费者实现.

@Controller
public class RedController {
    //注入由spring提供的RestTemplate对象
    @Autowired
    private RestTemplate restTemplate;
    /**
     * 发送远程的http请求, 消费http服务
     * 获得订单对象的集合
     */
    @RequestMapping("/loadOrderList3")
    @ResponseBody
    public List<ResponseEntity<Order[]>> loadOrderList3(String uid){
        //发送远程http请求的url
        String url = "http://localhost:7070/order/loadOrderList2";
        //发送到远程服务的参数
        MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
        params.add("uid", uid);

        //通过RestTemplate对象发送post请求
        ResponseEntity<Order[]> entitys = restTemplate.postForEntity(url, params, Order[].class);

        //查看响应的状态码
        System.out.println(entitys.getStatusCodeValue());

        //查看响应头
        HttpHeaders headMap = entitys.getHeaders();
        for(Map.Entry<String, List<String>> m : headMap.entrySet()){
            System.out.println(m.getKey() + ": " + m.getValue());
        }

        return Arrays.asList(entitys);
    }
}

标签：服务,String,RestTemplate,public,RPC,new,rmi,远程,WebService
来源： https://www.cnblogs.com/tanshaoshenghao/p/10796319.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Java实现远程服务生产与消费(RPC)的4种方法-RMI,WebService,HttpClient,RestTemplate

一. 通过rmi实现远程服务的生产与消费

远程服务提供者实现.

创建rmi-provider项目(Maven)

远程服务消费者实现

创建rmi-consumer项目

二. 通过WebService实现远程服务的生产与消费

远程服务提供者实现.

查看远程服务文档wdsl

远程服务消费者实现.

三. 通过HttpClient实现远程服务的生产与消费

远程服务提供者实现

远程服务消费者实现

四. 通过spring提供的RestTemplate实现远程服务的生产与消费

远程服务消费者实现.