欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java基于JNDI 實(shí)現(xiàn)讀寫分離的示例代碼

 更新時(shí)間：2021年12月13日 11:33:44   作者：沙漠一只鵰  
本文主要介紹了Java基于JNDI 實(shí)現(xiàn)讀寫分離的示例代碼，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

一、JNDI數(shù)據(jù)源配置

在Tomcat的conf目錄下，context.xml在其中標(biāo)簽中添加如下JNDI配置：

<Resource name="dataSourceMaster" factory="org.apache.tomcat.jdbc.pool.DataSourceFactory" 
 auth="Container" type="javax.sql.DataSource" maxActive="100" maxIdle="30" maxWaitMillis="30000"
 username="root" password="root" driverClassName="com.mysql.jdbc.Driver"  url="jdbc:mysql://localhost:3306/user_master?useUnicode=true&amp;characterEncoding=utf-8"/>
<Resource name="dataSourceSlave" factory="org.apache.tomcat.jdbc.pool.DataSourceFactory" 
 auth="Container" type="javax.sql.DataSource" maxActive="100" maxIdle="30" maxWaitMillis="30000"   
 username="root" password="root" driverClassName="com.mysql.jdbc.Driver"  url="jdbc:mysql://localhost:3306/user_slave?useUnicode=true&amp;characterEncoding=utf-8"/>

二、JNDI數(shù)據(jù)源使用

1、在普通web項(xiàng)目中

（1）在web.xml文件中添加如下配置（也可以不配置）：

<resource-ref>
 <res-ref-name>dataSourceMaster</res-ref-name>
 <res-type>javax.sql.DataSource</res-type> 
 <res-auth>Container</res-auth>
</resource-ref>
<resource-ref>
 <res-ref-name>dataSourceSlave</res-ref-name>
 <res-type>javax.sql.DataSource</res-type>
 <res-auth>Container</res-auth>
</resource-ref>

三、web.xml配置

<!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app>  
 <display-name>Archetype Created Web Application</display-name>  
 <context-param>    
  <param-name>log4jConfigLocation</param-name>    
  <param-value>classpath:log4j.properties</param-value>  
 </context-param>    
 <context-param>    
  <param-name>log4jRefreshInterval</param-name>    
  <param-value>60000</param-value>  
 </context-param>  
 <filter>    
  <filter-name>CharacterEncodingFilter</filter-name>    
  <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>     
  <init-param>      
   <param-name>encoding</param-name>      
   <param-value>utf-8</param-value>    
  </init-param>    
  <init-param>      
   <param-name>forceEncoding</param-name>      
   <param-value>true</param-value>    
  </init-param>  
 </filter>  
 <filter-mapping>    
  <filter-name>CharacterEncodingFilter</filter-name>    
  <servlet-name>xiyun</servlet-name>  
 </filter-mapping>  
 <servlet>    
  <servlet-name>xiyun</servlet-name>    
  <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>    
  <init-param>      
   <param-name>contextConfigLocation</param-name>      
   <param-value>        classpath:conf/spring/spring-servlet.xml      </param-value>    
  </init-param>    
  <load-on-startup>1</load-on-startup>  
 </servlet>  
 <servlet-mapping>    
  <servlet-name>xiyun</servlet-name>    
  <url-pattern>*.do</url-pattern>  
 </servlet-mapping>
</web-app>

四、spring-servlet.xml配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"       
 xmlns:context="http://www.springframework.org/schema/context"       xmlns:mvc="http://www.springframework.org/schema/mvc"       
 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd       
 http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd       
 http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">    
 
 <context:component-scan base-package="com.xiaoxi"/>    
 
 <mvc:annotation-driven/>    
 
 <import resource="classpath:conf/spring/spring-db.xml"/>    
 
 <bean id="viewResolver"          class="org.springframework.web.servlet.view.InternalResourceViewResolver">        
  <property name="prefix" value="/WEB-INF/freemarker/"/>        
  <property name="suffix" value=".ftl"/>    
  </bean>
 </beans>

