SpringBoot系列之基于Jersey实现文件上传API

news2024/11/26 21:31:19

前言

  • JAX-RS：JAX-RS是可以用可以用于实现RESTFul应用程序的JAVA API，给开发者提供了一系列的RESTFul注解
  • Jersey：是基于JAX-RX API的实现框架，用于实现RESTful Web 服务的开源框架。

JAX-RX常用的注解：

@javax.ws.rs.Path // 请求的资源类或资源方法的uri路径
@javax.ws.rs.GET //表示此方法响应HTTP GET请求。
@javax.ws.rs.POST // 表示此方法响应HTTP POST请求。
@javax.ws.rs.PUT // 通常用来更新数据，PUT操作
@javax.ws.rs.DELETE // 通常用来删除数据。
@javax.ws.rs.Produces //设置Http返回报文，报文体的内容类型
@javax.ws.rs.Consumes //客户端请求的MIME媒体类型
@javax.ws.rs.QueryParam // 一般是GET请求的参数，相当于SpringMVC框架的@RequestParam
@javax.ws.rs.FormParam // 媒体类型为”application/x-www-form-urlencoded” 的参数
@javax.ws.rs.PathParam // uri中指定的路径参数绑定到资源方法参数

开发环境

  • SpringBoot2.2.1.RELEASE
  • Jersey2.x
  • JDK1.8
  • Maven 3.2+

搭建一个SpringBoot项目

在IDEA里new一个project，这里使用Spring Initializer快速创建一个SpringBoot项目，Server url可以使用Spring官网的，也可以使用阿里的，然后点击Next
在这里插入图片描述

选择jdk版本，还有使用maven做jar管理
在这里插入图片描述
选择需要的jar，选择之后，生成的项目会自动加上maven配置
在这里插入图片描述
如果是自己搭建的项目，可以自己加上spring-boot-starter-jersey的maven配置

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-jersey</artifactId>
</dependency>

点击Next会生成一个SpringBoot项目，注意也可以加上lombok和hutool组件，方便开发项目

<dependency>
	<groupId>org.projectlombok</groupId>
	<artifactId>lombok</artifactId>
	<optional>true</optional>
</dependency>
<dependency>
	<groupId>cn.hutool</groupId>
	<artifactId>hutool-all</artifactId>
	<version>5.7.11</version>
</dependency>

加上jersey-media-multipart，注意不要加上版本号，因为自己加的版本号可能会和spring-boot-starter-jersey版本冲突，不加上版本号，通过SpringBoot的版本仲裁机制，自动加载对应版本的jar，加上jersey-media-multipart依赖就可以使用@FormDataParam注解，上传文件一般都是要form-data方式

<dependency>
	<groupId>org.glassfish.jersey.media</groupId>
	<artifactId>jersey-media-multipart</artifactId>
</dependency>

项目代码实现

简单加一个返回结果的枚举类，方便返回参数

package com.example.springbootjersey.common;

import lombok.Data;
import org.springframework.http.HttpStatus;

@Data
public class ResultBean<T> {

	/**
	 * 状态
	 * */
	private int status;
	/**
	 * 描述
	 * */
	private String desc;
	/**
	 * 数据返回
	 * */
	private T data;

	public ResultBean(int status, String desc, T data) {
		this.status = status;
		this.desc = desc;
		this.data = data;
	}

	public ResultBean(T data) {
		this.status = HttpStatus.OK.value();
		this.desc = "处理成功";
		this.data = data;
	}

	public static <T> ResultBean<T> ok(T data) {
		return new ResultBean(data);
	}

	public static <T> ResultBean<T> ok() {
		return new ResultBean(null);
	}

	public static <T> ResultBean<T> badRequest(String desc,T data) {
		return new ResultBean(HttpStatus.BAD_REQUEST.value(), desc, data);
	}

	public static <T> ResultBean<T> badRequest(String desc) {
		return new ResultBean(HttpStatus.BAD_REQUEST.value(), desc, null);
	}

	public static <T> ResultBean serverError(String desc, T data){
		return new ResultBean(HttpStatus.INTERNAL_SERVER_ERROR.value(),"服务器内部异常:"+desc,data);
	}

	public static <T> ResultBean serverError(String desc){
		return new ResultBean(HttpStatus.INTERNAL_SERVER_ERROR.value(),"服务器内部异常:"+desc,null);
	}

}

写一个文件上传的api接口

package com.example.springbootjersey.endpoint;


import com.example.springbootjersey.common.ResultBean;
import com.example.springbootjersey.entity.FileUploadResult;
import org.glassfish.jersey.media.multipart.FormDataContentDisposition;

