aladdinclientconnectionmanager.java

来自「mysql集群」· Java 代码 · 共 42 行

package com.meidusa.amoeba.aladdin.net;

import java.io.IOException;

import com.meidusa.amoeba.aladdin.handler.AladdinMessageDispatcher;
import com.meidusa.amoeba.mysql.net.MysqlClientConnectionManager;
import com.meidusa.amoeba.mysql.net.packet.OkPacket;
import com.meidusa.amoeba.net.AuthResponseData;
import com.meidusa.amoeba.net.Connection;

public class AladdinClientConnectionManager extends
		MysqlClientConnectionManager {
	private static byte[] authenticateOkPacketData;
	public AladdinClientConnectionManager() throws IOException {
	}
	
	public AladdinClientConnectionManager(String managerName,int port) throws IOException {
		super(managerName,port);
	}
	
	public AladdinClientConnectionManager(String name,String ipAddress,int port) throws IOException{
		super(name,ipAddress,port);
	}
	
	public void connectionAuthenticateSuccess(Connection conn,AuthResponseData data) {
		if(logger.isInfoEnabled()){
			logger.info("Connection Authenticate success [ conn=" + conn + "].");
		}
		if(authenticateOkPacketData == null){
			OkPacket ok = new OkPacket();
			ok.packetId = 2;
			ok.affectedRows = 0;
			ok.insertId = 0;
			ok.serverStatus = 2;
			ok.warningCount = 0;
			authenticateOkPacketData = ok.toByteBuffer(conn).array();
		}
		conn.setMessageHandler(new AladdinMessageDispatcher());
		conn.postMessage(authenticateOkPacketData);
	}
}