微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

带有SMTP连接池的Spring Boot

如何解决带有SMTP连接池的Spring Boot

将SMTPconnection池集成到我的spring boot应用程序中时遇到问题。请建议我在以下配置中做错了什么。我想以异步方式执行批量电子邮件执行。

参考材料: https://gist.github.com/manish-in-java/c71e974fa178d3cdaf51bb4dd8f61aec

Pom.xml:

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0"    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.5.RELEASE</version>
    <relativePath /> <!-- lookup parent from repository -->
</parent>
<groupId>com.library.demo</groupId>
<artifactId>Library_management</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>Library_management</name>
<description>Genpact project for use cases</description>

<properties>
    <java.version>1.8</java.version>
    <maven-jar-plugin.version>3.1.1</maven-jar-plugin.version>
</properties>

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>com.h2database</groupId>
        <artifactId>h2</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-mail</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
        <exclusions>
            <exclusion>
                <groupId>org.junit.vintage</groupId>
                <artifactId>junit-vintage-engine</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>com.github.nithril</groupId>
        <artifactId>smtp-connection-pool</artifactId>
        <version>1.4.0</version>
    </dependency>
</dependencies>

<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>               
        </plugin>
    </plugins>
</build>

application.yml:

server:
 port: 8081
# Spring datasource configuration
spring:
 h2:
 console:
  path: /h2
  enabled: true
datasource:
 platform: h2
 url: jdbc:h2:mem:library:MODE=MysqL;DB_CLOSE_DELAY=-1
 driver-class-name: org.h2.Driver
 username: sa
 password: Test@123 
jpa:
show-sql: true   
hibernate:
  ddl-auto: update
database-platform: org.hibernate.dialect.H2Dialect  
logging:
 file: /logs/demo/library_management.log 
 level:
  org.springframework.web: ERROR
  com.canidateid: INFO
  org.hibernate: ERRO
pattern:
console: "%d{yyyy-MM-dd HH:mm:ss} - %msg%n"
file: "%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n"

Spring boot主类:

package com.library.demo.main;

import org.nlab.smtp.pool.SmtpConnectionPool;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.domain.EntityScan;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;

@SpringBootApplication
@EnableAutoConfiguration
@EntityScan(basePackages = {"com.library.demo.model"})
@EnableJpaRepositories(basePackages = {"com.library.demo.repository"})
@ComponentScan(basePackages = { "com.library.demo.*" })
public class LibraryManagementApplication {

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

EmailService类:

 @Autowired
  private SmtpConnectionPool smtpConnectionPool;

