Mycat-Web
Mycat-Web copied to clipboard
MyCATApache
Mycat配置管理 添加mycat功能，点击保存无法应（firefox） ，点击保存一直loading(chrom)
我的改法是将org/mycat/web/util/DataSourceUtils.java中的连接池进行了修改。主要是将druid连接池换成了dbcp, 连接服务端口时不指定数据库，且注释掉了服务端口的监听 ; 修改如下：（修改mycat应该也可以，但修改mycat成本太大，不做考虑） 另一种不改代码的方法就是mycat降级到1.6.
修改完的代码如下：
package org.mycat.web.util;
import java.sql.Connection; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSource; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.hx.rainbow.common.context.RainbowContext; import org.hx.rainbow.common.context.RainbowProperties; import org.hx.rainbow.common.core.SpringApplicationContext; import org.hx.rainbow.common.core.service.SoaManager; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.SqlSessionTemplate; import org.mycat.web.task.common.TaskManger; import org.mycat.web.task.server.CheckMycatSuspend; import org.mycat.web.task.server.CheckServerDown; import org.mycat.web.task.server.SyncClearData; import org.mycat.web.task.server.SyncSysSql; import org.mycat.web.task.server.SyncSysSqlhigh; import org.mycat.web.task.server.SyncSysSqlslow; import org.mycat.web.task.server.SyncSysSqlsum; import org.mycat.web.task.server.SyncSysSqtable; import org.springframework.beans.MutablePropertyValues; import org.springframework.beans.factory.config.ConstructorArgumentValues; import org.springframework.beans.factory.support.DefaultListableBeanFactory; import org.springframework.beans.factory.support.GenericBeanDefinition; import org.springframework.context.ConfigurableApplicationContext;
import com.alibaba.druid.pool.DruidDataSource;
public class DataSourceUtils {
private static final Logger logger = LogManager
.getLogger(DataSourceUtils.class);
public enum MycatPortType{
MYCAT_MANGER,
MYCAT_SERVER
}
public static final String DEFAULT_MYSQL_DRIVER_CLASS = "com.mysql.jdbc.Driver";
private volatile static DataSourceUtils dataSourceUtils = null;
private DataSourceUtils(){};
public static DataSourceUtils getInstance(){
if(dataSourceUtils == null){
synchronized (DataSourceUtils.class) {
if(dataSourceUtils == null){
dataSourceUtils = new DataSourceUtils();
}
}
}
return dataSourceUtils;
}
private static final String NAME_SUFFIX = "dataSource";
public boolean register(Map<String, Object> jdbc, String dbName, MycatPortType portType) throws Exception {
Connection conn = null;
String dbBean = dbName + portType;
String beanName = dbBean + NAME_SUFFIX;
try {
logger.info("dbname:" + dbBean + " is initializing!!");
remove(dbBean);
switch (portType) {
case MYCAT_MANGER:
jdbc.put("port", jdbc.get("mangerPort"));
break;
case MYCAT_SERVER:
jdbc.put("port", jdbc.get("serverPort"));
break;
default:
break;
};
ConfigurableApplicationContext applicationContext =
(ConfigurableApplicationContext) SpringApplicationContext.getApplicationContext();
DefaultListableBeanFactory beanFactory =
(DefaultListableBeanFactory) applicationContext.getBeanFactory();
beanFactory.registerBeanDefinition(beanName, getDefinition(jdbc, portType));
DataSource dbSource = (DataSource)SpringApplicationContext.getBean(beanName);
conn = dbSource.getConnection();
beanFactory.registerBeanDefinition(dbBean + "sqlSessionFactory", getSqlSessionFactoryDef(dbSource));
Object sqlSessionFactory = SpringApplicationContext.getBean(dbBean + "sqlSessionFactory");
beanFactory.registerBeanDefinition(dbBean + "sqlSessionTemplate", getSqlSessionTemplateDef(sqlSessionFactory));
if(MycatPortType.MYCAT_MANGER == portType){
updateTask(dbName);
}
return true;
} catch (Exception e) {
logger.error(e.getMessage(), e.getCause());
remove(dbBean);
return false;
}finally{
if(conn != null){
conn.close();
}
}
}
private void updateTask(String dbName){
TaskManger taskManger = TaskManger.getInstance();
System.out.println("添加监控dbName:" + dbName);
taskManger.addDBName(dbName);
taskManger.cancelTask("SyncSysSql", "SyncSysSqlhigh", "SyncSysSqlslow", "SyncSysSqtable", "SyncSysSqlsum");
taskManger.addTask(new SyncSysSql(), 60 * 1000, "SyncSysSql");//1分钟
taskManger.addTask(new SyncSysSqlhigh(), 60 * 1000*2, "SyncSysSqlhigh");//2分钟
taskManger.addTask(new SyncSysSqlslow(), 60 * 1000*2, "SyncSysSqlslow");//2分钟
taskManger.addTask(new SyncSysSqtable(), 60 * 1000*3, "SyncSysSqtable");//3分钟
taskManger.addTask(new SyncSysSqlsum(), 60 * 1000*3, "SyncSysSqlsum");//3分钟
taskManger.addTask(new SyncClearData(),60 *1000*60*10, "SyncClearData");//10小时
taskManger.addTask(new CheckMycatSuspend(), 60 * 1000*5, "CheckMycatSuspend",10);//5分钟检查一次，10秒一次
taskManger.addTask(new CheckServerDown(), 60 * 1000*5, "CheckServerDown");//5分钟检查一次
}
public synchronized boolean register(String dbName, MycatPortType portType) throws Exception {
String beanId = dbName + portType + NAME_SUFFIX;
if(!SpringApplicationContext.getApplicationContext().containsBean(beanId)){
RainbowContext context = new RainbowContext("mycatService", "query");
context.addAttr("mycatName", dbName);
context = SoaManager.getInstance().invokeNoTx(context);
if (context.getRows() == null || context.getRows().size() == 0) {
return false;
}
Map<String, Object> row = context.getRow(0);
switch (portType) {
case MYCAT_MANGER:
row.put("port", row.get("mangerPort"));
break;
case MYCAT_SERVER:
row.put("port", row.get("serverPort"));
break;
default:
break;
};
return register(row, dbName, portType);
}else{
Connection conn = null;
try{
DataSource dbSource = (DataSource)SpringApplicationContext.getBean(beanId);
conn = dbSource.getConnection();
}catch(Exception ex){
ex.printStackTrace();
logger.warn("连接异常,进行重试!");
remove(dbName + portType);
// return false; return register(dbName, portType); }finally{ if(conn != null){ conn.close(); } } } return true; }
public synchronized boolean register(Map<String, Object> jdbc, String dbName) throws Exception {
if(!register(jdbc, dbName, MycatPortType.MYCAT_MANGER)){
return false;
}
// if(! register(jdbc, dbName, MycatPortType.MYCAT_SERVER)){ // return false; // } return true;
}
public synchronized boolean register(String dbName) throws Exception {
if(!register(dbName, MycatPortType.MYCAT_MANGER)){
return false;
}
// if(! register(dbName, MycatPortType.MYCAT_SERVER)){ // return false; // } return true; }
public String getDbName(String dbName) {
int n_pos = dbName.indexOf(MycatPortType.MYCAT_MANGER+"");
if (n_pos>0) {
return dbName.substring(0,n_pos);
}
else {
return dbName;
}
}
public String getDbName(String dbName, MycatPortType portType ) {
int n_pos = dbName.indexOf(portType+"");
if (n_pos>0) {
return dbName.substring(0,n_pos);
}
else {
return dbName;
}
}
public void remove(String dbName) {
ConfigurableApplicationContext applicationContext =
(ConfigurableApplicationContext) SpringApplicationContext.getApplicationContext();
DefaultListableBeanFactory beanFactory =
(DefaultListableBeanFactory) applicationContext.getBeanFactory();
beanFactory.destroySingleton(dbName + NAME_SUFFIX);
beanFactory.destroySingleton(dbName + "sqlSessionFactory");
beanFactory.destroySingleton(dbName + "sqlSessionTemplate");
beanFactory.destroySingleton(dbName+ "transactionManager");
}
private GenericBeanDefinition getDefinition(Map<String, Object> jdbc, MycatPortType portType) {
GenericBeanDefinition messageSourceDefinition = new GenericBeanDefinition();
Map<String, Object> original = new HashMap<String, Object>();
original.put("driverClassName", DEFAULT_MYSQL_DRIVER_CLASS);
original.put("url", getMySQLURL((String)jdbc.get("ip"), (String)jdbc.get("port"), (String)jdbc.get("dbName")));
original.put("username", jdbc.get("username"));
original.put("password", jdbc.get("password"));
original.put("maxActive", RainbowProperties.getProperties("jdbc.maxActive"));
original.put("initialSize", RainbowProperties.getProperties("jdbc.initialSize"));
original.put("maxWait", RainbowProperties.getProperties("jdbc.maxWait"));
original.put("minIdle", RainbowProperties.getProperties("jdbc.minIdle"));
original.put("timeBetweenEvictionRunsMillis", 3600000);
original.put("minEvictableIdleTimeMillis",300000);
switch (portType) {
case MYCAT_MANGER:
original.put("validationQuery", "show @@sysparam");
original.put("testWhileIdle", false);
break;
case MYCAT_SERVER:
original.put("validationQuery", "select user()");
original.put("testWhileIdle", true);
break;
default:
break;
};
original.put("testOnBorrow", false);
original.put("testOnReturn", false);
original.put("poolPreparedStatements", false);
//original.put("maxPoolPreparedStatementPerConnectionSize", 200);
original.put("removeAbandoned", true);
original.put("removeAbandonedTimeout", 1800);
original.put("logAbandoned", true);
//messageSourceDefinition.setBeanClass(DruidDataSource.class);
messageSourceDefinition.setBeanClass(BasicDataSource.class);
messageSourceDefinition.setDestroyMethodName("close");
messageSourceDefinition.setPropertyValues(new MutablePropertyValues(original));
return messageSourceDefinition;
}
private String getMySQLURL(String ip, String port, String server) {
//return "jdbc:mysql://" + ip + ":" + port + "/" + server + "?characterEncoding=utf8";
return "jdbc:mysql://" + ip + ":" + port + "/" + "?characterEncoding=utf8";
}
private GenericBeanDefinition getSqlSessionFactoryDef(Object dbSource) {
GenericBeanDefinition sessionFactoryDef = new GenericBeanDefinition();
Map<String, Object> paramData = new HashMap<String, Object>();
paramData.put("dataSource", dbSource);
List<String> list = new ArrayList<String>();
list.add("classpath:mybatis/**/*Mapper.xml");
paramData.put("mapperLocations", list);
paramData.put("typeAliasesPackage", "org.hx.rainbow.common.dao.handler");
sessionFactoryDef.setBeanClass(SqlSessionFactoryBean.class);
sessionFactoryDef.setPropertyValues(new MutablePropertyValues(paramData));
return sessionFactoryDef;
}
private GenericBeanDefinition getSqlSessionTemplateDef(Object sqlSessionFacotry) {
GenericBeanDefinition sqlSessionTemplateDef = new GenericBeanDefinition();
ConstructorArgumentValues values = new ConstructorArgumentValues();
values.addIndexedArgumentValue(0, sqlSessionFacotry);
sqlSessionTemplateDef.setConstructorArgumentValues(values);
sqlSessionTemplateDef.setBeanClass(SqlSessionTemplate.class);
return sqlSessionTemplateDef;
}
}
