HttpClient遠程介面調用-實名認證

来源:https://www.cnblogs.com/lisingshen/archive/2019/09/22/11569290.html
-Advertisement-
Play Games

1、HttpClient遠程介面調用 1)用戶註冊 註冊按鈕 提交表單時，要 表單 js提交表單 2)載入外部資源文件 app.properties 編輯 RestApiServerInfo.java 3)HTTPClient工具遠程調用介面 導入依賴 發送post請求 工具類 遠程介面返回 封裝對 ...


1、HttpClient遠程介面調用

1)用戶註冊

用戶註冊

註冊按鈕button提交表單時，要return false

form表單

    <!-- action="http://localhost:8082/scw-restapi/member/regist" -->
    <form class="form-signin" role="form" action="${ctp}/member/regist"
        method="post" id="regForm">
    ...
    </form>

js提交表單

    $("#submitBtn").click(function() {

        var loginType = $("select.form-control").val();
        log("註冊類型==============>", loginType)
        
        /* if (loginType == "管理") {
            $("#regForm").submit();
        } else {
            alert("此功能尚未開通");
        } */

        $("#regForm").submit();
        return false
    })

2)載入外部資源文件

app.properties

restapi.server.ip=127.0.0.1
restapi.server.port=8082
restapi.server.apppath=scw-restapi

編輯springmvc.xml

    <!-- 引入外部配置文件 -->
    <context:property-placeholder
        location="classpath:other/app.properties" />

RestApiServerInfo.java

    @Controller
    public class RestApiServerInfo {
    
        // MemberService memberService;
        @Value("${restapi.server.ip}")
        private String restapiserver;
    
        @Value("${restapi.server.port}")
        private String restapiport;
    
        @Value("${restapi.server.apppath}")
        private String appPath;
    
        public String getRestApiURL() {
            System.out.println("http://" + restapiserver + ":" + restapiport);
            return "http://" + restapiserver + ":" + restapiport + "/" + appPath;
        }
    }

3)HTTPClient工具遠程調用介面

導入依賴

    <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
    <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpclient</artifactId>
        <version>4.5.3</version>
    </dependency>

發送post請求

    public static String httpPostRequest(String url, Map<String, Object> params)

工具類HttpClientUtil.java

package com.atguigu.project;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.Map;

import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.entity.UrlEncodedFormEntity;
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.client.methods.HttpRequestBase;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;

/**
 * @author Nan 2015-11
 */
public class HttpClientUtil {

    private static PoolingHttpClientConnectionManager cm;
    private static String EMPTY_STR = "";
    private static String UTF_8 = "UTF-8";

    private static void init() {
        if (cm == null) {
            cm = new PoolingHttpClientConnectionManager();
            cm.setMaxTotal(50);// 整個連接池最大連接數
            cm.setDefaultMaxPerRoute(5);// 每路由最大連接數，預設值是2
        }
    }

    /**
     * 通過連接池獲取HttpClient
     * 
     * @return
     */
    private static CloseableHttpClient getHttpClient() {
        init();
        return HttpClients.custom().setConnectionManager(cm).build();
    }

    /**
     * @param url
     * @return
     */
    public static String httpGetRequest(String url) {
        HttpGet httpGet = new HttpGet(url);
        return getResult(httpGet);
    }

    public static String httpGetRequest(String url, Map<String, Object> params) throws URISyntaxException {
        URIBuilder ub = new URIBuilder();
        ub.setPath(url);

        ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
        ub.setParameters(pairs);

        HttpGet httpGet = new HttpGet(ub.build());
        return getResult(httpGet);
    }

    public static String httpGetRequest(String url, Map<String, Object> headers, Map<String, Object> params)
            throws URISyntaxException {
        URIBuilder ub = new URIBuilder();
        ub.setPath(url);

        ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
        ub.setParameters(pairs);

        HttpGet httpGet = new HttpGet(ub.build());
        for (Map.Entry<String, Object> param : headers.entrySet()) {
            httpGet.addHeader(param.getKey(), String.valueOf(param.getValue()));
        }
        return getResult(httpGet);
    }