import java.io.InputStream;

public interface IFileServerClient {

    ResultBean<FileUploadResult> uploadFile(InputStream inputStream , FormDataContentDisposition fileDisposition);

}

在SpringBoot里封装的Jersey使用Endpoint作为一个Resource，在JAX-RS项目里一般使用Resource，SpringBoot使用Endpoint，那项目也跟着命名，关键点，要先设置客户端传入的媒体类型，这里使用multipart/form-data方式，加上注解@Consumes(MediaType.MULTIPART_FORM_DATA)，@FormDataParam定义传入的对象

package com.example.springbootjersey.endpoint;

import com.example.springbootjersey.common.ResultBean;
import com.example.springbootjersey.entity.FileUploadResult;
import com.example.springbootjersey.manager.FileUploadHandler;
import lombok.extern.slf4j.Slf4j;
import org.glassfish.jersey.media.multipart.FormDataContentDisposition;
import org.glassfish.jersey.media.multipart.FormDataParam;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.ws.rs.Consumes;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import java.io.InputStream;


@Path("/api")
@Service
@Produces({MediaType.APPLICATION_JSON  , MediaType.APPLICATION_XML})
@Slf4j
public class FileServerEndpoint implements IFileServerClient {

    @Resource
    private FileUploadHandler fileUploadHandler;

    @POST
    @Path("/v1/uploadFile")
    @Consumes(MediaType.MULTIPART_FORM_DATA)
    @Override
    public ResultBean<FileUploadResult> uploadFile(@FormDataParam("file") InputStream inputStream,
                                                   @FormDataParam("file") FormDataContentDisposition fileDisposition) {
        try {
            FileUploadResult result = fileUploadHandler.fileUpload(inputStream ,fileDisposition);
            return ResultBean.ok(result);
        } catch (Exception e) {
            log.error("exception:{}" , e);
            return ResultBean.badRequest("error" , null);
        }
    }
}

具体的业务实现，拿到对应的InputStream ，就可以创建文件，注意这个文件大小不能从FormDataContentDisposition 直接拿，里面的getSize方法拿到的是-1，可能是bug，所以从File里拿

package com.example.springbootjersey.manager;

import cn.hutool.core.io.FileUtil;
import com.example.springbootjersey.entity.FileUploadResult;
import lombok.extern.slf4j.Slf4j;
import org.glassfish.jersey.media.multipart.FormDataContentDisposition;
import org.springframework.stereotype.Component;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;

@Component
@Slf4j
public class FileUploadHandler {

    public FileUploadResult fileUpload(InputStream inputStream , FormDataContentDisposition fileDisposition) throws IOException {
        String fileName = fileDisposition.getFileName();
        String fileType = fileName.substring(fileName.lastIndexOf("."));
        File file = FileUtil.writeFromStream(inputStream, new File("D:/server/" + fileName));
        long length = file.length();
        log.info("fileName : [{}] , fileTye : [{}], size:[{}]" , fileName , fileType , length);
        return FileUploadResult.builder()
                .fileName(fileName)
                .fileUrl(file.getPath())
                .fileSize(length)
                .fileType(fileType).build();
    }
}

