java读取文件推送报文

接口

package com.lwl.service;

/**
 * 
 *
 * @author liuwenlong
 * @create 2021-11-11 23:48:02
 */
@SuppressWarnings("all")
public interface IDevelopService {

    //批量报文推送
    String BatchPacketPush(String url, String path, String count, String frequency);
}

实现类

package com.lwl.service.Impl;

import com.lwl.service.IDevelopService;
import com.lwl.util.ReadText;
import com.lwl.util.SendPost;
import com.test.controller.BatchPacketPush_test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.File;

/**
 * @author liuwenlong
 * @create 2021-11-11 23:49:21
 */
@SuppressWarnings("all")
@Service
public class DevelopServiceImpl implements IDevelopService {


    /**
     * 批量推送报文
     *
     * @param url       推送地址
     * @param path      文件所在路径
     * @param count     文件数量
     * @param frequency 频率（秒）
     * @return
     */
    @Override
    public String BatchPacketPush(String url, String path, String count, String frequency) {
        frequency = String.valueOf(Integer.parseInt(frequency) * 1000); //传入的是秒，先转为毫秒
        ReadText readText = new ReadText();
        SendPost sendPost = new SendPost();
        try {
            //获取绝对路径下的文件
            for (int i = 1; i <= Integer.parseInt(count); i++) {
                String message = readText.readTxt(new File(path + i + ".txt"));
                message = message.replaceAll("\\s*", "");//删除报文中所有空格、空白符等无效字符
                System.out.println(message);
                //拼接报文
                String requestBody = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:les=\"http://www.foton.com.cn/LES_LWL_001_AvailableInventoryInformation\">\n" +
                        "   <soapenv:Header/>\n" +
                        "   <soapenv:Body>\n" +
                        "      <les:LES_LWL_001_AvailableInventoryInformationService>\n" +
                        "         <les:DATA><![CDATA[" + message + "]]></les:DATA>\n" +
                        "      </les:LES_LWL_001_AvailableInventoryInformationService>\n" +
                        "   </soapenv:Body>\n" +
                        "</soapenv:Envelope>";
                //请求接口
                String result = sendPost.doPost(url, requestBody);
                System.out.println("响应报文：\n" + result);
                //发送一个报文后，停一段时间，5000毫秒就是5秒
                Thread.sleep(Integer.parseInt(frequency));
                System.out.println("成功发送" + i + "次");
            }
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
        return "success";
    }
}

控制层

package com.lwl.controller;

import com.lwl.entity.Interface;
import com.lwl.service.IDevelopService;
import com.lwl.util.ReadText;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;

/**
 * @author liuwenlong
 * @create 2021-11-11 23:46:10
 */
@SuppressWarnings("all")
@Controller
@RequestMapping(value = "develop")
public class DevelopController {

    @Autowired
    IDevelopService iDevelopService;

    /**
     * 批量推送报文
     *
     * @param req
     * @param resp
     * @param url       推送地址
     * @param path      文件所在路径
     * @param count     数量
     * @param frequency 频率（秒）
     * @throws IOException
     */
    @RequestMapping(value = "BatchPacketPush")
    public void BatchPacketPush(HttpServletRequest req, HttpServletResponse resp,
                                String url, String path, String count, String frequency) throws IOException {
        resp.setContentType("text/plain; charset=UTF-8");
        resp.setCharacterEncoding("UTF-8");
        PrintWriter out = resp.getWriter();
        String result = iDevelopService.BatchPacketPush(url, path, count, frequency);
        System.out.println(result);
        out.write(result);
        out.flush();
    }
}

工具类-读取文件

package com.lwl.util;

import java.io.*;

/**
 * 读取文本文件内容
 *
 * @author liuwenlong
 * @create 2021-11-30 22:05:04
 */
@SuppressWarnings("all")
public class ReadText {

    /**
     * 读文件
     *
     * @param file 文件
     * @return
     * @throws IOException
     * @throws IOException
     */
    public static String readTxt(File file) throws IOException, IOException {
        String s = "";
        InputStreamReader in = new InputStreamReader(new FileInputStream(file), "UTF-8");
        BufferedReader br = new BufferedReader(in);
        StringBuffer content = new StringBuffer();
        while ((s = br.readLine()) != null) {
            content = content.append(s);
        }
        return content.toString();
    }
}

工具类--post请求API接口

package com.lwl.util;

import sun.misc.BASE64Encoder;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;

/**
 * post请求
 *
 * @author liuwenlong
 * @create 2021-11-30 22:25:00
 */
@SuppressWarnings("all")
public class SendPost {