    public static String httpPostRequest(String url) {
        HttpPost httpPost = new HttpPost(url);
        return getResult(httpPost);
    }

    public static String httpPostRequest(String url, Map<String, Object> params) throws UnsupportedEncodingException {
        HttpPost httpPost = new HttpPost(url);
        ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
        httpPost.setEntity(new UrlEncodedFormEntity(pairs, UTF_8));
        return getResult(httpPost);
    }

    public static String httpPostRequest(String url, Map<String, Object> headers, Map<String, Object> params)
            throws UnsupportedEncodingException {
        HttpPost httpPost = new HttpPost(url);

        for (Map.Entry<String, Object> param : headers.entrySet()) {
            httpPost.addHeader(param.getKey(), String.valueOf(param.getValue()));
        }

        ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
        httpPost.setEntity(new UrlEncodedFormEntity(pairs, UTF_8));

        return getResult(httpPost);
    }

    private static ArrayList<NameValuePair> covertParams2NVPS(Map<String, Object> params) {
        ArrayList<NameValuePair> pairs = new ArrayList<NameValuePair>();
        for (Map.Entry<String, Object> param : params.entrySet()) {
            pairs.add(new BasicNameValuePair(param.getKey(), String.valueOf(param.getValue())));
        }

        return pairs;
    }

    /**
     * 處理Http請求
     * 
     * @param request
     * @return
     */
    private static String getResult(HttpRequestBase request) {
        // CloseableHttpClient httpClient = HttpClients.createDefault();
        CloseableHttpClient httpClient = getHttpClient();
        try {
            CloseableHttpResponse response = httpClient.execute(request);
            // response.getStatusLine().getStatusCode();
            HttpEntity entity = response.getEntity();
            if (entity != null) {
                // long len = entity.getContentLength();// -1 表示長度未知
                String result = EntityUtils.toString(entity);
                response.close();
                // httpClient.close();
                return result;
            }
        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {

        }

        return EMPTY_STR;
    }

}

遠程介面返回ScwReturn<T>封裝對象

package com.atguigu.scw.restapi.bean;

import java.util.Map;

public class ScwReturn<T> {

    private int code;// 狀態碼 1：表示成功 0:表示失敗
    private String msg;// 要給的提示信息
    private T content;// 響應的內容；
    private Map<String, Object> ext;// 額外的數據

    public int getCode() {
        return code;
    }

    public void setCode(int code) {
        this.code = code;
    }

    public String getMsg() {
        return msg;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }

    public T getContent() {
        return content;
    }

    public void setContent(T content) {
        this.content = content;
    }

    public Map<String, Object> getExt() {
        return ext;
    }

    public void setExt(Map<String, Object> ext) {
        this.ext = ext;
    }

    // 兩個快速的成功失敗方法
    public static <T> ScwReturn<T> success(String msg, T content, Map<String, Object> ext) {
        ScwReturn<T> t = new ScwReturn<T>();
        t.setCode(1);
        t.setMsg(msg);
        t.setContent(content);
        t.setExt(ext);
        return t;
    }

    public static <T> ScwReturn<T> fail(String msg, T content, Map<String, Object> ext) {
        ScwReturn<T> t = new ScwReturn<T>();
        t.setCode(0);
        t.setMsg(msg);
        t.setContent(content);
        t.setExt(ext);
        return t;
    }
}

註冊調用遠程介面

發送請求

String response = HttpClientUtil.httpPostRequest(url, params);

遠程介面返回的響應字元串轉java對象