配置类，注意要加上MultiPartFeature，也要注册，@ApplicationPath是定义应用的根路径，默认是/*

package com.example.springbootjersey.configuration;

import com.example.springbootjersey.endpoint.FileServerEndpoint;
import org.glassfish.jersey.media.multipart.MultiPartFeature;
import org.glassfish.jersey.server.ResourceConfig;
import org.springframework.context.annotation.Configuration;

import javax.ws.rs.ApplicationPath;

@Configuration
@ApplicationPath("/server")
public class JerseyConfig extends ResourceConfig{

    public JerseyConfig() {
        register(FileServerEndpoint.class);
        register(MultiPartFeature.class);
    }
}

写好代码，丢一个文件测试一下看看，在POST MAN里测试，注意要form-data方式
在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/872292.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

链表OJ详解

链表OJ详解

题目一&#xff1a; 题目要求&#xff1a; 画图分析&#xff1a; 代码实现&#xff1a; struct ListNode* removeElements(struct ListNode* head, int val){struct ListNode*prev NULL,*cur head;//遍历while(cur){if(cur->val val)//相等{if(cur head)//头删{head…
阅读更多...
ubuntu22.04+cuda11.5+gcc11.4第一个cuda程序示例

ubuntu22.04+cuda11.5+gcc11.4第一个cuda程序示例

VisualStudio 2019是微软的集成开发环境(IDE)&#xff0c;通常在Windows操作系统上使用。然而&#xff0c;并不直接支持在Linux上安装。如果想在Ubuntu上进行开发&#xff0c;可以考虑以下几个选项: 使用替代的IDE或文本编辑器: Ubuntu上有许多适用于C等编程语言的开发工具&…
阅读更多...
【必看】时序逻辑仿真成组合逻辑？你知道原因吗？

【必看】时序逻辑仿真成组合逻辑？你知道原因吗？

对于初学者&#xff0c;一般会遇到这种情况&#xff0c;明明写的时序逻辑&#xff0c;结果仿真结果却是组合逻辑&#xff0c;然后看遍设计代码&#xff0c;始终找不到原因&#xff0c;交流群、知乎这种问题随处可见。但不要怀疑软件问题&#xff0c;modelsim这些专用软件基本不…
阅读更多...
【100天精通python】Day33：使用python操作数据库_SQLite数据库的使用与实战

【100天精通python】Day33：使用python操作数据库_SQLite数据库的使用与实战

目录 专栏导读 1 SQLite 简介 2 SQLite数据库安装及使用 2.1 检查 SQLite 支持 2.2 创建数据库文件 2.2.1 使用 Python 创建数据库文件&#xff1a; 2.2.2 使用命令行创建数据库文件&#xff1a; 2.3 连接到 SQLite 数据库&#xff1a; 3 SQLite 中常用的SQL语句…
阅读更多...
WebRTC音视频通话-实现iOS端调用ossrs视频通话服务

WebRTC音视频通话-实现iOS端调用ossrs视频通话服务

WebRTC音视频通话-实现iOS端调用ossrs视频通话服务 之前搭建ossrs服务&#xff0c;可以查看&#xff1a;https://blog.csdn.net/gloryFlow/article/details/132257196 这里iOS端使用GoogleWebRTC联调ossrs实现视频通话功能。 一、iOS端调用ossrs视频通话效果图 iOS端端效果图…
阅读更多...
HTML详解连载（7）

HTML详解连载（7）

HTML详解连载&#xff08;7&#xff09; 专栏链接 [link](http://t.csdn.cn/xF0H3)下面进行专栏介绍 开始喽结构伪类选择器作用 :nth-child&#xff08;公式&#xff09;作用举例 伪元素选择器作用注意&#xff1a; PxCoook作用盒子模型-重要组成部分 盒子模型-边框线属性名属性…
阅读更多...
Java-运算符和控制语句（上）（基于c语言的补充）

Java-运算符和控制语句（上）（基于c语言的补充）

算术运算符 关于求余 不管分子&#xff0c;分母是正还是负&#xff0c;对于分母&#xff0c;直接取正&#xff1b;对于分子若有负号&#xff0c;则先提取出来&#xff1b;剩下两个正的分子分母运算&#xff1b;最后&#xff0c;若刚才的分子有负号&#xff0c;对最后的结果添加…
阅读更多...
fork：创建一个子进程

fork：创建一个子进程

函数原型&#xff1a;pid_t fork&#xff08;void&#xff09;&#xff1b; 返回值&#xff1a; 成功&#xff1a;返回子进程id给附近父进程&#xff0c;返回0给子进程 失败&#xff1a;返回-1&#xff0c;并且设置错误号&#xff0c;同时子进程不会被创建 注意&#xff1…
阅读更多...
C++ QT(一)

C++ QT(一)

目录 初识QtQt 是什么Qt 能做什么Qt/C与QML 如何选择Qt 版本Windows 下安装QtLinux 下安装Qt安装Qt配置Qt Creator 输入中文配置Ubuntu 中文环境配置中文输入法 Qt Creator 简单使用Qt Creator 界面组成Qt Creator 设置 第一个Qt 程序新建一个项目项目文件介绍项目文件*.pro样式…
阅读更多...
锁与原子操作的底层原理

锁与原子操作的底层原理

偏向锁 在一个系统当中&#xff0c;大部分时间都不存在并发问题&#xff0c;但频繁的加锁释放锁又会占用大量系统资源。因此为了让线程获得锁的代价更低而引入了偏向锁。 获得偏向锁 1&#xff09;检查该锁是否被当前线程持有 2&#xff09;通过CAS操作修改对象头 3&#…
阅读更多...
python环境下载安装教程,python运行环境怎么下载

python环境下载安装教程,python运行环境怎么下载

本篇文章给大家谈谈python安装步骤以及环境变量配置&#xff0c;以及下载python需要设置环境变量吗&#xff0c;希望对各位有所帮助&#xff0c;不要忘了收藏本站喔。 1.https://www.python.org/downloads/windows/ 下载适合自己电脑的python安装包 2.下载后安装即可 3.配置环…
阅读更多...
Vue中如何更好地封装组件？

Vue中如何更好地封装组件？

子组件接受父组件传递的事件 1.子组件使用事件名"$emit(父组件中传递的事件名,想给父组件传递的参数(可选))" click"$emit(click)" 2.子组件使用 v-on"$listeners" 父组件&#xff1a; <template><div id"app"><myCo…
阅读更多...
Ceph分布式存储系统优化分析

Ceph分布式存储系统优化分析

Ceph支持多种存储访问接口&#xff0c;现有的多种性能测试工具都可用于Ceph的性能测试&#xff0c;如测试块接口性能的fio&#xff0c;iometer等&#xff1b;测试CephFS接口的filebench&#xff0c;fio等;测试对象接口的cosbench等。Ceph有专用的基准测试集CBT&#xff0c;其包…
阅读更多...
并查集的原理与实现

并查集的原理与实现

1.概念 2.生活中的例子 小弟-老大&#xff1b; 帮派识别 3.实现 3.1 初始化 3.2 中间过程 3.3合并 3.4 并查集路径优化 直接把下面的节点指向最终的老大。 3.5 伪代码实现 3.6JAVA实现 findRoot: 谁是帮派的老大。例如山鸡的老大是陈浩南 connected: 我们是不是同一个大…
阅读更多...
【机器学习 | 数据预处理】 提升模型性能，优化特征表达：数据标准化和归一化的数值处理技巧探析

【机器学习 | 数据预处理】 提升模型性能，优化特征表达：数据标准化和归一化的数值处理技巧探析

&#x1f935;‍♂️ 个人主页: AI_magician &#x1f4e1;主页地址&#xff1a; 作者简介&#xff1a;CSDN内容合伙人&#xff0c;全栈领域优质创作者。 &#x1f468;‍&#x1f4bb;景愿&#xff1a;旨在于能和更多的热爱计算机的伙伴一起成长&#xff01;&#xff01;&…
阅读更多...
勇敢牛牛，爱吃青草

勇敢牛牛，爱吃青草

牛顿问题&#xff08;牛吃草问题 / 消长问题&#xff09; 牛顿问题&#xff08;牛吃草问题/消长问题&#xff09; 牛顿问题&#xff08;牛吃草问题/消长问题&#xff09; 牧场上有一片青草&#xff0c;每天都生长得一样快。这片青草供给 10 头牛吃&#xff0c;可以吃 22 天&…
阅读更多...
元宇宙时代超高清视音频技术白皮书关于流媒体协议和媒体传输解读

元宇宙时代超高清视音频技术白皮书关于流媒体协议和媒体传输解读

流媒体协议 元宇宙业务场景对流媒体传输的实时性和互动性提出了更高的要求&#xff0c;这就需要在传统的 RTMP、SRT、 HLS 等基础上增加实时互动的支持。实时互动&#xff0c;指在远程条件下沟通、协作&#xff0c;可随时随地接入、实时地传递虚实融合的多维信息&#xff0c;身…
阅读更多...
LangChain-ChatGLM在WIndows10下的部署

LangChain-ChatGLM在WIndows10下的部署

LangChain-ChatGLM在WIndows10下的部署 参考资料 1、LangChain ChatGLM2-6B 搭建个人专属知识库中的LangChain ChatGLM2-6B 构建知识库这一节&#xff1a;基本的逻辑和步骤是对的&#xff0c;但要根据Windows和现状做很多调整。 2、没有动过model_config.py中的“LORA_MOD…
阅读更多...
Idea中使用statement接口对象，显示mysql版本号，所有库和表名

Idea中使用statement接口对象，显示mysql版本号，所有库和表名

使用statement 接口对象&#xff0c;进行以下操作&#xff1a; 显示数据库版本号显示所有库显示所有库中的table表 显示数据库版本号&#xff1a; public class StatementDemo {Testvoid showall(){try{Statement st conn.createStatement();ResultSet rs st.executeQuery(…
阅读更多...
C++_模板初阶

C++_模板初阶

在面向对象中&#xff0c;我们可以使用重载来实现多态。 但是问题在于&#xff0c;重载的函数仅仅是类型不同&#xff0c;代码复用率比较低&#xff0c;只要有新的类型出现时&#xff0c;就要增加对应的函数&#xff1b;另一方面它的代码可维护性比较低&#xff0c;一个出错可…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023