RestEasy 调用Rest接口使用详解[通俗易懂]

RestEasy 调用Rest接口使用详解[通俗易懂]RestEasy 调用Rest接口使用详解

大家好,又见面了,我是你们的朋友全栈君。

        最近项目中需要调用其他项目的Rest接口,之前一直在使用Apache的httpclient工具,该工具使用起来不是很方便,各种try{……} catch{……}结构,造成了代码量很大,而且有实际意义的代码却很少。

       最近请教别人,学习使用RESTEasy工具,进行调用REST接口,极大地减少了调用Rest接口的代码,项目中仅需要一个RestEasyClient.java工具类即可,其他package中是需要调用REST接口时,仅需要直接调用即可,代码中仅有一个try{……} catch{……},很好的维护了项目代码的整洁和实用。

1.实战

RESTEasy的Maven依赖:

 <dependency>
            <groupId>org.jboss.resteasy</groupId>
            <artifactId>jaxrs-api</artifactId>
            <version>3.0.7.Final</version>
        </dependency>
        <dependency>
            <groupId>org.jboss.resteasy</groupId>
            <artifactId>resteasy-jaxrs</artifactId>
            <version>3.0.19.Final</version>
            <!--<scope>provided</scope>-->
        </dependency>
        <dependency>
            <groupId>org.jboss.resteasy</groupId>
            <artifactId>resteasy-client</artifactId>
            <version>3.0.19.Final</version>
        </dependency>
        <dependency>
            <groupId>org.jboss.resteasy</groupId>
            <artifactId>resteasy-multipart-provider</artifactId>
            <version>3.0.19.Final</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>org.jboss.resteasy</groupId>
            <artifactId>resteasy-jackson2-provider</artifactId>
            <version>3.0.19.Final</version>
        </dependency>
        <dependency>
            <groupId>org.jboss.resteasy</groupId>
            <artifactId>resteasy-servlet-initializer</artifactId>
            <version>3.0.19.Final</version>
        </dependency>

RestEasyClient.java工具类: 

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.jboss.resteasy.client.jaxrs.ResteasyClient;
import org.jboss.resteasy.client.jaxrs.ResteasyClientBuilder;
import org.jboss.resteasy.client.jaxrs.ResteasyWebTarget;

import javax.ws.rs.client.Entity;
import javax.ws.rs.client.Invocation;
import javax.ws.rs.core.Response;
import java.util.Map;
import java.util.concurrent.TimeUnit;

/**
 * Created by lance.
 */
@Slf4j
public class RestEasyClient {

  private static ResteasyClient client = null;

  static {
    ResteasyClientBuilder resteasyClientBuilder = new ResteasyClientBuilder();
    resteasyClientBuilder.connectionPoolSize(300);
    resteasyClientBuilder.socketTimeout(5, TimeUnit.SECONDS);
    resteasyClientBuilder.maxPooledPerRoute(200);
    client = resteasyClientBuilder.build();
  }


  /**
   * @param url url地址参数
   * @return
   */

  public static JSONObject get(String url, Map<String, Object> headers) {
    Response response = null;
    try {
      ResteasyWebTarget target = client.target(url);
      Invocation.Builder builder = target.request();
      if (null != headers && !headers.isEmpty()) {
        headers.entrySet().forEach(entry -> builder.header(entry.getKey(), entry.getValue()));
      }
      response = builder.get();
      if (response != null) {
        JSONObject jsonObject = response.readEntity(JSONObject.class);
        log.info("http get result:{}", JSON.toJSONString(jsonObject));
        return jsonObject;
      }

    } catch (Exception e) {
      log.error("client.get() Error, url:{}", url);
      log.error("client.get() Error", e);
    } finally {
      if (response != null) {
        try {
          response.close();
        } catch (Exception e) {
          log.error("client.close() Error", e);
        }
      }
    }

    return new JSONObject();
  }


  /**
   * @param url       url地址参数
   * @param headers   请求中的header参数
   * @param entity    请求的具体参数内容
   * @param mediaType 之情请求的类型,如json
   * @return
   */