五、spring-db.xml配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"       
 xmlns:aop="http://www.springframework.org/schema/aop"       xmlns:context="http://www.springframework.org/schema/context"       
 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd       
 http://www.springframework.org/schema/context  http://www.springframework.org/schema/context/spring-context.xsd       
 http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd" >    
 
 <!-- 主數(shù)據(jù)源配置 -->    
 <bean id="dataSourceMaster" class="org.springframework.jndi.JndiObjectFactoryBean">        
  <property name="jndiName" value="java:comp/env/dataSourceMaster"/>    
 </bean>    
 <!-- 從數(shù)據(jù)源配置 -->    
 <bean id="dataSourceSlave" class="org.springframework.jndi.JndiObjectFactoryBean">        
  <property name="jndiName" value="java:comp/env/dataSourceSlave"/>    
 </bean>    
 
 <aop:aspectj-autoproxy proxy-target-class="true"/>    

    <context:annotation-config/>    

 <bean id="dynamicDataSource" class="com.xiaoxi.config.DynamicRoutingDataSource">        
  <property name="targetDataSources">            
   <map>                
    <entry key="Master" value-ref="dataSourceMaster"/>                
    <entry key="Slave" value-ref="dataSourceSlave"/>            
   </map>        
  </property>        
  <property name="defaultTargetDataSource" value="dataSourceMaster"/>    
 </bean>    
 
 <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">        
  <!-- 配置數(shù)據(jù)源 -->        
  <property name="dataSource" ref="dynamicDataSource"/>    
 </bean>    
 
 <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">        
  <!-- 映射數(shù)據(jù)源 -->        
  <property name="dataSource" ref="dynamicDataSource"/>        
  <!-- 映射mybatis核心配置文件 -->        
  <property name="configLocation" value="classpath:conf/spring/mybatis-config.xml"/>        
  <!-- 映射mapper文件 -->        
  <property name="mapperLocations">            
   <list>                
    <value>classpath:conf/sqlMap/*.xml</value>            
   </list>        
  </property>    
 </bean>    

 <!-- 獲得sqlSession -->    
 <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">        
  <constructor-arg name="sqlSessionFactory" ref="sqlSessionFactory"/>     
 </bean>    

 <bean id="mapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer">        
  <!-- 這里的basePackage 指定了dao層接口路勁，這里的dao接口不用自己實(shí)現(xiàn) -->        
  <property name="basePackage" value="com.xiaoxi.dao" />        
  <!-- 如果只有一個(gè)數(shù)據(jù)源的話可以不用指定，但是如果有多個(gè)數(shù)據(jù)源的話必須要指定 -->        
  <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />        
  <!--直接指定了sqlsessionTemplate名稱，這個(gè)和上面的其實(shí)是一樣的 -->        
  <property name="sqlSessionTemplateBeanName" value="sqlSession" />    
 </bean>
</beans>

六、log4j.properties配置

log4j.rootLogger=DEBUG, CATALINA# Define all the appenders
log4j.appender.CATALINA=org.apache.log4j.RollingFileAppender
log4j.appender.CATALINA.File=${catalina.base}/logs/catalina.log
log4j.appender.CATALINA.Append=true
log4j.appender.CATALINA.MaxFileSize=10MB
log4j.appender.CATALINA.Encoding=UTF-8

# Roll-over the log once per day
log4j.appender.CATALINA.layout = org.apache.log4j.PatternLayout
log4j.appender.CATALINA.layout.ConversionPattern = %d [%t] %-5p %c- %m%n
log4j.appender.LOCALHOST=org.apache.log4j.RollingFileAppender
log4j.appender.LOCALHOST.File=${catalina.base}/logs/localhost.log
log4j.appender.LOCALHOST.MaxFileSize=10MB
log4j.appender.LOCALHOST.Append=true
log4j.appender.LOCALHOST.Encoding=UTF-8
log4j.appender.LOCALHOST.layout = org.apache.log4j.PatternLayout
log4j.appender.LOCALHOST.layout.ConversionPattern = %d [%t] %-5p %c- %m%n

log4j.appender.MANAGER=org.apache.log4j.RollingFileAppender
log4j.appender.MANAGER.File=${catalina.base}/logs/manager.log
log4j.appender.MANAGER.MaxFileSize=10MB
log4j.appender.MANAGER.Append=true
log4j.appender.MANAGER.Encoding=UTF-8
log4j.appender.MANAGER.DatePattern='.'yyyy-MM-dd'.log'
log4j.appender.MANAGER.layout = org.apache.log4j.PatternLayout
log4j.appender.MANAGER.layout.ConversionPattern = %d [%t] %-5p %c- %m%n

log4j.appender.HOST-MANAGER=org.apache.log4j.RollingFileAppender
log4j.appender.HOST-MANAGER.File=${catalina.base}/logs/host-manager.log
log4j.appender.HOST-MANAGER.MaxFileSize=10MB
log4j.appender.HOST-MANAGER.Append=true
log4j.appender.HOST-MANAGER.Encoding=UTF-8
log4j.appender.HOST-MANAGER.DatePattern='.'yyyy-MM-dd'.log'
log4j.appender.HOST-MANAGER.layout = org.apache.log4j.PatternLayout
log4j.appender.HOST-MANAGER.layout.ConversionPattern = %d [%t] %-5p %c- %m%n

log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.Encoding=UTF-8
log4j.appender.CONSOLE.layout = org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern = %d [%t] %-5p %c- %m%n

# Configure which loggers log to which appenders
log4j.logger.org.apache.catalina.core.ContainerBase.[Catalina].[localhost]=INFO, LOCALHOST
log4j.logger.org.apache.catalina.core.ContainerBase.[Catalina].[localhost].[/manager]= INFO, MANAGER
log4j.logger.org.apache.catalina.core.ContainerBase.[Catalina].[localhost].[/host-manager]= INFO, HOST-MANAGER

七、相關(guān)路由數(shù)據(jù)源切換邏輯代碼

package com.xiaoxi.config;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
import java.util.Map;

public class DynamicRoutingDataSource extends AbstractRoutingDataSource {

    @Override
    public void setTargetDataSources(Map<Object, Object> targetDataSources) {
        super.setTargetDataSources(targetDataSources);
        super.afterPropertiesSet();
    }

    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceContextHolder.getDbType();
    }
}
package com.xiaoxi.config;

/**
 * 線程上下文 <br>
 * 用于保存線程本地變量DbType(用于切換數(shù)據(jù)源)
 * 如果是異步線程操作，需要用InheritableThreadLocal （需要保存父線程的變量）
 *
 * @see [相關(guān)類/方法](可選)
 * @since [產(chǎn)品/模塊版本](可選)
 */
