public interface ResponseBodyAdvice<T>{
  /**
	 * Whether this component supports the given controller method return type
	 * and the selected {@code HttpMessageConverter} type.(此组件是否支持给定的控制器方法返回值类型)
	 * @param returnType the return type（返回类型）
	 * @param converterType the selected converter type(选中的转换器类型)
	 * @return {@code true} if {@link #beforeBodyWrite} should be invoked;
	 * {@code false} otherwise（返回是否调用处理方法）
	 */
    boolean support(MethodParameter returnType, Class<? extends HttpMessageConverter<?>> converterType);

/**
	 * Invoked after an {@code HttpMessageConverter} is selected and just before
	 * its write method is invoked.
	 * @param body the body to be written（需要写操作的body）
	 * @param returnType the return type of the controller method
	 * @param selectedContentType the content type selected through content negotiation
	 * @param selectedConverterType the converter type selected to write to the response
	 * @param request the current request
	 * @param response the current response
	 * @return the body that was passed in or a modified (possibly new) instance
	 */
	@Nullable
	T beforeBodyWrite(@Nullable T body, MethodParameter returnType, MediaType selectedContentType,
			Class<? extends HttpMessageConverter<?>> selectedConverterType,
			ServerHttpRequest request, ServerHttpResponse response);
}

@ControllerAdvice
public class LogRequestBodyAdvice implements RequestBodyAdvice {
    @Override
    public boolean supports(MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
        return true;
    }
 
    @Override
    public HttpInputMessage beforeBodyRead(HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) throws IOException {
        return httpInputMessage;
    }
 
    @Override
    public Object afterBodyRead(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
        Method method=methodParameter.getMethod();
        log.info("{}.{}:{}",method.getDeclaringClass().getSimpleName(),method.getName(),JSON.toJSONString(o));
        return o;
    }
 
    @Override
    public Object handleEmptyBody(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
        Method method=methodParameter.getMethod();
        log.info("{}.{}",method.getDeclaringClass().getSimpleName(),method.getName());
        return o;
    }
}

public static void main(String[] args) {
        runtimeException(); // 可以不处理，运行时会直接抛出异常
        try {
            exception(); // 必须try catch
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }

    private static void runtimeException() {
        throw new RuntimeException("runtime exception");
    }

    private static void exception() throws Exception {
        throw new Exception("exception");
    }

Observable.just("hello world")//简单创建一个生产者
              .subscribe(System.out::println);// 简易订阅

Observable.just("hello world")//简单创建一个生产者
              .map(v->v+"xxxx")
              .subscribe(System.out::println);// 简易订阅

boolean send(Message<?> message);
boolean sned(Message<?> message, long timeout);

Message<?> receive();
Message<?> receive(long timeout);

boolean subscribe(MessageHandler handler);
boolean unsubscribe(MessageHandler hanlder);

@Configuration
public class LocaleConfig {

    /**
     * 默认解析器 其中locale表示默认语言
     */
    @Bean
    public LocaleResolver localeResolver() {
        SessionLocaleResolver localeResolver = new SessionLocaleResolver();
        //设置默认英语
        localeResolver.setDefaultLocale(Locale.US);
        //注入Bean
        return localeResolver;
    }

    /**
     * 默认拦截器 其中lang表示切换语言的参数名
     * 例如:   ?lang=zh_CN
     */
    @Bean
    public WebMvcConfigurer localeInterceptor() {
        return new WebMvcConfigurer() {
            @Override
            public void addInterceptors(InterceptorRegistry registry) {
                LocaleChangeInterceptor localeInterceptor = new LocaleChangeInterceptor();
                localeInterceptor.setParamName("lang");
                registry.addInterceptor(localeInterceptor);
            }
        };
    }
}

public void sendSimpleMail(){
    try{
        SimpleMaileMessage simpleMailMessage = new SimpleMailMessage();
        simpleMailMessage .setFrom("sendFrom@qq.com");
        simpleMailMessage .setTo("sendTo@qq.com");
        simpleMailMessage.setSubject("主题");
        simpleMailMessage.setText("内容");
        javaMailSender.send(simpleMailMessage);//发送
    }catch(Exception e){
        logger.error("发送失败",e.getMessage());
    }
}

String nick = "";
            try {
                nick = javax.mail.internet.MimeUtility.encodeText("张三");
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            }
            // 设置发件人
            mimeMsg.setFrom(new InternetAddress("sendFrom@qq.com", nick));

public void sendHTMLMail(MailBean mailBean) {
        MimeMessage mimeMailMessage = null;
        try {
            mimeMailMessage = javaMailSender.createMimeMessage();
            MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMailMessage, true);
            mimeMessageHelper.setFrom(MAIL_SENDER);
            mimeMessageHelper.setTo(mailBean.getRecipient());
            mimeMessageHelper.setSubject(mailBean.getSubject());
            mimeMessageHelper.setText("<h1>hello</h1>", true);
            javaMailSender.send(mimeMailMessage);
        } catch (Exception e) {
            logger.error("邮件发送失败", e.getMessage());
        }
    }

