使用官方提供的ContentStreamUpdateRequest请求，虽然默认为POST请求，但是请求参数还是放在了url中，导致url太长，
    错误信息：

    1. URI is too large >8192

    解决办法：

    1. （治标不治本）修改jetty.xml的参数

      1. <New id="httpConfig" class="org.eclipse.jetty.server.HttpConfiguration">
      2. ...
      3.    <Set name="requestHeaderSize"><Property name="solr.jetty.request.header.size" default="81920" /></Set>
      4. </New>

    2. 自己封装http接口请求

    原代码：

    1. package com.datago.microservice.kb.server.service.impl;
    3. import cn.hutool.core.io.FileUtil;
    4. import cn.hutool.core.util.ObjectUtil;
    5. import cn.hutool.http.HttpUtil;
    6. import com.datago.microservice.kb.common.utils.Func;
    7. import com.datago.microservice.kb.server.entity.Attach;
    8. import com.datago.microservice.kb.server.entity.DistributeAttach;
    9. import com.datago.microservice.kb.server.entity.KnowledgeBaseManager;
    10. import com.datago.microservice.kb.server.enums.ParamEnum;
    11. import com.datago.microservice.kb.server.enums.SolrQueryEnum;
    12. import com.datago.microservice.kb.server.service.IAttachSolrService;
    13. import com.datago.microservice.kb.server.utils.cache.ParamCache;
    14. import com.datago.microservice.kb.server.utils.common.SolrUtil;
    15. import com.datago.microservice.kb.server.utils.common.TypeUtil;
    16. import com.datago.microservice.kb.server.vo.KnowledgeBaseManagerVO;
    17. import lombok.SneakyThrows;
    18. import org.apache.solr.client.solrj.request.AbstractUpdateRequest;
    19. import org.apache.solr.client.solrj.request.ContentStreamUpdateRequest;
    20. import org.apache.solr.common.util.ContentStreamBase;
    21. import org.springframework.beans.factory.annotation.Value;
    22. import org.springframework.scheduling.annotation.Async;
    23. import org.springframework.stereotype.Service;
    24. import org.springframework.web.multipart.MultipartFile;
    26. import java.io.File;
    27. import java.util.*;
    28. import java.util.stream.Collectors;
    30. /**
    31. * 附件
    32. *
    33. * @author xq
    34. * @date 2022/03/21 16:29
    35. * @describe 附件
    36. */
    37. @Service
    38. public class AttachSolrServiceImpl extends BaseSolrServiceImpl<Attach> implements IAttachSolrService {
    40.     @Async
    41.     @SneakyThrows
    42.     @Override
    43.     public void putFile(MultipartFile multipartFile, DistributeAttach attach) {
    44.         // 文件上传路径
    45.         ContentStreamUpdateRequest up = new ContentStreamUpdateRequest("/update/extract");
    46.         // 复制文件
    47.         File file = new File(Objects.requireNonNull(multipartFile.getOriginalFilename()));
    48.         FileUtil.writeFromStream(multipartFile.getInputStream(), file);
    49.         // 获取文件类型
    50.         String contentType = TypeUtil.getFileContentType(file.getName());
    51.         // 加入文件
    52.         up.addFile(file, contentType);
    53.         // 添加参数
    54.         if (ObjectUtil.isEmpty(attach)) {
    55.             return;
    56.         }
    57.         if (ObjectUtil.isNotEmpty(attach.getId())) {
    58.             up.setParam("literal.id", attach.getId().toString());
    59.         }
    60.         up.setParam("literal.attach_name", attach.getAttachName());
    61.         up.setParam("literal.attach_originial_address", attach.getAttachOriginialAddress());
    62.         up.setParam("literal.attach_address", attach.getAttachAddress());
    63.         up.setParam("literal.attach_http_address", attach.getAttachHttpAddress());
    64.         up.setParam("literal.extension", attach.getExtension());
    65.         up.setParam("literal.create_time", attach.getCreateTime().toString());
    66.         // up.setParam("literal.createUser", attach.getCreateUser());
    67.         // up.setParam("literal.createDept", attach.getCreateDept());
    68.         // up.setParam("literal.updateTime", attach.getUpdateTime().toString());
    69.         // up.setParam("literal.updateUser", attach.getUpdateUser());
    70.         // up.setParam("literal.status", attach.getStatus().toString());
    71.         // up.setParam("literal.isDeleted", attach.getIsDeleted().toString());
    73.         up.setParam("literal.size", String.valueOf(file.getTotalSpace()));
    74.         up.setAction(AbstractUpdateRequest.ACTION.COMMIT, true, true);
    76.         solrClient.request(up, getCore());
    77.     }
    79.     @Override
    80.     public void putFile(List<KnowledgeBaseManagerVO> managerVO) {
    81.         if (ObjectUtil.isEmpty(managerVO)) {
    82.             return;
    83.         }
    84.         for (KnowledgeBaseManagerVO vo : managerVO) {
    85.             if (ObjectUtil.isEmpty(vo)) {
    86.                 continue;
    87.             }
    88.             putFile(vo.getAttach(), vo);
    89.         }
    90.     }
    92.     @Override
    93.     public void putFile(List<DistributeAttach> attachList, KnowledgeBaseManagerVO managerVO) {
    94.         if (ObjectUtil.isEmpty(managerVO) || ObjectUtil.isEmpty(attachList)) {
    95.             return;
    96.         }
    97.         for (DistributeAttach attach : attachList) {
    98.             putFile(attach, managerVO);
    99.         }
    100.     }
    102.     @SneakyThrows
    103.     @Override
    104.     public void putFile(DistributeAttach attach, KnowledgeBaseManagerVO managerVO) {
    105.         // 文件上传路径
    106.         ContentStreamUpdateRequest up = new ContentStreamUpdateRequest("/update/extract");
    107.         // 复制文件
    108.         File file = new File(attach.getAttachAddress());
    109.         // 获取文件类型
    110.         String contentType = TypeUtil.getFileContentType(file.getName());
    111.         // 加入文件
    112.         up.addFile(file, contentType);
    113.         // 添加参数
    114.         if (ObjectUtil.isEmpty(attach)) {
    115.             return;
    116.         }
    117.         if (ObjectUtil.isNotEmpty(attach.getId())) {
    118.             up.setParam("literal.id", attach.getId().toString());
    119.         }
    120.         up.setParam("literal.attach_name", attach.getAttachName());
    121.         up.setParam("literal.attach_originial_address", attach.getAttachOriginialAddress());
    122.         up.setParam("literal.attach_address", attach.getAttachAddress());
    123.         up.setParam("literal.attach_http_address", attach.getAttachHttpAddress());
    124.         up.setParam("literal.extension", attach.getExtension());
    125.         up.setParam("literal.create_time", attach.getCreateTime().toString());
    128.         if (ObjectUtil.isNotEmpty(managerVO)) {
    129.             up.setParam("literal.kb_id", managerVO.getId().toString());
    130.             up.setParam("literal.category_id", managerVO.getCategoryId().toString());
    131.             up.setParam("literal.category_name", managerVO.getCategoryName());
    132.             up.setParam("literal.category_ancestors", managerVO.getCategoryAncestors());
    133.             up.setParam("literal.title", managerVO.getTitle());
    134.             up.setParam("literal.content_text", managerVO.getContentText());
    137.             up.setParam("literal.label_name", managerVO.getLabelName());
    139.             if (ObjectUtil.isNotEmpty(managerVO.getLabelIds())) {
    140.                 up.setParam("literal.label_ids", managerVO.getLabelIds());
    141.             }
    143.             if (ObjectUtil.isNotEmpty(managerVO.getAssociationModule())) {
    144.                 up.setParam("literal.association_module", String.valueOf(managerVO.getAssociationModule()));
    145.             }
    147.             if (ObjectUtil.isNotEmpty(managerVO.getAssociationModuleName())) {
    148.                 up.setParam("literal.association_module_name", managerVO.getAssociationModuleName());
    149.             }
    151.             up.setParam("literal.create_user_name", managerVO.getCreateUserName());
    152.             up.setParam("literal.create_user", managerVO.getCreateUser());
    154.             up.setParam("literal.create_dept_name", managerVO.getCreateDeptName());
    155.             up.setParam("literal.create_dept", managerVO.getCreateDept());
    156.             up.setParam("literal.is_deleted", managerVO.getIsDeleted().toString());
    157.         }
    159.         up.setParam("literal.size", String.valueOf(file.getTotalSpace()));
    160.         up.addContentStream(new ContentStreamBase.StringStream(""));
    162.         up.setAction(AbstractUpdateRequest.ACTION.COMMIT, true, true);
    164.         solrClient.request(up, getCore());
    165.     }
    168.     @Override
    169.     public String getCore() {
    170.         String value = ParamCache.getValue(ParamEnum.ATTACH.getKey());
    171.         return ObjectUtil.isEmpty(value) ? ParamEnum.ATTACH.getValue() : value;
    172.     }
    174. }

    后修改为下方代码:

    1. package com.datago.microservice.kb.server.service.impl;
    3. import cn.hutool.core.io.FileUtil;
    4. import cn.hutool.core.util.ObjectUtil;
    5. import cn.hutool.http.HttpUtil;
    6. import com.datago.microservice.kb.common.utils.Func;
    7. import com.datago.microservice.kb.server.entity.Attach;
    8. import com.datago.microservice.kb.server.entity.DistributeAttach;
    9. import com.datago.microservice.kb.server.entity.KnowledgeBaseManager;
    10. import com.datago.microservice.kb.server.enums.ParamEnum;
    11. import com.datago.microservice.kb.server.enums.SolrQueryEnum;
    12. import com.datago.microservice.kb.server.service.IAttachSolrService;
    13. import com.datago.microservice.kb.server.utils.cache.ParamCache;
    14. import com.datago.microservice.kb.server.utils.common.SolrUtil;
    15. import com.datago.microservice.kb.server.utils.common.TypeUtil;
    16. import com.datago.microservice.kb.server.vo.KnowledgeBaseManagerVO;
    17. import lombok.SneakyThrows;
    18. import org.apache.solr.client.solrj.request.AbstractUpdateRequest;
    19. import org.apache.solr.client.solrj.request.ContentStreamUpdateRequest;
    20. import org.apache.solr.common.util.ContentStreamBase;
    21. import org.springframework.beans.factory.annotation.Value;
    22. import org.springframework.scheduling.annotation.Async;
    23. import org.springframework.stereotype.Service;
    24. import org.springframework.web.multipart.MultipartFile;
    26. import java.io.File;
    27. import java.util.*;
    28. import java.util.stream.Collectors;
    30. /**
    31.  * 附件
    32.  *
    33.  * @author xq
    34.  * @date 2022/03/21 16:29
    35.  * @describe 附件
    36.  */
    37. @Service
    38. public class AttachSolrServiceImpl extends BaseSolrServiceImpl<Attach> implements IAttachSolrService {
    40.     @Value("${spring.data.solr.host}")
    41.     private String host;
    43.     @Async
    44.     @SneakyThrows
    45.     @Override
    46.     public void putFile(MultipartFile multipartFile, DistributeAttach attach) {
    47.         // 文件上传路径
    48.         ContentStreamUpdateRequest up = new ContentStreamUpdateRequest("/update/extract");
    49.         // 复制文件
    50.         File file = new File(Objects.requireNonNull(multipartFile.getOriginalFilename()));
    51.         FileUtil.writeFromStream(multipartFile.getInputStream(), file);
    52.         // 获取文件类型
    53.         String contentType = TypeUtil.getFileContentType(file.getName());
    54.         // 加入文件
    55.         up.addFile(file, contentType);
    56.         // 添加参数
    57.         if (ObjectUtil.isEmpty(attach)) {
    58.             return;
    59.         }
    60.         if (ObjectUtil.isNotEmpty(attach.getId())) {
    61.             up.setParam("literal.id", attach.getId().toString());
    62.         }
    63.         up.setParam("literal.attach_name", attach.getAttachName());
    64.         up.setParam("literal.attach_originial_address", attach.getAttachOriginialAddress());
    65.         up.setParam("literal.attach_address", attach.getAttachAddress());
    66.         up.setParam("literal.attach_http_address", attach.getAttachHttpAddress());
    67.         up.setParam("literal.extension", attach.getExtension());
    68.         up.setParam("literal.create_time", attach.getCreateTime().toString());
    69.         // up.setParam("literal.createUser", attach.getCreateUser());
    70.         // up.setParam("literal.createDept", attach.getCreateDept());
    71.         // up.setParam("literal.updateTime", attach.getUpdateTime().toString());
    72.         // up.setParam("literal.updateUser", attach.getUpdateUser());
    73.         // up.setParam("literal.status", attach.getStatus().toString());
    74.         // up.setParam("literal.isDeleted", attach.getIsDeleted().toString());
    76.         up.setParam("literal.size", String.valueOf(file.getTotalSpace()));
    77.         up.setAction(AbstractUpdateRequest.ACTION.COMMIT, true, true);
    79.         solrClient.request(up, getCore());
    80.     }
    82.     @Override
    83.     public void putFile(List<KnowledgeBaseManagerVO> managerVO) {
    84.         if (ObjectUtil.isEmpty(managerVO)) {
    85.             return;
    86.         }
    87.         for (KnowledgeBaseManagerVO vo : managerVO) {
    88.             if (ObjectUtil.isEmpty(vo)) {
    89.                 continue;
    90.             }
    91.             putFile(vo.getAttach(), vo);
    92.         }
    93.     }
    95.     @Override
    96.     public void putFile(List<DistributeAttach> attachList, KnowledgeBaseManagerVO managerVO) {
    97.         if (ObjectUtil.isEmpty(managerVO) || ObjectUtil.isEmpty(attachList)) {
    98.             return;
    99.         }
    100.         for (DistributeAttach attach : attachList) {
    101.             putFileUseHttp(attach, managerVO);
    102.         }
    103.     }
    105.     @SneakyThrows
    106.     @Override
    107.     public void putFile(DistributeAttach attach, KnowledgeBaseManagerVO managerVO) {
    108.         // 文件上传路径
    109.         ContentStreamUpdateRequest up = new ContentStreamUpdateRequest("/update/extract");
    110.         // 复制文件
    111.         File file = new File(attach.getAttachAddress());
    112.         // 获取文件类型
    113.         String contentType = TypeUtil.getFileContentType(file.getName());
    114.         // 加入文件
    115.         up.addFile(file, contentType);
    116.         // 添加参数
    117.         if (ObjectUtil.isEmpty(attach)) {
    118.             return;
    119.         }
    120.         if (ObjectUtil.isNotEmpty(attach.getId())) {
    121.             up.setParam("literal.id", attach.getId().toString());
    122.         }
    123.         up.setParam("literal.attach_name", attach.getAttachName());
    124.         up.setParam("literal.attach_originial_address", attach.getAttachOriginialAddress());
    125.         up.setParam("literal.attach_address", attach.getAttachAddress());
    126.         up.setParam("literal.attach_http_address", attach.getAttachHttpAddress());
    127.         up.setParam("literal.extension", attach.getExtension());
    128.         up.setParam("literal.create_time", attach.getCreateTime().toString());
    131.         if (ObjectUtil.isNotEmpty(managerVO)) {
    132.             up.setParam("literal.kb_id", managerVO.getId().toString());
    133.             up.setParam("literal.category_id", managerVO.getCategoryId().toString());
    134.             up.setParam("literal.category_name", managerVO.getCategoryName());
    135.             up.setParam("literal.category_ancestors", managerVO.getCategoryAncestors());
    136.             up.setParam("literal.title", managerVO.getTitle());
    137.             up.setParam("literal.content_text", managerVO.getContentText());
    140.             up.setParam("literal.label_name", managerVO.getLabelName());
    142.             if (ObjectUtil.isNotEmpty(managerVO.getLabelIds())) {
    143.                 up.setParam("literal.label_ids", managerVO.getLabelIds());
    144.             }
    146.             if (ObjectUtil.isNotEmpty(managerVO.getAssociationModule())) {
    147.                 up.setParam("literal.association_module", String.valueOf(managerVO.getAssociationModule()));
    148.             }
    150.             if (ObjectUtil.isNotEmpty(managerVO.getAssociationModuleName())) {
    151.                 up.setParam("literal.association_module_name", managerVO.getAssociationModuleName());
    152.             }
    154.             up.setParam("literal.create_user_name", managerVO.getCreateUserName());
    155.             up.setParam("literal.create_user", managerVO.getCreateUser());
    157.             up.setParam("literal.create_dept_name", managerVO.getCreateDeptName());
    158.             up.setParam("literal.create_dept", managerVO.getCreateDept());
    159.             up.setParam("literal.is_deleted", managerVO.getIsDeleted().toString());
    160.         }
    162.         up.setParam("literal.size", String.valueOf(file.getTotalSpace()));
    163.         up.addContentStream(new ContentStreamBase.StringStream(""));
    165.         up.setAction(AbstractUpdateRequest.ACTION.COMMIT, true, true);
    167.         solrClient.request(up, getCore());
    168.     }
    172.     @Override
    173.     public String getCore() {
    174.         String value = ParamCache.getValue(ParamEnum.ATTACH.getKey());
    175.         return ObjectUtil.isEmpty(value) ? ParamEnum.ATTACH.getValue() : value;
    176.     }
    178.     @Override
    179.     public String getUrl() {
    180.         if (ObjectUtil.isEmpty(host)) {
    181.             return null;
    182.         }
    183.         return host.concat(getCore().replace("/", "")).concat("/update/extract");
    184.     }
    186.     @Override
    187.     public void putFileUseHttp(DistributeAttach attach, KnowledgeBaseManagerVO managerVO) {
    189.         // 文件上传路径
    190.         String url = getUrl();
    191.         System.err.println("请求路径:" + url);
    193.         if (ObjectUtil.isEmpty(url)) {
    194.             return;
    195.         }
    196.         // 复制文件
    197.         File file = new File(attach.getAttachAddress());
    199.         // 添加参数
    200.         if (ObjectUtil.isEmpty(attach)) {
    201.             return;
    202.         }
    203.         Map<String, Object> map = new HashMap<>(16);
    204.         if (ObjectUtil.isNotEmpty(attach.getId())) {
    205.             map.put("literal.id", attach.getId().toString());
    206.         }
    207.         map.put("literal.attach_name", attach.getAttachName());
    208.         map.put("literal.attach_originial_address", attach.getAttachOriginialAddress());
    209.         map.put("literal.attach_address", attach.getAttachAddress());
    210.         map.put("literal.attach_http_address", attach.getAttachHttpAddress());
    211.         map.put("literal.extension", attach.getExtension());
    212.         map.put("literal.create_time", attach.getCreateTime().toString());
    214.         if (ObjectUtil.isNotEmpty(managerVO)) {
    215.             map.put("literal.kb_id", managerVO.getId().toString());
    216.             map.put("literal.category_id", managerVO.getCategoryId().toString());
    217.             map.put("literal.category_name", managerVO.getCategoryName());
    218.             map.put("literal.category_ancestors", managerVO.getCategoryAncestors());
    219.             map.put("literal.title", managerVO.getTitle());
    220.             map.put("literal.content_text", managerVO.getContentText());
    223.             map.put("literal.label_name", managerVO.getLabelName());
    225.             if (ObjectUtil.isNotEmpty(managerVO.getLabelIds())) {
    226.                 map.put("literal.label_ids", managerVO.getLabelIds());
    227.             }
    229.             if (ObjectUtil.isNotEmpty(managerVO.getAssociationModule())) {
    230.                 map.put("literal.association_module", String.valueOf(managerVO.getAssociationModule()));
    231.             }
    233.             if (ObjectUtil.isNotEmpty(managerVO.getAssociationModuleName())) {
    234.                 map.put("literal.association_module_name", managerVO.getAssociationModuleName());
    235.             }
    237.             map.put("literal.create_user_name", managerVO.getCreateUserName());
    238.             map.put("literal.create_user", managerVO.getCreateUser());
    240.             map.put("literal.create_dept_name", managerVO.getCreateDeptName());
    241.             map.put("literal.create_dept", managerVO.getCreateDept());
    242.             map.put("literal.is_deleted", managerVO.getIsDeleted().toString());
    243.         }
    244.         map.put("commitWithin", 1000);
    245.         map.put("overwrite", true);
    246.         map.put("file", file);
    248.         String res = HttpUtil.post(url, map);
    249.         System.err.println("响应：" + res);
    251.     }
    252. }