SSM —— SpringMvc的每一个控制器都可以做为http服务器

╰半橙微兮° 2023-11-10 06:16 161阅读 0赞

SpringMvc不仅可以接收Jsp页面的请求，而且可以作为一个简易的Http服务器，用控制器去接收别的http请求，进行业务操作最后返回数据，因为jsp页面请求其实也是http请求：

SSM框架搭建参考另一篇博客https://blog.csdn.net/DGH2430284817/article/details/88587804

控制器：

  1. package com.test.controller;
  2. import java.net.UnknownHostException;
  4. import org.apache.log4j.Logger;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.stereotype.Controller;
  7. import org.springframework.ui.Model;
  8. import org.springframework.web.bind.annotation.RequestBody;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import org.springframework.web.bind.annotation.RequestMethod;
  11. import org.springframework.web.bind.annotation.ResponseBody;
  13. import com.ceb.dgh.bo.Door;
  14. import com.qut.util.LoggerUtil;
  15. import com.test.service.DoorService;
  17. @RequestMapping("/door")
  18. @Controller
  19. public class DoorController {
  20.      private static Logger log = LoggerUtil.getLogger(DoorController.class);
  21.     //我就不注入了，没用到数据库和业务逻辑
  22.     //@Autowired 
  23.     //private DoorService doorService;
  26.     @RequestMapping(value = "server",method = {RequestMethod.POST})
  27.     @ResponseBody
  28.     public String serverTest(@RequestBody String clientMsg){
  29.         log.info("进入控制器server,参数：" + clientMsg);
  30.         //业务操作省略
  31.         String returnMsg = "服务器返回客户端数据";//相当于业务操作结果
  32.         return returnMsg;
  33.     }
  36. }

http客户端TestClient.java：

  1. package test.client;
  3. import java.io.BufferedReader;
  4. import java.io.InputStreamReader;
  5. import java.io.OutputStream;
  6. import java.net.HttpURLConnection;
  7. import java.nio.charset.Charset;
  8. import java.net.URL;
  9. import org.springframework.util.Assert;
  11. public class TestClient {
  13.     public static void main(String[] args) throws Exception {
  14.         TestClient aaClient = new TestClient();
  15.         String Msg = "client sent to server";
  16.         String resString =aaClient.doPostRequest("http://localhost:8080/Maven_SSM/door/server.action", Msg, Charset.forName("UTF-8"), 10, 10);
  17.         System.out.println("返回数据:"+resString);
  18.     }
  22.      /**
  23.      * @param reqUrl 地址
  24.      * @param params 数据(json)
  25.      * @param charset 编码
  26.      * @param readTimeSec 
  27.      * @param connTimeSec
  28.      * @return Http请求返回数据字符串
  29.      * @throws Exception
  30.      */
  31.     public static String doPostRequest(String reqUrl, String params,
  32.                 Charset charset, int readTimeSec, int connTimeSec)
  33.                 throws Exception {
  34.             try {
  35.                 Assert.hasText(reqUrl, "请求地址为空");
  36.                 Assert.hasText(params, "请求数据为空");
  37.             } catch (Exception e) {
  38.                 throw new Exception("发送请求参数为空:"
  39.                         + e.getMessage(), e);
  40.             }
  41.             String request = params ;//发送服务端数据
  42.             HttpURLConnection httpConnection = null;
  43.             try {
  44.                 httpConnection = (HttpURLConnection) new URL(reqUrl)
  45.                         .openConnection();
  46.                 httpConnection.setRequestMethod("POST");
  47.                 httpConnection.setDoOutput(true);
  48.                 httpConnection.setDoInput(true);
  49.                 httpConnection.setUseCaches(false);
  50.                 httpConnection.setRequestProperty("Connection", "Keep-Alive");
  51.                 httpConnection.setRequestProperty("Charset", charset.displayName());
  52.                 httpConnection.setRequestProperty("Content-Type",
  53.                         "application/json; charset=" + charset.displayName());
  54.                 httpConnection.setRequestProperty("accept", "application/json");
  55.                 httpConnection.setReadTimeout(readTimeSec * 1000);// 设置http连接的读超时,单位是毫秒
  56.                 httpConnection.setConnectTimeout(connTimeSec * 1000);
  57.                 // 1、连接
  58.                 try {
  59.                     httpConnection.connect();
  60.                 } catch (Exception e) {
  61.                     throw new Exception(
  62.                             "服务器连接是失败");
  63.                 }
  64.                 OutputStream outwritestream = null;
  65.                 // 2、发送数据
  66.                 try {
  67.                     System.out.println("请求数据:"+request);
  68.                     byte[] writebytes = request.getBytes(charset);
  69.                     outwritestream = httpConnection.getOutputStream();
  70.                     outwritestream.write(writebytes);
  71.                     outwritestream.flush();
  72.                 } catch (Exception e) {
  73.                     throw new Exception(
  74.                             "请求数据发送失败", e);
  75.                 } finally {
  76.                         try {
  77.                             outwritestream.close();
  78.                         } catch (Exception e) {
  79.                         }
  80.                 }
  81.                 return getHttpReturn(httpConnection , charset);
  82.             } catch (Exception e) {
  83.                 throw new Exception("服务器连接失败："
  84.                         + e.getMessage(), e);
  85.             } finally {
  86.                 if (httpConnection != null) {
  87.                     httpConnection.disconnect();
  88.                 }
  89.             }
  90.         }
  92.         /**
  93.          * @param httpConnection  
  94.          * @return Http连接返回数据转化成字符串
  95.          * @throws Exception
  96.          */
  97.         private static String getHttpReturn(HttpURLConnection httpConnection , Charset charset)
  98.                 throws Exception {
  99.             int responseCode = -1;
  100.             try {
  101.                 responseCode = httpConnection.getResponseCode();
  102.                 //System.out.println("responseCode:"+responseCode);
  103.             } catch (Exception e) {
  104.                 throw new Exception(
  105.                         "接收数据超时", e);
  106.             }
  107.             try {
  108.                 Assert.isTrue(responseCode == 200, "服务器响应码【"
  109.                         + responseCode + "】");
  110.             } catch (Exception e) {
  111.                 throw new Exception(
  112.                         "接收数据失败：" + e.getMessage(), e);
  113.             }
  114.             BufferedReader reader = null;
  115.             try {
  116.                 reader = new BufferedReader(new InputStreamReader(
  117.                         httpConnection.getInputStream(), charset));
  118.                 String str = "";
  119.                 String temp;
  120.                    while((temp = reader.readLine())!=null){ 
  121.                        str = str + temp +"\r\n" ;
  122.                    }
  123.                 return str;
  124.             } catch (Exception e) {
  125.                 throw new Exception(
  126.                         "接收数据超时：" + e.getMessage(), e);
  127.             } finally {
  128.                 try {
  129.                     if (null != reader) {
  130.                         reader.close();
  131.                     }
  132.                 } catch (Exception e) {
  133.                 }
  134.             }
  135.         }
  136. }

开启SSM项目后右键启动客户端类，发起http请求：

测试结果：

服务端：

  1. [2019-03-18 18:03:17,955] [INFO] [com.test.controller.DoorController.httpMo:40] - 进入控制器server,参数：client sent to server

客户端：

  1. 请求数据:client sent to server
  2. 返回数据:服务器返回客户端数据

发表评论

表情：
评论列表 （有 0 条评论，161人围观）

还没有评论，来说两句吧...

相关阅读