脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → restTemplate实现跨服务API调用

restTemplate实现跨服务API调用方式

 更新时间：2023年07月20日 14:46:44   作者：GoodStudyAndDayDayUp  
这篇文章主要介绍了restTemplate实现跨服务API调用方式，具有很好的参考价值，希望对大家有所帮助。

restTemplate跨服务API调用

同时使用ribbon，实现接口调用的负载均衡。

1 注册中心

略…

2 消费端

2.1 pom

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-ribbon</artifactId>
        </dependency>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Brixton.SR5</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

2.2 application.properties

spring.application.name=ribbon-consumer
server.port=9000
# 本地启动注册中心
eureka.client.service-url.defaultZone=http://localhost:1111/eureka/

2.3 启动类

package com.example.lei;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
@EnableDiscoveryClient
@SpringBootApplication
public class RibbonConsumerApplication {
    @Bean
    @LoadBalanced
    RestTemplate restTemplate(){
        return new RestTemplate();
    }
    public static void main(String[] args) {
        SpringApplication.run(RibbonConsumerApplication.class, args);
    }
}

2.4 消费

package com.example.lei.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
/**
 * @Author: leimin
 * @Description: new class
 * @Date: 2020/6/8 16:04
 * @Version: 1.0
 */
@RestController
public class ConsumerController {
    /**
     * xx
     */
    @Autowired
    RestTemplate restTemplate;
    /**
     * yyy
     * @return rr
     */
    @RequestMapping(value = "/ribbon-consumer", method = RequestMethod.GET)
    private String helloConsumer(){
        return restTemplate.getForEntity("http://HELLO-SERVICE/hello",String.class).getBody();
    }
}

3 服务端

3.1 pom

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
            <version>2.2.0.RELEASE</version>
        </dependency>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Brixton.SR5</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

3.2 application.properties

spring.application.name=hello-service
# 服务注册到两台注册中心
eureka.client.service-url.defaultZone=http://peer1:1111/eureka/,http://peer2:1112/eureka

3.3 启动类

package com.didispace.springboothello;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
/**
 * 能够被发现为客户端
 */
@EnableDiscoveryClient
@SpringBootApplication
public class SpringBootHelloApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringBootHelloApplication.class, args);
    }
}

3.4 服务

package com.didispace.springboothello.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import java.util.logging.Logger;
/**
 * @Author: leimin
 * @Description: new class
 * @Date: 2020/6/8 9:08
 * @Version: 1.0
 */
@RestController
public class HelloController {
    /**
     * xx
     */
    private final Logger logger = Logger.getLogger(String.valueOf(getClass()));
    /**
     * xx
     */
    @Autowired
    private DiscoveryClient client;
    /**
     * xx
     * @return xx
     */
    @RequestMapping(value = "/hello",method = RequestMethod.GET)
    public String index(){
        ServiceInstance instance = client.getLocalServiceInstance();
        logger.info("/hello,host:" + instance.getHost()+", service_id:" +instance.getServiceId());
        return "hello World !";
    }
}

restTemplate实现跨域调用接口

本文主要针对post方式，发送请求。

import com.alibaba.fastjson.JSONObject;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.ResponseEntity;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import java.util.HashMap;
import java.util.Map;
/**
 * 调用mufly_api接口
 * Created by 耿洪生 on 2016/10/17.
 */
@Component
public class HttpEntityServiceImpl {
    @Value("${muflyapi.appid}")
    private String appID;
    public ResponseEntity<String> responseHttpEntity(String url, Object parameters) {
        Map<String, Object> requestObject = new HashMap<>();
        requestObject.put("appID", appID);
        requestObject.put("parameters", parameters);
        //转json字符串
        JSONObject jsonObject = (JSONObject) JSONObject.toJSON(requestObject);
        String jsonStr = jsonObject.toJSONString();
        //设置HttpHeader
        HttpHeaders headers = new HttpHeaders();
        headers.set("Content-Type", "application/json;charset=UTF-8");
        //设置HttpEntity
        HttpEntity<String> entity = new HttpEntity<String>(jsonStr, headers);
        //设置连接、读取超时时间
        SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
        factory.setConnectTimeout(30 * 1000);
        factory.setReadTimeout(60 * 1000);
        //接口调用
        RestTemplate temp = new RestTemplate(factory);
        ResponseEntity<String> output = temp.postForEntity(url, entity, String.class);
        return output;
    }
}

