SpringCloud微服务之间传输文件

简介: SpringCloud微服务之间传输文件

SpringCloud微服务之间传输文件:

1.引入jar

<dependency>
     <groupId>io.github.openfeign.form</groupId>
     <artifactId>feign-form</artifactId>
     <version>2.1.0</version>
</dependency>
<dependency>
     <groupId>io.github.openfeign.form</groupId>
     <artifactId>feign-form-spring</artifactId>
     <version>2.1.0</version>
</dependency>

2.添加配置类

import feign.form.spring.SpringFormEncoder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
import org.springframework.cloud.openfeign.support.SpringEncoder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
import feign.codec.Encoder;
import org.springframework.beans.factory.ObjectFactory;
 
 
@Configuration
public class MultipartSupportConfig {
    @Autowired
    private ObjectFactory<HttpMessageConverters> messageConverters;
 
    @Bean
    public Encoder feignFormEncoder() {
        return new SpringFormEncoder(new SpringEncoder(messageConverters));
    }
 
}

3.调用其他微服务上传文件的FeignClient

import com.yl.soft.princess.common.config.MultipartSupportConfig;
import com.yl.soft.princess.dto.base.ResultItem;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RequestPart;
import org.springframework.web.multipart.MultipartFile;
 
 
@FeignClient(value = "live", contextId = "uploadVideoService",configuration = MultipartSupportConfig.class, fallbackFactory = LiveServiceFallbackFactory.class)
public interface UploadVideoService {
//注意注解名称,consumes ,RequestPart
    @PostMapping(value =  "/signature/uploadVideo",consumes = MediaType.MULTIPART_FORM_DATA_VALUE )
 
    ResultItem uploadVideo(@RequestPart("file") MultipartFile file);
}

4.前端要调用上传文件的Controller

import com.alibaba.fastjson.JSON;
import com.yl.soft.princess.common.util.StringUtilsEX;
import com.yl.soft.princess.controller.BaseController;
import com.yl.soft.princess.dto.base.ResultItem;
import com.yl.soft.princess.ek.course.CourseService;
import com.yl.soft.princess.ek.live.LiveService;
import com.yl.soft.princess.ek.live.UploadVideoService;
import com.yl.soft.princess.ek.user.UserService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.servlet.ModelAndView;
 
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.Map;
 
 
@RestController
@RequestMapping("/signature")
public class PlatformVideoController extends BaseController {
 
    protected Logger logger = LoggerFactory.getLogger(this.getClass());
 
 
//    @Autowired
//    private LiveService liveService;
 
    @Resource
    private UploadVideoService uploadVideoService;
 
 
    /**
     * 上传视频
     *
     * @param id   小视频id
     * @param sort 排序
     */
    @PostMapping("/uploadVideo")
    public ResultItem videoSort(@RequestParam("file") MultipartFile file) {
        try {
            ResultItem resultItem = uploadVideoService.uploadVideo(file);
            System.out.println(resultItem);
            return resultItem;
        } catch (Exception e) {
            e.printStackTrace();
            logger.error("修改小视频排序出错! 异常信息:{}", e.getMessage());
            return error();
        }
    }
}

 

相关文章
|
7月前
|
自然语言处理 负载均衡 算法
Nacos架构与原理 - 通信通道
Nacos架构与原理 - 通信通道
88 1
|
7月前
|
Dubbo Java 应用服务中间件
如何在Spring Boot项目中集成Dubbo并启用gRPC协议,来实现高效的分布式服务通信?
如何在Spring Boot项目中集成Dubbo并启用gRPC协议,来实现高效的分布式服务通信?
106 0
如何在Spring Boot项目中集成Dubbo并启用gRPC协议,来实现高效的分布式服务通信?
|
9月前
|
Java 微服务 Spring
微服务之间的调用之openFeign。
在spring cloud项目中,微服务之间的调用使用openfegin注解的方式,可以简洁快速的实现微服务之间的调用。下面直接通过实战的方式让读者清晰明了,全是干货,没有一点废话。
141 0
|
9月前
|
消息中间件 存储 人工智能
微服务之间的最佳调用方式,你会了吗(一)
微服务之间的最佳调用方式,你会了吗
|
9月前
|
存储 运维 Dubbo
微服务之间的最佳调用方式,你会了吗(二)
微服务之间的最佳调用方式,你会了吗
|
12月前
|
消息中间件 安全 前端开发
「第二部:容器和微服务架构](12) 基于异步消息的通信
「第二部:容器和微服务架构](12) 基于异步消息的通信
|
12月前
|
消息中间件 开发框架 负载均衡
「第二部:容器和微服务架构](9) API网关模式与客户端直接通信
「第二部:容器和微服务架构](9) API网关模式与客户端直接通信
|
12月前
|
设计模式 缓存 开发框架
「第二部:容器和微服务架构](10) API网关模式与客户端直接通信2
「第二部:容器和微服务架构](10) API网关模式与客户端直接通信2
|
12月前
|
消息中间件 存储 Kubernetes
「微服务架构」Kafka和Moskitto那个更适合微服务之间的通信?
「微服务架构」Kafka和Moskitto那个更适合微服务之间的通信?
|
JSON 数据格式 计算机视觉
微服务如何实现各个模块之间相互调用
微服务如何实现各个模块之间相互调用
375 0