  public void sendEmail() {
    try (ClosableSmtpConnection transport = smtpConnectionPool.borrowObject()) {
      MimeMessage mimeMessage = new MimeMessage(transport.getSession());

      ...

      transport.sendMessage(mimeMessage);
    }
  }

SMTPConfiguration.java:该类与参考URL相同,只是我已添加了smtp配置。

在Spring Boot应用程序启动时,我遇到以下错误,请帮助我解决问题

Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2020-09-03 15:22:48 - Application run Failed
org.springframework.jmx.export.UnabletoRegisterMBeanException: Unable to register MBean [SmtpConnectionPool [maxTotal=8,blockWhenExhausted=true,maxWaitMillis=-1,lifo=true,fairness=false,testOnCreate=false,testOnBorrow=false,testOnReturn=false,testWhileIdle=false,timeBetweenevictionRunsMillis=-1,numTestsPerevictionRun=3,minevictableIdleTimeMillis=1800000,softMinevictableIdleTimeMillis=-1,evictionPolicy=org.apache.commons.pool2.impl.DefaultevictionPolicy@79a71171,closeLock=java.lang.Object@1322c982,closed=false,evictionLock=java.lang.Object@636613,evictor=null,evictionIterator=null,factoryClassLoader=java.lang.ref.WeakReference@23c01dcd,oname=org.apache.commons.pool2:type=GenericObjectPool,name=pool,creationStackTrace=java.lang.Exception
    at org.apache.commons.pool2.impl.BaseGenericObjectPool.<init>(BaseGenericObjectPool.java:143)
    at org.apache.commons.pool2.impl.GenericObjectPool.<init>(GenericObjectPool.java:105)
    at org.apache.commons.pool2.impl.GenericObjectPool.<init>(GenericObjectPool.java:88)
    at org.nlab.smtp.pool.SmtpConnectionPool.<init>(SmtpConnectionPool.java:17)
    at com.library.demo.main.SMTPConfiguration.smtpConnectionPool(SMTPConfiguration.java:32)
    at com.library.demo.main.SMTPConfiguration$$EnhancerBySpringcglib$$67c6ab52.cglib$smtpConnectionPool$3(<generated>)
    at com.library.demo.main.SMTPConfiguration$$EnhancerBySpringcglib$$67c6ab52$$FastClassBySpringcglib$$4e630d15.invoke(<generated>)
    at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:228)
    at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:365)
    at com.library.demo.main.SMTPConfiguration$$EnhancerBySpringcglib$$67c6ab52.smtpConnectionPool(<generated>)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(UnkNown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(UnkNown Source)
    at java.lang.reflect.Method.invoke(UnkNown Source)
    at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:154)
    at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:582)
    at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.instantiateUsingFactoryMethod(AbstractAutowireCapablebeanfactory.java:1247)
    at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.createBeanInstance(AbstractAutowireCapablebeanfactory.java:1096)
    at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.doCreateBean(AbstractAutowireCapablebeanfactory.java:535)
    at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.createBean(AbstractAutowireCapablebeanfactory.java:495)
    at org.springframework.beans.factory.support.Abstractbeanfactory.lambda$doGetBean$0(Abstractbeanfactory.java:317)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
    at org.springframework.beans.factory.support.Abstractbeanfactory.doGetBean(Abstractbeanfactory.java:315)
    at org.springframework.beans.factory.support.Abstractbeanfactory.getBean(Abstractbeanfactory.java:199)
    at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:251)
    at org.springframework.beans.factory.support.DefaultListablebeanfactory.doResolveDependency(DefaultListablebeanfactory.java:1135)
    at org.springframework.beans.factory.support.DefaultListablebeanfactory.resolveDependency(DefaultListablebeanfactory.java:1062)
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:583)
    at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90)
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcesspropertyValues(AutowiredAnnotationBeanPostProcessor.java:372)
    at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.populateBean(AbstractAutowireCapablebeanfactory.java:1341)
    at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.doCreateBean(AbstractAutowireCapablebeanfactory.java:572)
    at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.createBean(AbstractAutowireCapablebeanfactory.java:495)
    at org.springframework.beans.factory.support.Abstractbeanfactory.lambda$doGetBean$0(Abstractbeanfactory.java:317)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
    at org.springframework.beans.factory.support.Abstractbeanfactory.doGetBean(Abstractbeanfactory.java:315)
    at org.springframework.beans.factory.support.Abstractbeanfactory.getBean(Abstractbeanfactory.java:199)
    at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:251)
    at org.springframework.beans.factory.support.DefaultListablebeanfactory.doResolveDependency(DefaultListablebeanfactory.java:1135)
    at org.springframework.beans.factory.support.DefaultListablebeanfactory.resolveDependency(DefaultListablebeanfactory.java:1062)
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:583)
    at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90)
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcesspropertyValues(AutowiredAnnotationBeanPostProcessor.java:372)
    at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.populateBean(AbstractAutowireCapablebeanfactory.java:1341)
    at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.doCreateBean(AbstractAutowireCapablebeanfactory.java:572)
    at org.springframework.beans.factory.support.AbstractAutowireCapablebeanfactory.createBean(AbstractAutowireCapablebeanfactory.java:495)
    at org.springframework.beans.factory.support.Abstractbeanfactory.lambda$doGetBean$0(Abstractbeanfactory.java:317)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
    at org.springframework.beans.factory.support.Abstractbeanfactory.doGetBean(Abstractbeanfactory.java:315)
    at org.springframework.beans.factory.support.Abstractbeanfactory.getBean(Abstractbeanfactory.java:199)
    at org.springframework.beans.factory.support.DefaultListablebeanfactory.preInstantiateSingletons(DefaultListablebeanfactory.java:759)
    at org.springframework.context.support.AbstractApplicationContext.finishbeanfactoryInitialization(AbstractApplicationContext.java:869)
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:550)
    at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:140)
    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:780)
    at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:412)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:333)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1277)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1265)
    at com.library.demo.main.LibraryManagementApplication.main(LibraryManagementApplication.java:19)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(UnkNown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(UnkNown Source)
    at java.lang.reflect.Method.invoke(UnkNown Source)
    at org.springframework.boot.devtools.restart.RestartLauncher.run(RestartLauncher.java:49),borrowedCount=0,returnedCount=0,createdCount=0,destroyedCount=0,destroyedByevictorCount=0,destroyedByBorrowValidationCount=0,activeTimes=Statsstore [values=[-1,-1,-1],size=100,index=0],idleTimes=Statsstore [values=[-1,waitTimes=Statsstore [values=[-1,maxBorrowWaitTimeMillis=0,swallowedExceptionListener=null,factoryType=null,maxIdle=8,minIdle=0,factory=org.nlab.smtp.transport.factory.SmtpConnectionFactory@62adac5d,allObjects={},createCount=0,idleObjects=[],abandonedConfig=null]] with key 'smtppool'; nested exception is javax.management.InstanceAlreadyExistsException: MXBean already registered with name org.apache.commons.pool2:type=GenericObjectPool,name=pool
    at org.springframework.jmx.export.MBeanExporter.registerBeanNameOrInstance(MBeanExporter.java:625)
    at org.springframework.jmx.export.MBeanExporter.lambda$registerBeans$2(MBeanExporter.java:551)
    at java.util.HashMap.forEach(UnkNown Source)
    at org.springframework.jmx.export.MBeanExporter.registerBeans(MBeanExporter.java:551)
    at org.springframework.jmx.export.MBeanExporter.afterSingletonsInstantiated(MBeanExporter.java:434)
    at org.springframework.beans.factory.support.DefaultListablebeanfactory.preInstantiateSingletons(DefaultListablebeanfactory.java:776)
    at org.springframework.context.support.AbstractApplicationContext.finishbeanfactoryInitialization(AbstractApplicationContext.java:869)
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:550)
    at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:140)
    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:780)
    at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:412)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:333)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1277)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1265)
    at com.library.demo.main.LibraryManagementApplication.main(LibraryManagementApplication.java:19)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(UnkNown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(UnkNown Source)
    at java.lang.reflect.Method.invoke(UnkNown Source)
    at org.springframework.boot.devtools.restart.RestartLauncher.run(RestartLauncher.java:49)
Caused by: javax.management.InstanceAlreadyExistsException: MXBean already registered with name org.apache.commons.pool2:type=GenericObjectPool,name=pool
    at com.sun.jmx.mbeanserver.MXBeanLookup.addReference(UnkNown Source)
    at com.sun.jmx.mbeanserver.MXBeanSupport.register(UnkNown Source)
    at com.sun.jmx.mbeanserver.MBeanSupport.preRegister2(UnkNown Source)
    at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(UnkNown Source)
    at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(UnkNown Source)
    at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(UnkNown Source)
    at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(UnkNown Source)
    at org.springframework.jmx.support.MBeanRegistrationSupport.doRegister(MBeanRegistrationSupport.java:137)
    at org.springframework.jmx.export.MBeanExporter.registerBeanInstance(MBeanExporter.java:671)
    at org.springframework.jmx.export.MBeanExporter.registerBeanNameOrInstance(MBeanExporter.java:615)
    ... 19 common frames omitted
2020-09-03 15:22:48 - Closing org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext@1223f2d0: startup date [Thu Sep 03 15:22:43 IST 2020]; root of context hierarchy
2020-09-03 15:22:48 - Unregistering JMX-exposed beans on shutdown

如果在主类中排除jmx配置,则应用程序启动,但应用程序未采用smtp配置。

@EnableAutoConfiguration(exclude = {JmxAutoConfiguration.class})

请帮助

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。