    readValue = new ObjectMapper().readValue(response.getBytes(), new TypeReference<ScwReturn<TMemeber>>() {
        });


@RequestMapping("/regist")
public String regist(TMemeber memeber, Model model) throws Exception {
    // 需要利用http工具去模擬發調用介面的請求
    // http://localhost:8082/scw-restapi/member/regist
    // <httpclient.version>4.5.3</httpclient.version>
    // httpclient使用java代碼來模擬發送請求
    // 能收到api調用後產生的json數據；
    // 1、可以將產生的json逆向成對象ScwReturn<TMemeber>
    // 2、可以直接將json寫給頁面
    System.out.println("memeber===========>" + memeber);
    // 註冊成功以後可以來到一個頁面；

    // 1、應該去發送請求來進行註冊；java代碼發請求
    String url = serverInfo.getRestApiURL() + "/member/regist";
    System.out.println("url===========>" + url);
    // 2、構建請求參數
    Map<String, Object> params = new HashMap<String, Object>();

    params.put("loginacct", memeber.getLoginacct());
    // 密碼是業務邏輯加密的，我們不用管
    params.put("userpswd", memeber.getUserpswd());
    params.put("email", memeber.getEmail());

    // 響應內容；
    String response = HttpClientUtil.httpPostRequest(url, params);

    // 封裝響應為對象
    ScwReturn<TMemeber> readValue = null;

    readValue = new ObjectMapper().readValue(response.getBytes(), new TypeReference<ScwReturn<TMemeber>>() {
    });

    // 判斷，註冊成功！來到登陸頁面
    if (readValue.getCode() == 1) {
        return "redirect:/login.jsp";
    } else {
        // 註冊失敗！來到註冊頁面進行回顯
        model.addAttribute("msg", "用戶名和郵箱已經被註冊了！");
        return "forward:/reg.jsp";
    }
}

遠程介面註冊方法

控制層

    /**
     * ScwReturn<List<TMemeber>>:泛型是content內容的對象的類型
     * 
     * @Description (TODO這裡用一句話描述這個方法的作用)
     * @param memeber
     * @return
     */
    @RequestMapping("/regist")
    public ScwReturn<TMemeber> regist(TMemeber memeber) {

        // 創建一個空的對象
        TMemeber regist = new TMemeber();
        Map<String, Object> hashMap = new HashMap<>();
        try {
            regist = memberService.regist(memeber);
        } catch (Exception e) {
            // 判斷異常類型來放錯誤
            // e.printStackTrace();
            hashMap.put("error", "觸犯唯一約束，請保證用戶名和郵箱唯一");
        }
        regist.setUserpswd("");
        if (regist.getId() != null) {
            return ScwReturn.success("用戶註冊成功！", regist, null);
        } else {
            return ScwReturn.fail("用戶註冊失敗!", null, hashMap);
        }
    }

業務層

帶條件插入

    int i = memeberMapper.insertSelective(tMemeber);


    @Override
    public TMemeber regist(TMemeber tMemeber) {
        // TODO Auto-generated method stub
        String digest = MD5Util.digest(tMemeber.getUserpswd());
        // 加密密碼保存
        tMemeber.setUserpswd(digest);
        // 初始化用戶名和賬號
        tMemeber.setUsername(tMemeber.getLoginacct());
        // 實名認證狀態 0:未實名認證 1::實名認證
        tMemeber.setAuthstatus("0");
        // 真實姓名；實名認證是保存的
        tMemeber.setRealname("未實名");
        // 0：普通會員 1：月費會員 2：年費會員 3：
        tMemeber.setUsertype("0");
        // 身份證號，賬戶類型；（實名認證是做的）
        // 賬戶類型：直接保存賬戶的全名

        int i = memeberMapper.insertSelective(tMemeber);

        // 剛纔就是按照這個對象給資料庫插入值，希望獲取到資料庫分配的自增主鍵
        return tMemeber;
    }

2、實名認證文件上傳

1)上傳用戶資質證件