  public static JSONObject post(String url, Map<String, Object> headers, Object entity, String mediaType) {

    log.info("client.post() INFO, url:{}, headers:{}, entity:{}, mediaType:{}", url, headers, entity, mediaType);
    Response response = null;
    try {
      ResteasyWebTarget target = client.target(url);
      Invocation.Builder builder = target.request();
      if (null != headers && !headers.isEmpty()) {
        headers.entrySet().forEach(entry -> builder.header(entry.getKey(), entry.getValue()));
      }
      response = builder.post(Entity.entity(entity, mediaType));

      if (response != null) {
        JSONObject jsonObject = response.readEntity(JSONObject.class);
        log.info("http get result:{}", JSON.toJSONString(jsonObject));
        return jsonObject;
      }
    } catch (Exception e) {
      log.error("client.post() Error, url:{}, headers:{}, entity:{}, mediaType:{}", url, headers, entity, mediaType);
      log.error("client.post() Error", e);
    } finally {
      if (response != null) {
        try {
          response.close();
        } catch (Exception e) {
          log.error("client.close() Error", e);
        }
      }
    }

    return new JSONObject();

  }

   Test类:

public class Test {


    public static void main(String[] args) {
	
	//get test
	 Map map = RestEasyClient.get("http://10.118.32.254:8801/data/rest/");
         log.info("response:{}",map);
	 
	 
	 
	 
	//post test
	Map<String, Object> header = Maps.newHashMap(); 
        header.put("userId", "1000");
        Object item = new Object(); 
		
        Map map = RestEasyClient.post("http://10.118.32.254:8801/data/rest/", header, Sets.newHashSet(item), MediaType.APPLICATION_JSON);


        log.info("response:{}", map);
	
	}
	
}






版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/149577.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 一台服务器可以干什么

    一台服务器可以干什么

  • Wireshark分析SSL协议[通俗易懂]

    Wireshark分析SSL协议[通俗易懂]SSL:(SecureSocketLayer,安全套接字层),位于可靠的面向连接的网络层协议和应用层协议之间的一种协议层。SSL通过互相认证、使用数字签名确保完整性、使用加密确保私密性,以实现客户端和服务器之间的安全通讯。该协议由两层组成:SSL记录协议和SSL握手协议。TLS:(TransportLayerSecurity,传输层安全协议),用于两个应用程序之间提供保密性和数据完整性。该协议由两层组成:TLS记录协议和TLS握手协议。SSL/TLS位于传输层和应用层之间,应用层数据不再直接传递

  • computed radiography_select a reference library

    computed radiography_select a reference libraryaim:Inthispaper,ourgoalistoprovidesuchaphysicalsceneparse:tosegmentvisibleregionsintosurfacesandobjectsandtoinfertheirsupportrelations.Inparticular,weareinterestedinin…

  • Java实现一个简单的冒泡排序「建议收藏」

    Java实现一个简单的冒泡排序「建议收藏」代码思路创建一个bound,(0,bound)是待排序区间。遍历数组,如果前一个的值大于后一个,交换。直到将这个最大值挪到数组的最后。代码示例importjava.util.Arrays;publicclassSort{publicvoidBubbleSort(int[]arr){//遍历数组,如果前一个的值大于后一个,交换。直到将这个最大值…

  • A 星算法总结_数据结构与算法知识点总结

    A 星算法总结_数据结构与算法知识点总结A星算法总结A星算法FPGAEDA工具VPR布线器所采用的布线算法,面试滴滴的时候听说他们的路径规模用的也是A星算法,感觉这个算法还蛮厉害的,对这个算法进行一个总结。文章http://www.tuicool.com/articles/MJrYz26对这个算法用语言描述的很好,搬运下:  A星寻路算法显然是用来寻路的,应用也很普遍,比如梦幻西游。。。算法的思路很简单,就是在bfs的

  • python——Request模块「建议收藏」

    Requests:让HTTP服务人类虽然Python的标准库中urllib2模块已经包含了平常我们使用的大多数功能,但是它的API使用起来让人感觉不太好,而Requests自称“HTTPforHumans”,说明使用更简洁方便。Requests唯一的一个非转基因的PythonHTTP库,人类可以安全享用:)Requests继承了urllib2的所有特性。Reque…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号