public class DataSourceContextHolder {

    private static final ThreadLocal<DbType> contextHolder = new ThreadLocal<>();

    public static ThreadLocal<DbType> getLocal() {
        return contextHolder;
    }

    private DataSourceContextHolder () {}

    public static String getDbType() {
        return contextHolder.get() == null ? DbType.MASTER.dbType : contextHolder.get().dbType;
    }

    public static void setDbType(DbType dbType) {
        contextHolder.set(dbType);
    }

    public static void clearDbType() {
        contextHolder.remove();
    }

    public enum DbType {

        MASTER("Master"),

        SLAVE("Slave");

        private String dbType;

        DbType(String dbType) {
            this.dbType = dbType;
        }

        public String getDbType() {
            return dbType;
        }
    }
}
package com.xiaoxi.aop;

import com.xiaoxi.config.DataSourceContextHolder;
import org.apache.log4j.Logger;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

/**
 * 數(shù)據(jù)源切面，用于在執(zhí)行sql前進(jìn)行讀寫數(shù)據(jù)源切換 <br>
 * 〈功能詳細(xì)描述〉
 *
 * @see [相關(guān)類/方法](可選)
 * @since [產(chǎn)品/模塊版本](可選)
 */
@Aspect
@Order(-1)
@Component
public class DataSourceAop {