導入依賴

    <dependency>
        <groupId>commons-fileupload</groupId>
        <artifactId>commons-fileupload</artifactId>
        <version>1.3.2</version>
    </dependency>
    <dependency>
        <groupId>commons-io</groupId>
        <artifactId>commons-io</artifactId>
        <version>2.5</version>
    </dependency>

編輯springmvc.xml文件

    <!-- 1、文件上傳需要一個文件上傳解析器 -->
    <bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
        <property name="defaultEncoding" value="utf-8"></property>
    </bean>

前臺ajax提交

帶有文件表單，一次提交所有項

var fd = new FormData($("#certForm")[0])

帶有文件表單,提交部分內容

//使用formData（js對象來包裝form表單）
var fd = new FormData();
log($("#ad_name_input").val())
log($("#ad_file_input")[0].files[0])
fd.append("name", $("#ad_name_input").val());
fd.append("ad", $("#ad_file_input")[0].files[0])

processData(預設: true)

預設情況下，通過data選項傳遞進來的數據，如果是一個對象(技術上講只要不是字元串)，都會處理轉化成一個查詢字元串，以配合預設內容類型 "application/x-www-form-urlencoded"。

contentType

不使用預設的內容類型；(預設: "application/x-www-form-urlencoded") 發送信息至伺服器時內容編碼類型。

    //這是一個資質文件上傳的頁面
    //發送文件上傳資質文件請求；
    var fd = new FormData($("#certForm")[0]);
    $.ajax({
        url:"http://localhost:8082/scw-restapi/auth/upload",
        data:fd,
        type:"post",
        contentType:false,
        dataType:"json",
        processData:false,
        success:function(result){
            //來到郵箱填寫頁面
            location.href="${ctp}/auth/apply-2.html"
        },
        error:function(e){
            layer.msg("上傳失敗:"+e);
        }
    });

控制層

    //文件上傳
    private String uploadfile(String webPath,MultipartFile file,HttpSession session){
        ServletContext context = session.getServletContext();
        String realPath = context.getRealPath(webPath);
        String name = UUID.randomUUID().toString().replace("-", "").substring(0, 10) +"_file_"+ file.getOriginalFilename();
        try {
            //webPath不存在的情況下必須創建
            File file2 = new File(realPath);
            if(!file2.exists()){
                //創建目錄
                file2.mkdirs();
            }
            
            file.transferTo(new File(realPath+"/"+name));
            //返回這個圖片在伺服器下的路徑
            return webPath+"/"+name;
        }catch (Exception e) {
            return null;
        }
    }
    
    @RequestMapping("/upload")
    public ScwReturn<Object> upload(HttpSession session,
            @RequestParam("file")MultipartFile[] file,
            @RequestParam("certid")Integer[] certid,@RequestParam("memberid")Integer memberid){
        
        try {
            System.out.println("資質的id"+certid);
            List<TMemberCert> certsList= new ArrayList<TMemberCert>();
            for (int i=0;i<certid.length;i++) {
                TMemberCert cert = new TMemberCert();
                MultipartFile multipartFile = file[i];
                String uploadfile = uploadfile("/certsimg", multipartFile, session);
                cert.setCertid(certid[i]);
                cert.setMemberid(memberid);
                cert.setIconpath(uploadfile);
                certsList.add(cert);
            }
            //調用業務邏輯進行保存;/刪除原有資質，保存新的資質
            certService.insertCerts(certsList);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            System.out.println(e);
            return ScwReturn.fail("資質保存失敗！", null, null);
        }
        
        return ScwReturn.success("保存成功！", null, null);
    }

2)批量插入用戶資質證件描述信息

業務層

CertService.java

    public void insertCerts(List<TMemberCert> certsList);

CertServiceImpl.java

    @Override
    public void insertCerts(List<TMemberCert> certsList) {
        // TODO Auto-generated method stub
        TMemberCertExample example = new TMemberCertExample();
        Criteria criteria = example.createCriteria();
        criteria.andMemberidEqualTo(certsList.get(0).getMemberid());
        //先刪除
        memberCertMapper.deleteByExample(example);
        //後保存
        certMapper.insertBatch(certsList);
    }

