Включение JMX в Hibernate, Ehcache, Quartz, DBPC и Spring

Коллекция коротких инструкций по включению JMX в нескольких популярных технологиях Java.

Продолжая наше путешествие с JMX (см .: … JMX для людей ), мы узнаем, как включить поддержку JMX (обычно возможности статистики и мониторинга) в некоторых популярных средах. Большую часть этой информации можно найти на домашних страницах проекта, но я решил собрать ее, добавив несколько полезных советов.

Hibernate (с поддержкой Spring)

Предоставить
статистику Hibernate с помощью JMX довольно
просто , однако при использовании JPA API для получения базового SessionFactory требуются некоторые неприятные обходные пути

class JmxLocalContainerEntityManagerFactoryBean() extends LocalContainerEntityManagerFactoryBean {
 override def createNativeEntityManagerFactory() = {
  val managerFactory = super.createNativeEntityManagerFactory()
  registerStatisticsMBean(managerFactory)
  managerFactory
 }
 
 def registerStatisticsMBean(managerFactory: EntityManagerFactory) {
  managerFactory match {
   case impl: EntityManagerFactoryImpl =>
    val mBean = new StatisticsService();
    mBean.setStatisticsEnabled(true)
    mBean.setSessionFactory(impl.getSessionFactory);
    val name = new ObjectName("org.hibernate:type=Statistics,application=spring-pitfalls")
    ManagementFactory.getPlatformMBeanServer.registerMBean(mBean, name);
   case _ =>
  }
 }
 
}

Обратите внимание, что я создал подкласс встроенного в Springs LocalContainerEntityManagerFactoryBean. Переопределив метод createNativeEntityManagerFactory (), я могу получить доступ к EntityManagerFactory и попытаться уменьшить его до org.hibernate.ejb.EntityManagerFactoryImpl, и мы смогли зарегистрировать Hibernate Mbean.

Еще одна вещь ушла. Очевидно, что мы должны использовать наш собственный подкласс вместо org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean. Кроме того, чтобы собирать фактическую статистику вместо того, чтобы просто видеть нули до конца, мы должны установить флаг hibernate.generate_statistics.

@Bean
def entityManagerFactoryBean() = {
 val entityManagerFactoryBean = new JmxLocalContainerEntityManagerFactoryBean()
 entityManagerFactoryBean.setDataSource(dataSource())
 entityManagerFactoryBean.setJpaVendorAdapter(jpaVendorAdapter())
 entityManagerFactoryBean.setPackagesToScan("com.blogspot.nurkiewicz")
 entityManagerFactoryBean.setJpaPropertyMap(
  Map(
   "hibernate.hbm2ddl.auto" -> "create",
   "hibernate.format_sql" -> "true",
   "hibernate.ejb.naming_strategy" -> classOf[ImprovedNamingStrategy].getName,
   "hibernate.generate_statistics" -> true.toString
  ).asJava
 )
 entityManagerFactoryBean
}

Вот пример того, что мы можем увидеть в JvisualVM (не забудьте установить все плагины!):

Кроме того, мы получаем хорошую запись в Hibernate:

HQL: select generatedAlias0 from Book as generatedAlias0, time: 10ms, rows: 20

Ehcache

Мониторинг кэшей очень важен, особенно в приложениях, где вы ожидаете, что значения обычно присутствуют там. Я склонен запрашивать базу данных так часто, как это необходимо, чтобы избежать ненужных аргументов метода или локального
кэширования . Все, чтобы сделать код максимально простым. Однако этот подход работает только тогда, когда кэширование на уровне базы данных работает правильно. Как и в Hibernate, включение мониторинга JMX в
EhCache является двухэтапным процессом. Сначала вам нужно выставить предоставленный MBean в MBeanServer:

@Bean(initMethod = "init", destroyMethod = "dispose")
def managementService = new ManagementService(ehCacheManager(), platformMBeanServer(), true, true, true, true, true)
 
@Bean def platformMBeanServer() = ManagementFactory.getPlatformMBeanServer
 
def ehCacheManager() = ehCacheManagerFactoryBean.getObject
 
@Bean def ehCacheManagerFactoryBean = {
 val ehCacheManagerFactoryBean = new EhCacheManagerFactoryBean
 ehCacheManagerFactoryBean.setShared(true)
 ehCacheManagerFactoryBean.setCacheManagerName("spring-pitfalls")
 ehCacheManagerFactoryBean
}

Обратите внимание, что я явно установил имя CacheManager. Это не обязательно, но это имя используется как часть имени Mbean, а имя по умолчанию содержит значение hashCode, что не очень приятно. Последний штрих — включить статистику на основе кеша:

	<cache name="org.hibernate.cache.StandardQueryCache"
    maxElementsInMemory="10000"
    eternal="false"
    timeToIdleSeconds="3600"
    timeToLiveSeconds="600"
    overflowToDisk="false"
    memoryStoreEvictionPolicy="LRU"
    statistics="true"
/>

Теперь мы можем с радостью отслеживать различные характеристики кэширования каждого кэша в отдельности:
как мы видим, увеличивается процент пропусков кэша. Никогда хорошая вещь. Если мы не включаем статистику кэширования, включение JMX все еще является хорошей идеей, поскольку мы бесплатно получаем множество операций управления, включая очистку и очистку кэшей (полезно при отладке и тестировании).

org.quartz.scheduler.jmx.export=true

	
val job = newJob(classOf[MyJob])
val trigger = newTrigger().
  withSchedule(
   repeatSecondlyForever()
  ).
  startAt(
   futureDate(30, SECOND)
  )
scheduler.scheduleJob(job.build(), trigger.build())

@ManagedResource
class ManagedBasicDataSource extends BasicDataSource {
 
    @ManagedAttribute override def getNumActive = super.getNumActive
    @ManagedAttribute override def getNumIdle = super.getNumIdle
    @ManagedAttribute def getNumOpen = getNumActive + getNumIdle
    @ManagedAttribute override def getMaxActive: Int= super.getMaxActive
    @ManagedAttribute override def setMaxActive(maxActive: Int) {
        super.setMaxActive(maxActive)
    }
 
    @ManagedAttribute override def getMaxIdle = super.getMaxIdle
    @ManagedAttribute override def setMaxIdle(maxIdle: Int) {
        super.setMaxIdle(maxIdle)
    }
 
    @ManagedAttribute override def getMinIdle = super.getMinIdle
    @ManagedAttribute override def setMinIdle(minIdle: Int) {
        super.setMinIdle(minIdle)
    }
 
    @ManagedAttribute override def getMaxWait = super.getMaxWait
    @ManagedAttribute override def setMaxWait(maxWait: Long) {
        super.setMaxWait(maxWait)
    }
 
    @ManagedAttribute override def getUrl = super.getUrl
    @ManagedAttribute override def getUsername = super.getUsername
}

<context:mbean-export/>

@Bean def annotationMBeanExporter() = new AnnotationMBeanExporter()