    /**
     * Post请求一个地址
     *
     * @param URL         请求地址
     * @param requestBody 请求的body
     * @return
     */
    public String doPost(String URL, String requestBody) {
        OutputStreamWriter out = null;
        BufferedReader in = null;
        StringBuilder result = new StringBuilder();
        HttpURLConnection conn = null;
        String username = "账号";
        String password = "密码";
        String input = username + ":" + password;
        try {
            java.net.URL url = new URL(URL);
            conn = (HttpURLConnection) url.openConnection();
            BASE64Encoder base = new BASE64Encoder();
            String encodedPassword = base.encode(input.getBytes("UTF-8"));
            System.out.println("加密后的密码：" + encodedPassword);
            //将加密的账号密码放到请求头里，这里注意Basic后面要加空格
            conn.setRequestProperty("Authorization", "Basic " + encodedPassword);
            conn.setRequestMethod("POST");
            //发送POST请求必须设置为true
            conn.setDoOutput(true);
            conn.setDoInput(true);
            //设置连接超时时间和读取超时时间
            conn.setConnectTimeout(3000);
            conn.setReadTimeout(3000);
            conn.setRequestProperty("Content-Type", "application/json");
            conn.setRequestProperty("Accept", "application/json");
            //获取输出流，写入请求的json报文
            out = new OutputStreamWriter(conn.getOutputStream());
            System.out.println(requestBody);

            out.write(requestBody); //获取请求的body,
            out.flush();
            out.close();
            //取得输入流，并使用Reader读取
            if (200 == conn.getResponseCode()) {
                in = new BufferedReader(new InputStreamReader(conn.getInputStream(), StandardCharsets.UTF_8));
                String line;
                while ((line = in.readLine()) != null) {
                    result.append(line);
                    System.out.println(line);
                }
            } else {
                System.out.println("ResponseCode is an error code:" + conn.getResponseCode());
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ioe) {
                ioe.printStackTrace();
            }
        }
        return result.toString();
    }
}

前端页面

<html>
<head>
    <meta http-equiv="Content-Type" content="text/html; charset=utf-8">
    <meta http-equiv="X-UA-Compatible" content="IE=Edge,chrome=1">
    <link rel="icon" th:href="@{/public/favicon.ico}" type="image/x-icon"/>
    <link rel="bookmark" th:href="@{/public/favicon.ico}" type="image/x-icon"/>
    <link rel="stylesheet" href="${pageContext.request.contextPath}/static/layui/css/layui.css">
    <script src="${pageContext.request.contextPath}/static/layui/layui.js"></script>
    <script type="text/javascript" src="${pageContext.request.contextPath}/static/wms/Js/jquery-1.7.2.min.js"></script>
</head>


<script>

    function BtnBatchPacketPush(text, reviver) {

        const url = $('#url').val().toString();
        const path = $('#path').val().toString();
        const count = $('#count').val().toString();
        const frequency = $('#frequency').val().toString();

        $.ajax({
            method: 'post',
            url: "${pageContext.request.contextPath}/develop/BatchPacketPush",
            data: {
                "url": url,
                "path": path,
                "count": count,
                "frequency": frequency
            },
            success: function (res) {
                if (res !== "") {
                    alert(res.toString())
                } else {
                    alert("发送失败！")
                }
            }
        })
    }
</script>

<body>



<div style=" 100%;height: 850px;background: white;margin-top: 10px;padding: 10px">


        <div class="layui-form-item">
            <label class="layui-form-label">请求地址</label>
            <div class="layui-input-block">
                <input type="text" id="url" name="url" required lay-verify="required" placeholder="请输入接口地址"
                       autocomplete="off" class="layui-input">
            </div>
        </div>

        <div class="layui-form-item">
            <label class="layui-form-label">文件路径</label>
            <div class="layui-input-block">
                <input type="text" id="path" name="path" required lay-verify="required" placeholder="请输入报文所在的路径"
                       autocomplete="off" class="layui-input">
            </div>
            <div class="layui-form-mid layui-word-aux">D:\\报文推送\\</div>
        </div>

        <div class="layui-form-item">
            <label class="layui-form-label">文件数量</label>
            <div class="layui-input-inline">
                <input type="text" id="count" name="count" lay-verify="required" placeholder="请输入文件数量"
                       autocomplete="off" class="layui-input">
            </div>
        </div>

        <div class="layui-form-item">
            <label class="layui-form-label">推送间隔</label>
            <div class="layui-input-inline">
                <input type="text" id="frequency" name="frequency" lay-verify="required" placeholder="报文请求频率"
                       autocomplete="off" class="layui-input">
            </div>
            <div class="layui-form-mid layui-word-aux">（秒）</div>
        </div>


        <div class="layui-form-item">
            <div class="layui-input-block">
                <button class="layui-btn" lay-submit lay-filter="formDemo" type="button" onclick="BtnBatchPacketPush();">
                    立即提交
                </button>
                <button type="button" class="layui-btn layui-btn-primary">重置</button>

            </div>
        </div>

</div>

</div>

</body>
</html>

数据文件

 执行

 后端执行