public void sendAttachmentMail(MailBean mailBean) {
       MimeMessage mimeMailMessage = null;
       try {
           mimeMailMessage = javaMailSender.createMimeMessage();
           MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMailMessage, true);
           mimeMessageHelper.setFrom(MAIL_SENDER);
           mimeMessageHelper.setTo(mailBean.getRecipient());
           mimeMessageHelper.setSubject(mailBean.getSubject());
           mimeMessageHelper.setText(mailBean.getContent());
           //文件路径  spring的FileSystemResource,使用绝对路径访问文件资源
           FileSystemResource file = new FileSystemResource(new File("src/main/resources/static/image/mail.png"));
           mimeMessageHelper.addAttachment("mail.png", file);

           javaMailSender.send(mimeMailMessage);
       } catch (Exception e) {
           logger.error("邮件发送失败", e.getMessage());
       }
   }

public void sendInlineMail(MailBean mailBean) {
    MimeMessage mimeMailMessage = null;
    try {
        mimeMailMessage = javaMailSender.createMimeMessage();
        MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMailMessage, true);
        mimeMessageHelper.setFrom(MAIL_SENDER);
        mimeMessageHelper.setTo(mailBean.getRecipient());
        mimeMessageHelper.setSubject(mailBean.getSubject());
        mimeMessageHelper.setText("<html><body>带静态资源的邮件内容，这个一张IDEA配置的照片:<img src='cid:picture' /></body></html>", true);
        //文件路径
        FileSystemResource file = new FileSystemResource(new File("src/main/resources/static/image/mail.png"));
        mimeMessageHelper.addInline("picture", file);

        javaMailSender.send(mimeMailMessage);
    } catch (Exception e) {
        logger.error("邮件发送失败", e.getMessage());
    }
}

public void sendTemplateMail(MailBean mailBean) {
        MimeMessage mimeMailMessage = null;
        try {
            mimeMailMessage = javaMailSender.createMimeMessage();
            MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMailMessage, true);
            mimeMessageHelper.setFrom(MAIL_SENDER);
            mimeMessageHelper.setTo(mailBean.getRecipient());
            mimeMessageHelper.setSubject(mailBean.getSubject());

            Map<String, Object> model = new HashMap<String, Object>();
            model.put("content", mailBean.getContent());
            model.put("title", "标题Mail中使用了FreeMarker");
            Template template = configuration.getTemplate("mail.ftl");
            String text = FreeMarkerTemplateUtils.processTemplateIntoString(template, model);
            mimeMessageHelper.setText(text, true);

            javaMailSender.send(mimeMailMessage);
        } catch (Exception e) {
            logger.error("邮件发送失败", e.getMessage());
        }

    }

public void sendSimpleMail() throws Exception {
	JavaMailSenderImpl mailSender = new JavaMailSenderImpl();//直接生产一个实例
	String users[] = {"xxxxx@qq.com","xxxxx@126.com"};
	mailSender.setHost("smtp.126.com");//动态添加配置
	mailSender.setPassword("xxxxx");
	mailSender.setPort(25);
	mailSender.setProtocol("smtp");
	mailSender.setUsername("xxxxx");
	SimpleMailMessage message = new SimpleMailMessage();
	message.setFrom("xxxxxxx");
	message.setTo(users); // 使用数组的形式还可以群发
	message.setSubject("羽毛球比赛");
	message.setText("报名参加羽毛球赛");
	mailSender.send(message);
	}