Mycat配置管理 添加mycat功能，点击保存无法应（firefox） ，点击保存一直loading(chrom)

[JJdog]

No description provided.

[joffreychen]

请问您的问题解决了吗，我也遇到与您同样的问题不知道怎么解决

[arsArtD]

我的改法是将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;
}

}

[gaotuan]

mark, 同样遇到这个问题，求解决方案

[gaotuan]

请问您的问题解决了吗，我也遇到与您同样的问题不知道怎么解决

我也遇到了

[gaotuan]

且注释

需要从新编译吗？ 有没有具体的操作步骤