import com.easemob.EMConnectionListener; //导入依赖的package包/类
/**
 * init HuanXin listeners
 */
protected void initListener(){
    Log.d(TAG, "init listener");
    
    // create the global connection listener
    connectionListener = new EMConnectionListener() {
        @Override
        public void onDisconnected(int error) {
        	if (error == EMError.USER_REMOVED) {
        		onCurrentAccountRemoved();
        	}else if (error == EMError.CONNECTION_CONFLICT) {
                onConnectionConflict();
            }else{
                onConnectionDisconnected(error);
            }
        }

        @Override
        public void onConnected() {
            onConnectionConnected();
        }
    };
    
    //注册连接监听
    EMChatManager.getInstance().addConnectionListener(connectionListener);       
}
 

import com.easemob.EMConnectionListener; //导入依赖的package包/类
/**
 * 设置全局事件监听
 */
protected void setGlobalListeners(){
    syncGroupsListeners = new ArrayList<DataSyncListener>();
    syncContactsListeners = new ArrayList<DataSyncListener>();
    syncBlackListListeners = new ArrayList<DataSyncListener>();
    
    isGroupsSyncedWithServer = demoModel.isGroupsSynced();
    isContactsSyncedWithServer = demoModel.isContactSynced();
    isBlackListSyncedWithServer = demoModel.isBacklistSynced();
    
    // create the global connection listener
    connectionListener = new EMConnectionListener() {
        @Override
        public void onDisconnected(int error) {
            if (error == EMError.USER_REMOVED) {
                onCurrentAccountRemoved();
            }else if (error == EMError.CONNECTION_CONFLICT) {
                onConnectionConflict();
            }
        }

        @Override
        public void onConnected() {
            
            // in case group and contact were already synced, we supposed to notify sdk we are ready to receive the events
            if(isGroupsSyncedWithServer && isContactsSyncedWithServer){
                new Thread(){
                    @Override
                    public void run(){
                        DemoHelper.getInstance().notifyForRecevingEvents();
                    }
                }.start();
            }else{
                if(!isGroupsSyncedWithServer){
                    asyncFetchGroupsFromServer(null);
                }
                
                if(!isContactsSyncedWithServer){
                    asyncFetchContactsFromServer(null);
                }
                
                if(!isBlackListSyncedWithServer){
                    asyncFetchBlackListFromServer(null);
                }
            }
            // 当连接到服务器之后，这里开始检查是否有没有发送的ack回执消息，
            EaseACKUtil.getInstance(appContext).checkACKData();
            
        }
    };
    
    
    IntentFilter callFilter = new IntentFilter(EMChatManager.getInstance().getIncomingCallBroadcastAction());
    if(callReceiver == null){
        callReceiver = new CallReceiver();
    }

    //注册通话广播接收者
    appContext.registerReceiver(callReceiver, callFilter);    
    //注册连接监听
    EMChatManager.getInstance().addConnectionListener(connectionListener);       
    //注册群组和联系人监听
    registerGroupAndContactListener();
    //注册消息事件监听
    registerEventListener();
    
}
 

import com.easemob.EMConnectionListener; //导入依赖的package包/类
/**
 * 设置全局事件监听
 */
protected void setGlobalListeners() {
    syncGroupsListeners = new ArrayList<DataSyncListener>();
    syncContactsListeners = new ArrayList<DataSyncListener>();
    syncBlackListListeners = new ArrayList<DataSyncListener>();

    isGroupsSyncedWithServer = demoModel.isGroupsSynced();
    isContactsSyncedWithServer = demoModel.isContactSynced();
    isBlackListSyncedWithServer = demoModel.isBacklistSynced();

    // create the global connection listener
    connectionListener = new EMConnectionListener() {
        @Override
        public void onDisconnected(int error) {
            if (error == EMError.USER_REMOVED) {
                onCurrentAccountRemoved();
            } else if (error == EMError.CONNECTION_CONFLICT) {
                onConnectionConflict();
            }
        }

        @Override
        public void onConnected() {

            // in case group and contact were already synced, we supposed to notify sdk we are ready to receive the events
            if (isGroupsSyncedWithServer && isContactsSyncedWithServer) {
                new Thread() {
                    @Override
                    public void run() {
                        DemoHelper.getInstance().notifyForRecevingEvents();
                    }
                }.start();
            } else {
                if (!isGroupsSyncedWithServer) {
                    asyncFetchGroupsFromServer(null);
                }

                if (!isContactsSyncedWithServer) {
                    asyncFetchContactsFromServer(null);
                }

                if (!isBlackListSyncedWithServer) {
                    asyncFetchBlackListFromServer(null);
                }
            }
        }
    };


    IntentFilter callFilter = new IntentFilter(EMChatManager.getInstance().getIncomingCallBroadcastAction());
    if (callReceiver == null) {
        callReceiver = new CallReceiver();
    }

    //注册通话广播接收者
    appContext.registerReceiver(callReceiver, callFilter);
    //注册连接监听
    EMChatManager.getInstance().addConnectionListener(connectionListener);
    //注册群组和联系人监听
    registerGroupAndContactListener();
    //注册消息事件监听
    registerEventListener();

}