dao層

TCertMapper.java

    void insertBatch(@Param("certs")List<TMemberCert> certsList);

TCertMapper.xml

  <!-- void insertBatch(@Param("certs")List<TMemberCert> certsList); -->
  <insert id="insertBatch">
        INSERT INTO t_member_cert(memberid,certid,iconpath) 
        VALUES
        <foreach collection="certs" item="c" separator=",">
            (#{c.memberid},#{c.certid},#{c.iconpath})
        </foreach>
  </insert>

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • R語言構建蛋白質網路並實現GN演算法
    R語言構建蛋白質網路並實現GN演算法 1.蛋白質網路的構建 我們使用與人類HIV相關的蛋白質互作數據hunam HIV PPI.csv來構建這個蛋白質互作網路。 在R中，我們可以從存儲在R環境外部的文件讀取數據。還可以將數據寫入由操作系統存儲和訪問的文件。 R可以讀取和寫入各種文件格式，如：csv，e ...
  • 如何保證消息的順序性？
    面試題 如何保證消息的順序性？ 面試官心理分析 其實這個也是用 MQ 的時候必問的話題，第一看看你了不瞭解順序這個事兒？第二看看你有沒有辦法保證消息是有順序的？這是生產系統中常見的問題。 面試題剖析 我舉個例子，我們以前做過一個 mysql 同步的系統，壓力還是非常大的，日同步數據要達到上億，就是說 ...
  • elasticsearch Discovery 發現模塊學習
    發現模塊和集群的形成 目標 發現節點 Master選舉 組成集群，在Master信息發生變化時及時更新。 故障檢測 細分為幾個子模塊 Discovery發現模塊 Discover是在集群Master節點未知時，互相發現對方的過程，例如新節點的加入或是先前的主節點宕機，如果一個節點不滿足Master資 ...
  • JVM的一些工具的簡要使用
    JConsole(可視化工具) 運行 JConsole記憶體監控 測試代碼 這裡看到我們有倆個線程。 JPS(JVM Process status) JPS是使用的頻率最高的工具，和linux下的ps命令差不多(把J去掉就是一個ps)。 因為我這裡開啟了一個eclipse，所以運行結果如下所示： 如果 ...
  • 最好的重試是指數後退和抖動
    1. 概述 在本教程中，我們將探討如何使用兩種不同的策略改進客戶端重試：指數後退和抖動。 2. 重試 在分散式系統中，多個組件之間的網路通信隨時可能發生故障。 客戶端應用程式通過實現重試來處理這些失敗。 設想我們有一個調用遠程服務的客戶端應用程式—— PingPongService 。 如果 Pin ...
  • DJango錯誤日誌生成
    0922自我總結 DJango錯誤日誌生成 setting.py設置 exception.py(拋錯設置) logging.py ...
  • 聊一聊大廠內部的安全管理機制
    工作了兩個月了體會到了很多之前做外包小項目沒有的東西，不得不說大廠的還是有自己一套的完善的體制，不會像B站那樣泄露自己整個後臺的源碼這種事情發生。 電腦辦公 比如說在使用電腦辦公這方面，剛入職那天每個人都會領一臺電腦（MAC和Windows都有看工作需要），每個人領的電腦上都裝有 度管家 ,度管家是 ...
  • ssh無密登錄_集群分發腳本xsync
    1、ssh免密登錄 ssh ip地址 免密登錄配置 生成公鑰和私鑰 將公鑰拷貝到要免密登錄的目標機器上 .ssh文件夾下（~/.ssh）的文件功能解釋 （1）known_hosts ：記錄ssh訪問過電腦的公鑰(public key) （2）id_rsa ：生成的私鑰 （3）id_rsa.pub ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類