如果，你不想new，可以使用@Autowired直接引入：

@Autowired
private RestTemplate restTemplate;
/**
 * post请求
 *
 * @param url
 * @param data  map类型
 * @param token
 * @return 实体
 */
public ResponseEntity<String> post(String url, Map data, String token) {
    HttpHeaders headers = new HttpHeaders();
    headers.add("Accept", "application/json");
    headers.add("Accept-Encoding", "gzip");
    headers.add("Content-Encoding", "UTF-8");
    headers.add("Content-Type", "application/json;charset=UTF-8");
    headers.add("Token", token);
    String dataStr = JsonUtil.toJSon(data);
    HttpEntity<String> postEntity = new HttpEntity<>(dataStr, headers);
    return restTemplate.postForEntity(url, postEntity, String.class);
}

至于设置restTemplate bean 的超时：

@Bean(name="restTemplate")
RestTemplate restTemplate() {
   ClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
       //设置连接、读取超时时间
       ((SimpleClientHttpRequestFactory) factory).setConnectTimeout(30 * 1000);
       ((SimpleClientHttpRequestFactory) factory).setReadTimeout(60 * 1000);
   return new RestTemplate();
}

spring自带的restTemplate里有很多实用的方法，

其底层还是ClientHttpRequest,

总结

以此记录。以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • intellij idea旗舰版解决学生无法注册问题详解

    intellij idea旗舰版解决学生无法注册问题详解

    这篇文章主要介绍了intellij idea旗舰版解决学生无法注册问题详解，文中通过图文示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-07-07
  • java多线程之CyclicBarrier的使用方法

    java多线程之CyclicBarrier的使用方法

    这篇文章主要介绍了java多线程之CyclicBarrier的使用方法的相关资料,希望通过本文能帮助到大家，让大家理解掌握这部分内容，需要的朋友可以参考下
    2017-10-10
  • JAVA使用JDBC技术操作SqlServer数据库实例代码

    JAVA使用JDBC技术操作SqlServer数据库实例代码

    本篇文章主要介绍了JAVA使用JDBC技术操作SqlServer数据库实例代码，具有一定的参考价值，有兴趣的可以了解一下。
    2017-01-01
  • Java异常（Exception）处理以及常见异常总结

    Java异常（Exception）处理以及常见异常总结

    在《Java编程思想》中这样定义异常,阻止当前方法或作用域继续执行的问题,虽然java中有异常处理机制,但是要明确一点,决不应该用"正常"的态度来看待异常,这篇文章主要给大家介绍了关于Java异常（Exception）处理以及常见异常的相关资料,需要的朋友可以参考下
    2021-10-10
  • feign post参数对象不加@RequestBody的使用说明

    feign post参数对象不加@RequestBody的使用说明

    这篇文章主要介绍了feign post参数对象不加@RequestBody的使用说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-10-10
  • Java windows环境构建图文教程

    Java windows环境构建图文教程

    这篇文章主要为大家介绍了Java windows环境构建图文教程,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪<BR>
    2023-12-12
  • SpringMVC源码解析之消息转换器HttpMessageConverter

    SpringMVC源码解析之消息转换器HttpMessageConverter

    本篇文章主要介绍了SpringMVC源码解析之消息转换器HttpMessageConverter ，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-11-11
  • Java之打印String对象的地址

    Java之打印String对象的地址

    这篇文章主要介绍了Java之打印String对象的地址,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-09-09
  • Java Timer使用讲解

    Java Timer使用讲解

    Timer是一种工具，线程用其安排以后在后台线程中执行的任务。可安排任务执行一次，或者定期重复执行，这篇文章主要介绍了Java Timer使用讲解,需要的朋友可以参考下
    2022-11-11
  • Java cookie和session会话技术介绍

    Java cookie和session会话技术介绍

    session的工作原理和cookie非常类似,在cookie中存放一个sessionID,真实的数据存放在服务器端,客户端每次发送请求的时候带上sessionID,服务端根据sessionID进行数据的响应
    2023-04-04

最新评论