关键词搜索

源码搜索 ×
×

Java快速验证项目API服务是否发布成功

发布2018-07-24浏览820次

详情内容

这里有三个知识点：a.HTTP的协议请求方式;b.Jackson的使用；c.Java的HttpClient模拟Http请求响应。最近通过.Net  MVC 实现了一套应用服务接口，因为Java同事始终无法正确的访问，我只好自己动手给写了个示例程序。Java也是我一直热爱从事开发的语言，因为工作需要通过.Net MVC提供了一套基于音视频服务的接口，所以在此记录下。

Maven 依赖配置

加入两类配置HttpClient和Jackson。

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.orghttps://files.jxasp.com/image/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <modelVersion>4.0.0</modelVersion>
  6.  
  7.     <groupId>com.boonya.httpclient</groupId>
  8.     <artifactId>HttpClientTest</artifactId>
  9.     <version>1.0-SNAPSHOT</version>
  10.  
  11.     <properties>
  12.         <jackjson.version>2.8.8</jackjson.version>
  13.     </properties>
  14.  
  15.     <dependencies>
  16.         <dependency>
  17.             <groupId>org.apache.httpcomponents</groupId>
  18.             <artifactId>httpclient</artifactId>
  19.             <version>4.5.2</version>
  20.         </dependency>
  21.         <dependency>
  22.             <groupId>com.fasterxml.jackson.core</groupId>
  23.             <artifactId>jackson-core</artifactId>
  24.             <version>${jackjson.version}</version>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>com.fasterxml.jackson.core</groupId>
  28.             <artifactId>jackson-annotations</artifactId>
  29.             <version>${jackjson.version}</version>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>com.fasterxml.jackson.core</groupId>
  33.             <artifactId>jackson-databind</artifactId>
  34.             <version>${jackjson.version}</version>
  35.         </dependency>
  36.  
  37.     </dependencies>
  38.  
  39. </project>

Jackson Json工具

最简单的就是提交JSON格式的数据，JSON的工具是很有必要的，可以实现对象的序列化和反序列化操作。

  1. package com.boonya.httpclient;
  2.  
  3. import com.fasterxml.jackson.core.JsonFactory;
  4. import com.fasterxml.jackson.core.JsonGenerator;
  5. import com.fasterxml.jackson.databind.ObjectMapper;
  6.  
  7. import java.io.IOException;
  8. import java.io.StringWriter;
  9.  
  10. /**
  11.  * @ClassName: JSONUtil
  12.  * @Description: TODO(功能描述)
  13.  * @author: pengjunlin
  14.  * @company: ******科技有限公司
  15.  * @date 2018-07-21
  16.  */
  17. public class JSONUtil {
  18.  
  19.     /**
  20.      * 对象转json
  21.      * @param obj object 对象
  22.      * @return String
  23.      * @throws IOException
  24.      */
  25.     public static String toJson(Object obj) throws IOException {
  26.  
  27.         ObjectMapper mapper = new ObjectMapper();
  28.         StringWriter sw = new StringWriter();
  29.         JsonGenerator gen = new JsonFactory().createJsonGenerator(sw);
  30.         mapper.writeValue(gen, obj);
  31.         gen.close();
  32.         return sw.toString();
  33.     }
  34.  
  35.     /**
  36.      * json转对象
  37.      * @param jsonStr json字符串
  38.      * @param objClass 类名.class
  39.      * @return 泛型
  40.      * @throws Exception
  41.      */
  42.     public static <T> T toObject(String jsonStr, Class<T> objClass)
  43.             throws Exception {
  44.  
  45.         ObjectMapper mapper = new ObjectMapper();
  46.  
  47.         return mapper.readValue(jsonStr, objClass);
  48.     }
  49. }

HttpClient工具