    private static Logger logger = Logger.getLogger(DataSourceAop.class);

    @Before("execution(* com.xiaoxi.dao..*.query*(..))")
    public void setReadDataSourceType() {
        DataSourceContextHolder.setDbType(DataSourceContextHolder.DbType.MASTER);
        logger.debug("[DataSourceAop] DataSource Covert To SLAVE");
    }

    @Before("execution(* com.xiaoxi.dao..*.insert*(..))" +
         "|| execution(* com.xiaoxi.dao..*.update*(..))" +
         "|| execution(* com.xiaoxi.dao..*.delete*(..))")
    public void setWriteDataSourceType() {
        DataSourceContextHolder.setDbType(DataSourceContextHolder.DbType.SLAVE);
        logger.debug("[DataSourceAop] DataSource Covert To MASTER");
    }

    /** ☆☆☆☆☆ 也可以獲取參數(shù)中路由字段進(jìn)行切換數(shù)據(jù)源 ☆☆☆☆☆ **/

    @Pointcut("execution(* com.xiaoxi.dao..*.*(..))")
    public void cutPoint() {}

    @Before(value="cutPoint()")
    public void setDynamicDataSource(JoinPoint point){
        String className = point.getTarget().getClass().getSimpleName();
        String methodName = point.getSignature().getName();
        String log = "[DataSourceAop] className:%s, methodName:%s";
        logger.debug(String.format(log, className, methodName));
    }
}

八、搭建過程中遇到的問題和解決方案

1、注入數(shù)據(jù)源dataSourceMaster和dataSourceSlave失敗
spring 中jndiName配置的數(shù)據(jù)源名稱和Tomcat配置文件中Resource name存在區(qū)別，并非一致,其中java:comp/env為環(huán)境，否則會(huì)報(bào)can not find jndi name …

2、Cannot create JDBC driver of class ‘' for connect URL ‘null'

3、The requested resource is not available（404）
分析了web.xml和servlet.xml發(fā)現(xiàn)配置無誤，注解驅(qū)動(dòng)和包掃描都配置，但仍然訪問不了，后發(fā)現(xiàn)
項(xiàng)目啟動(dòng)過程中打印的日志存在問題，如下：
2019-12-17 16:20:41,767 [RMI TCP Connection(3)-127.0.0.1] INFO org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerMapping- Mapped “{[/userInfo],methods=[GET]}” onto public java.lang.String com.xiaoxi.controller.UserInfoController.queryUserInfoById(java.lang.String)
通過分析發(fā)現(xiàn)這里的請求映射，通過controller的requestMapping映射到具體方法，卻丟失了方法上的requestMapping路徑，后發(fā)現(xiàn)方法RequestMapping寫法如下：

@Controller
@RequestMapping("/userInfo")
public class UserInfoController {

    private static Logger logger =Logger.getLogger(UserInfoController.class);

    @Autowired
    private UserInfoService userInfoService;

    @ResponseBody
    @RequestMapping(name= "/queryUserInfoById", method = RequestMethod.GET)
    public String queryUserInfoById(@RequestParam("id") String id){
        logger.info("UserInfoController.queryUserInfoById.  id:{}" + id);
        UserInfo userInfo = userInfoService.queryUserInfoById(id);
        return JSON.toJSONString(userInfo);
    }
}

此處的RequestMapping屬性name應(yīng)該改為value，否則解析為空（可查看注解定義）

