苍穹外卖--httpclient--get&post请求

sky-server/src/main/resources/application.yml

@@ -15,7 +15,7 @@ spring:
   redis:
     host: ${sky.redis.host}
     port: ${sky.redis.port}
-    password: ${sky.redis.password}
+#    password: ${sky.redis.password}
     database: ${sky.redis.database}
 mybatis:
   #mapper配置文件

sky-server/src/test/java/com/sky/test/HttpClientTest.java

@@ -0,0 +1,69 @@
+package com.sky.test;
+
+import com.alibaba.fastjson.JSONObject;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.io.IOException;
+
+//@SpringBootTest
+public class HttpClientTest {
+
+    @Test
+    public void testGet() throws IOException {
+        //创建httpclient对象
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        //创建请求对象,请求用户端的查询营业状态的接口
+        HttpGet httpGet = new HttpGet("http://localhost:8080/user/shop/status");
+        //发送请求
+        CloseableHttpResponse response = httpClient.execute(httpGet);
+        //获取响应数据
+        int statusCode = response.getStatusLine().getStatusCode();
+        System.out.println("服务端返回的状态码："+statusCode);
+        HttpEntity entity = response.getEntity();
+        String body = EntityUtils.toString(entity);
+        System.out.println("服务端返回的数据为："+body);
+        //释放资源
+        response.close();
+        httpClient.close();
+    }
+
+
+    @Test
+    public void testPost() throws IOException {
+        //创建httpclient对象
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        //创建请求对象
+        HttpPost httpPost = new HttpPost("http://localhost:8080/admin/employee/login");
+        //设置请求参数（post：请求体）
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("username","admin");
+        jsonObject.put("password","123456");
+        StringEntity entity = new StringEntity(jsonObject.toString());
+        //指定请求的编码方式
+        entity.setContentEncoding("UTF-8");
+        //数据格式
+        entity.setContentType("application/json");
+        //设置请求体到请求对象中
+        httpPost.setEntity(entity);
+        //发送请求
+        CloseableHttpResponse response = httpClient.execute(httpPost);
+        //获取响应数据
+        int statusCode = response.getStatusLine().getStatusCode();
+        System.out.println("服务端返回的状态码："+statusCode);
+        HttpEntity responseEntity = response.getEntity();
+        String body = EntityUtils.toString(responseEntity);
+        System.out.println("服务端返回的数据为："+body);
+        //释放资源
+        response.close();
+        httpClient.close();
+    }
+}