这里提供两种请求方式：GET和POST。

  1. package com.boonya.httpclient;
  2. import org.apache.http.HttpEntity;
  3. import org.apache.http.HttpResponse;
  4. import org.apache.http.HttpStatus;
  5. import org.apache.http.client.HttpClient;
  6. import org.apache.http.client.methods.CloseableHttpResponse;
  7. import org.apache.http.client.methods.HttpGet;
  8. import org.apache.http.client.methods.HttpPost;
  9. import org.apache.http.entity.StringEntity;
  10. import org.apache.http.impl.client.CloseableHttpClient;
  11. import org.apache.http.impl.client.HttpClients;
  12. import org.apache.http.util.EntityUtils;
  13. import java.io.IOException;
  14. import java.nio.charset.Charset;
  15.  
  16. /**
  17.  * @ClassName: HttpClientUtil
  18.  * @Description: TODO(HttpClientUtil工具类)
  19.  * @author: pengjunlin
  20.  * @company: ******科技有限公司
  21.  * @date 2018-07-19
  22.  */
  23. public class HttpClientUtil{
  24.  
  25.     /**
  26.      * get请求，参数拼接在地址上
  27.      * @param url 请求地址加参数
  28.      * @return 响应
  29.      */
  30.     public static String get(String url)
  31.     {
  32.         String result = null;
  33.         CloseableHttpClient httpClient = HttpClients.createDefault();
  34.         HttpGet get = new HttpGet(url);
  35.         get.addHeader("Content-Type","application/json; charset=utf-8");
  36.         get.setHeader("Accept", "application/json");
  37.         CloseableHttpResponse response = null;
  38.         try {
  39.             response = httpClient.execute(get);
  40.             if(response != null && response.getStatusLine().getStatusCode() == 200)
  41.             {
  42.                 HttpEntity entity = response.getEntity();
  43.                 result =entity.getContent().toString();
  44.             }
  45.             return result;
  46.         } catch (IOException e) {
  47.             e.printStackTrace();
  48.         }finally {
  49.             try {
  50.                 httpClient.close();
  51.                 if(response != null)
  52.                 {
  53.                     response.close();
  54.                 }
  55.             } catch (IOException e) {
  56.                 e.printStackTrace();
  57.             }
  58.         }
  59.         return null;
  60.     }
  61.  
  62.     public static  String  post(String url,String jsonParams){
  63.         HttpClient httpClient =HttpClients.createDefault();
  64.         HttpPost httpPost=new HttpPost(url);
  65.         httpPost.addHeader("Content-Type","application/json; charset=utf-8");
  66.         httpPost.setHeader("Accept", "application/json");
  67.         httpPost.setEntity(new StringEntity(jsonParams, Charset.forName("UTF-8")));
  68.         try {
  69.             HttpResponse response = httpClient.execute(httpPost);
  70.             int statusCode = response.getStatusLine().getStatusCode();
  71.             if (statusCode != HttpStatus.SC_OK) {
  72.                 System.err.println("Method failed:" + response.getStatusLine());
  73.             }else{
  74.                 String result = EntityUtils.toString(response.getEntity());
  75.  
  76.                 return result;
  77.             }
  78.         } catch (IOException e) {
  79.             e.printStackTrace();
  80.         }
  81.         return null;
  82.     }
  83.  
  84. }

编写接口业务实体