到此這篇關(guān)于Java基于JNDI 實(shí)現(xiàn)讀寫分離的示例代碼的文章就介紹到這了,更多相關(guān)Java JNDI讀寫分離內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

相關(guān)文章

  • Java中Array、List、ArrayList的區(qū)別及說明

    Java中Array、List、ArrayList的區(qū)別及說明

    這篇文章主要介紹了Java中Array、List、ArrayList的區(qū)別及說明，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2023-07-07
  • java_時(shí)間戳與Date_相互轉(zhuǎn)化的實(shí)現(xiàn)代碼

    java_時(shí)間戳與Date_相互轉(zhuǎn)化的實(shí)現(xiàn)代碼

    本篇文章是對java_時(shí)間戳與Date_相互轉(zhuǎn)化的實(shí)現(xiàn)代碼進(jìn)行了詳細(xì)的分析介紹,需要的朋友參考下如下。
    2016-11-11
  • JavaWeb中異步交互的關(guān)鍵Ajax詳解

    JavaWeb中異步交互的關(guān)鍵Ajax詳解

    這篇文章主要給大家介紹了關(guān)于JavaWeb中異步交互關(guān)鍵Ajax的相關(guān)資料,在javaweb中,ajax是前后臺(tái)交互的技術(shù),可以實(shí)現(xiàn)異步請求,不用刷新整個(gè)頁面就可以完成操作,需要的朋友可以參考下
    2023-07-07
  • IntelliJ IDEA 構(gòu)建maven多模塊工程項(xiàng)目(詳細(xì)多圖)

    IntelliJ IDEA 構(gòu)建maven多模塊工程項(xiàng)目(詳細(xì)多圖)

    這篇文章主要介紹了IntelliJ IDEA 構(gòu)建maven多模塊工程項(xiàng)目(詳細(xì)多圖)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-06-06
  • 深入解讀分布式事務(wù)Seata的XA模式

    深入解讀分布式事務(wù)Seata的XA模式

    這篇文章主要介紹了深入解讀分布式事務(wù)Seata的XA模式,XA 規(guī)范 描述了全局的事務(wù)管理器與局部的資源管理器之間的接口,XA規(guī)范 的目的是允許的多個(gè)資源在同一事務(wù)中訪問,這樣可以使 ACID 屬性跨越應(yīng)用程序而保持有效,需要的朋友可以參考下
    2023-08-08
  • java模擬實(shí)現(xiàn)銀行ATM機(jī)操作

    java模擬實(shí)現(xiàn)銀行ATM機(jī)操作

    這篇文章主要為大家詳細(xì)介紹了java模擬實(shí)現(xiàn)銀行ATM機(jī)操作，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
    2022-05-05
  • RocketMQ延遲消息簡明介紹

    RocketMQ延遲消息簡明介紹

    這篇文章主要介紹了RocketMQ延遲消息，延遲消息是個(gè)啥？顧名思義，就是等一段時(shí)間再消費(fèi)的消息。文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2022-08-08
  • redisson分布式鎖的用法大全

    redisson分布式鎖的用法大全

    這篇文章主要介紹了redisson分布式鎖的用法,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下
    2021-03-03
  • Java使用正則表達(dá)式檢索、替換String中特定字符和正則表達(dá)式的一切

    Java使用正則表達(dá)式檢索、替換String中特定字符和正則表達(dá)式的一切

    這篇文章主要給大家介紹了關(guān)于Java使用正則表達(dá)式檢索、替換String中特定字符和正則表達(dá)式的一切，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-09-09
  • 從源碼角度簡單看StringBuilder和StringBuffer的異同(全面解析)

    從源碼角度簡單看StringBuilder和StringBuffer的異同(全面解析)

    下面小編就為大家分享一篇從源碼角度簡單看StringBuilder和StringBuffer的異同(全面解析)，具有很好的參考價(jià)值，希望對大家有所幫助。一起跟隨小編過來看看吧
    2017-12-12

最新評論