spring-boot 用于开发JavaEE非web程序

spring-boot 用于开发JavaEE非web程序

一直想优雅地再JavaEE程序中方便地使用集成在spring上的工具,以前的方法是用如下的方式硬编码。

    private static  ApplicationContext applicationContext;
    static {
        String path2 = AppUtils.class.getResource("/applicationContext.xml").toString();
        String path1 = AppUtils.class.getResource("/applicationContext-myBatis.xml").toString();
        applicationContext = new ClassPathXmlApplicationContext(path1,path2);
    }

    public static  T beanFactory(Class clazz) {
        return applicationContext.getBean(clazz);
    }

如今发现可以用Springboot项目启动自动触发方法，可以很方便地使用spring工具。

@Component
public class InitProject implements ApplicationRunner {
    private static final Logger LOG = LoggerFactory.getLogger(InitProject.class);
 
    @Override
    public void run(ApplicationArguments args) throws Exception {
        LOG.info("==========redis data start===========");
    }
}

示例:Spring-boot整合FastDFS

FastDFS与Springboot集成_技术改变生活-CSDN博客_fastdfs springboot

1.添加pom依赖

    com.github.tobato
    fastdfs-client
    1.25.2-RELEASE

 2、将Fdfs配置引入项目

@import(FdfsClientConfig.class)
@SpringBootApplication
public class JingtongApplication {

    public static void main(String[] args) {
        SpringApplication.run(JingtongApplication.class, args);
    }
}

3.配置文件中加入fdfs相关配置

application.yml

fdfs:
  soTimeout: 1500
  connectTimeout: 600
  thumbImage:             #缩略图生成参数
    width: 150
    height: 150
  trackerList:            #TrackerList参数,支持多个
    - 192.168.0.201:22122
    - 192.168.0.202:22122 

application.properties

fdfs.soTimeout=1500
fdfs.connectTimeout=600
fdfs.thumbImage.width=150
fdfs.thumbImage.height=150
fdfs.trackerList[0]=192.168.0.201:22122
fdfs.trackerList[1]=192.168.0.202:22122

4.简单封装FastDFS使用类

package com.example.components;

import com.github.tobato.fastdfs.FdfsClientConfig;
import com.github.tobato.fastdfs.domain.StorePath;
import com.github.tobato.fastdfs.service.FastFileStorageClient;
import org.apache.commons.io.FilenameUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.EnableMBeanExport;
import org.springframework.context.annotation.import;
import org.springframework.jmx.support.RegistrationPolicy;
import org.springframework.stereotype.Component;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;

//解决jmx重复注册bean的问题
@EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)
@import(FdfsClientConfig.class)//只需要一行注解 @import(FdfsClientConfig.class)就可以拥有带有连接池的FastDFS Java客户端了
@Component
public class FastDFSClientWrapper {

    @Autowired
    private FastFileStorageClient storageClient;

   public String uploadFile(File source) throws IOException {
       FileInputStream is=null;
       try {
           is = new FileInputStream(source);
           StorePath storePath = storageClient.uploadFile(is, source.length(), FilenameUtils.getExtension(source.getName()), null);
           return getResAccessUrl(storePath);
       } catch (FileNotFoundException e) {
           e.printStackTrace();
       }finally {
           if(is!=null){
               is.close();
           }
       }
       return null;
   }
   
   // 封装文件完整URL地址
   private String getResAccessUrl(StorePath storePath) {


       String fileUrl = "192.168.10.183:80" + "/" + storePath.getFullPath();
       return fileUrl;
   }
}

5.项目启动自动触发方法

package com.example.components;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;

import java.io.File;

@Component
public class InitProject implements ApplicationRunner {
    @Autowired
    private FastDFSClientWrapper fastDFSClientWrapper;

    @Override
    public void run(ApplicationArguments args) throws Exception {
        //在这里写数据逻辑
        System.out.println("start upload job!!!!!!!!!");
        String pathname = "C:\Users\76204\Postman\files\youyin_test1.mp4";
         pathname = "D:\test\test.png";
        String path = fastDFSClientWrapper.uploadFile(new File(pathname));
        System.out.println("path========>>>>>"+path);
    }
}

 6.项目入口

package com.example.demo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ComponentScan;

@SpringBootApplication
//在启动类下添加扫描路径
@ComponentScan(basePackages = {"com.example.components"})
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

7.测试类

package com.example.demo;

import com.github.tobato.fastdfs.domain.StorePath;
import com.github.tobato.fastdfs.service.FastFileStorageClient;
import org.apache.commons.io.FilenameUtils;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import java.io.*;

@SpringBootTest
class SpringbootApplicationTest
{
    @Autowired
    private FastFileStorageClient storageClient;

    
    @Test
    public void uploadTest()
    {
        InputStream is = null;
        try
        {
            // 获取文件源
//            File source = new File("C:\Users204\Postman\files\youyin_test1.mp4");
            File source = new File("D:\test\test.png");
            // 获取文件流
            is = new FileInputStream(source);
            // 进行文件上传
            StorePath storePath = storageClient.uploadFile(is, source.length(), FilenameUtils.getExtension(source.getName()), null);
            // 获得文件上传后访问地址
            String fullPath = storePath.getFullPath();
            // 打印访问地址
            System.out.println("fullPath = " + fullPath);
        }
        catch (FileNotFoundException e)
        {
            e.printStackTrace();
        }
        finally
        {
            try
            {
                if(is != null)
                {
                    // 关闭流资源
                    is.close();
                }
            }
            catch (IOException e)
            {
                e.printStackTrace();
            }
        }
    }
}

扩充:

使用过程中发现了一个很好用的注解@PostConstruct注解

这个注解是由Java提供的，它用来修饰一个非静态的void方法。它会在服务器加载Servlet的时候运行，并且只运行一次。

@Component
public class SystemConstant {

    public static String surroundings;

    @Value("${spring.profiles.active}")
    public String environment;

    @PostConstruct
    public void initialize() {
        System.out.println("初始化环境...");
        surroundings = this.environment;
    }
}

这个注解还可以方便地将自动装配地类供static工具类使用，例如

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;


@Component
public class RedisUtil {

    private static RedisTemplate redisTemplates;

    @Autowired
    private RedisTemplate redisTemplate;

    @PostConstruct
    public void initialize() {
        redisTemplates = this.redisTemplate;
    }

    
    public static void set(Object key, Object value) {

        if (key == null || value == null) {
            return;
        }
        redisTemplates.opsForValue().set(key, value);
    }
}