这里是一个简单的音视频资源查询实体类：

  1. package com.boonya.httpclient;
  2.  
  3. import java.io.Serializable;
  4. import java.util.Date;
  5.  
  6. /**
  7.  * @ClassName: FileSourceMultiRequest
  8.  * @Description: TODO(功能描述)
  9.  * @author: pengjunlin
  10.  * @company: ******科技有限公司
  11.  * @date 2018-07-19
  12.  */
  13. public class FileSourceMultiRequest implements Serializable
  14. {
  15.  
  16.     /// <summary>
  17.     /// SIM卡号【必填】
  18.     /// </summary>
  19.     public String[] Sims ;
  20.  
  21.     /// <summary>
  22.     /// 通道号(Channel小于0通道不生效)
  23.     /// </summary>
  24.     public int Channel ;
  25.  
  26.     /// <summary>
  27.     /// 报警标志(最小值为0，不能为负数)
  28.     /// </summary>
  29.     public long[] Alarms ;
  30.  
  31.     /// <summary>
  32.     /// 存储器类型(0:主存储器或灾备存储器，1:主存储器，2:灾备存储器)【必填】
  33.     /// </summary>
  34.     public int StorageType ;
  35.  
  36.     /// <summary>
  37.     /// 码流类型(0:主码流或子码流，1:主码流，2:子码流)【必填】
  38.     /// </summary>
  39.     public int StreamType ;
  40.  
  41.     /// <summary>
  42.     /// 开始时间(yyyy-MM-dd HH:mm:ss)【必填】
  43.     /// </summary>
  44.     public Date StartTime ;
  45.  
  46.     /// <summary>
  47.     /// 结束时间(yyyy-MM-dd HH:mm:ss)【必填】
  48.     /// </summary>
  49.     public Date EndTime ;
  50.  
  51.     /// <summary>
  52.     /// 音视频资源类型(0:音视频，1:音频，2:视频，3:视频或音频)
  53.     /// </summary>
  54.     public int DataType;
  55.  
  56.     public String[] getSims() {
  57.         return Sims;
  58.     }
  59.  
  60.     public void setSims(String[] sims) {
  61.         Sims = sims;
  62.     }
  63.  
  64.     public int getChannel() {
  65.         return Channel;
  66.     }
  67.  
  68.     public void setChannel(int channel) {
  69.         Channel = channel;
  70.     }
  71.  
  72.     public long[] getAlarms() {
  73.         return Alarms;
  74.     }
  75.  
  76.     public void setAlarms(long[] alarms) {
  77.         Alarms = alarms;
  78.     }
  79.  
  80.     public int getStorageType() {
  81.         return StorageType;
  82.     }
  83.  
  84.     public void setStorageType(int storageType) {
  85.         StorageType = storageType;
  86.     }
  87.  
  88.     public int getStreamType() {
  89.         return StreamType;
  90.     }
  91.  
  92.     public void setStreamType(int streamType) {
  93.         StreamType = streamType;
  94.     }
  95.  
  96.     public Date getStartTime() {
  97.         return StartTime;
  98.     }
  99.  
  100.     public void setStartTime(Date startTime) {
  101.         StartTime = startTime;
  102.     }
  103.  
  104.     public Date getEndTime() {
  105.         return EndTime;
  106.     }
  107.  
  108.     public void setEndTime(Date endTime) {
  109.         EndTime = endTime;
  110.     }
  111.  
  112.     public int getDataType() {
  113.         return DataType;
  114.     }
  115.  
  116.     public void setDataType(int dataType) {
  117.         DataType = dataType;
  118.     }
  119. }

测试访问接口

  1. package com.boonya.httpclient;
  2. import java.util.Date;
  3.  
  4. /**
  5.  * @ClassName: MainTest
  6.  * @Description: TODO(功能描述)
  7.  * @author: pengjunlin
  8.  * @company: ******科技有限公司
  9.  * @date 2018-07-19
  10.  */
  11. public class MainTest {
  12.  
  13.     public static void main(String[] args) throws Exception{
  14.  
  15.         String url="http://10.10.10.10:18100/api/WebService/MultiSIMAlarmForJsonParam";
  16.         FileSourceMultiRequest request=new FileSourceMultiRequest();
  17.         request.setSims(new String[]{"",""});
  18.         request.setChannel(1);
  19.         request.setAlarms(new long[]{1});
  20.         Date start=new Date();
  21.         start.setTime(start.getTime()-86400);
  22.         request.setStartTime(start);
  23.         Date end=new Date();
  24.         end.setTime(end.getTime()+86400);
  25.         request.setEndTime(end);
  26.         request.setStorageType(0);
  27.         request.setStreamType(0);
  28.         request.setDataType(0);
  29.  
  30.         System.out.println(HttpClientUtil.post(url,JSONUtil.toJson(request)));
  31.  
  32.     }
  33. }

运行此测试：

程序接口正常返回数据。

相关技术文章

最新源码

下载排行榜
点击QQ咨询
开通会员
返回顶部
×
微信扫码支付 元
微信扫码支付
确定支付下载
请使用微信描二维码支付
×

提示信息

×

选择支付方式

  • 微信支付
  • 支付宝付款
确定支付下载