Lotus Sametime Toolkit 开发入门，第 3 部分: 使用 Sametime Connect Toolkit 开发 Logging Bot

                
public void init() {
    try {
        session = new STSession("Logging Bot" + this);
        session.loadSemanticComponents();
    } catch (DuplicateObjectException e) {
        e.printStackTrace();
    }
    session.start();
    appNames = getAppNameList();        
    Iterator iter = appNames.iterator();        
    while(iter.hasNext()){
        String appName = (String)iter.next();
        LogBuffer buffer = new LogBuffer();
        this.logBuffers.put(appName, buffer);
    }
    login();
}			
private void login() {
        comm = (CommunityService) session
                .getCompApi(CommunityService.COMP_NAME);				
        comm.addLoginListener(new LoginHandler());				
        comm.loginByPassword(host, userId, password);
}			
public class LoginHandler implements LoginListener {
    public void loggedIn(LoginEvent event) {
        System.out.println("Logged in");			
        imService = (InstantMessagingService) session
                .getCompApi(InstantMessagingService.COMP_NAME);			
        imService.registerImType(LoggingBotConstant.IM_TYPE);			
        imService.addImServiceListener(new ImServiceHandler());
        Iterator iter = appNames.iterator();			
        while (iter.hasNext()) {
            String appName = (String) iter.next();
            Thread thread = new Thread(new PlaceRunable(appName));
            thread.start();                
        }			
    }			
    public void loggedOut(LoginEvent event) {
        System.out.print("Logged Out");
    }
}     

                
class PlaceRunable implements Runnable{        
        private String appName;
        public PlaceRunable(String appName){
            this.appName = appName;
        }
        public void run() {            
            LogBuffer buffer = (LogBuffer)logBuffers.get(appName);
            LoggingBotServerPlace place = new LoggingBotServerPlace(
                    session, appName,buffer);
            places.put(appName,place);
            System.out.println("Loging Bot Place created for "
                    + place.getAppName());
        }
        
}     

                
public LoggingBotServerPlace(STSession session,String appName,LogBuffer buffer) {
	this.session = session;
	this.appName = appName;
	this.buffer = buffer;
	PlacesService placesService = (PlacesService) session
			.getCompApi(PlacesService.COMP_NAME);
	// Create the place wer'e going to work with, and enter.
	place = placesService.createPlace(appName,
			appName, EncLevel.ENC_LEVEL_DONT_CARE, 0);
	place.addPlaceListener(new PlaceHandler());
	place.enter();
}   

                
public void writeLog(String appName, String logLevel, String logMsg) {        
    if(!appNames.contains(appName)){
        System.out.println("The application:"+appName+"is not supported by Logging Bot");
        return;
    }
    LogBuffer buffer = (LogBuffer)logBuffers.get(appName);  
    LogMessage lm = new LogMessage();
    lm.level = logLevel;
    lm.msg = logMsg;
    lm.date = new Date();
    buffer.addLog(lm);
    
}   

                
public void sendLogs(){
    //如果Place没有准备好，当前线程休眠1秒后再试
    while(!this.placeReady){
        try {            
            Thread.sleep(1000);
        } catch (InterruptedException e) {                        
            e.printStackTrace();
        }
    }	    
    LogMessage log = null;
    while(true){
        log = buffer.getLog();
        //如果Log，当前线程休眠1秒后再试
        if(null == log){               
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {                        
                e.printStackTrace();
            }
        }
        else{
            //向整个Place广播该log
            place.sendText(log.toString());
        }
    }
}   

                
public void textReceived(ImEvent e) {
    System.out.println("textReceived from" + e.getSource());
    String command = e.getText();
    if (LoggingBotConstant.LIST_PLACES.equals(command)) {
        // send a list a app names to client, sperated by comma.
        StringBuffer buffer = new StringBuffer();
        if (appNames != null) {
            for (int i = 0; i < appNames.size(); i++) {
                if (i != 0) {
                    buffer.append(",");
                }
                buffer.append(appNames.get(i));
            }
        }
        e.getIm().sendText(true, buffer.toString());
    }
} 

                
public class LoggingBotMessageHandler extends DefaultMessageHandler{
... ...
public void handleMessage(ImConnectedMessage message) {
    session = getSTSession(message.getCommunityId());
    if(null == session){        
        return;
    }
    getPlaceList(session);
}
private STSession getSTSession(String communityID){       
    try {
        communityMgr = (CommunityService) ServiceHub
              .getService(CommunityService.SERVICE_TYPE);            
        RtcSession rs = communityMgr.getCommunity(communityID).getRtcSession();
        return (STSession) rs.getProtocolSession();
    } catch (ServiceException e) {
        e.printStackTrace();
    }
    return null;
}
... ...
} 

                
public class GetPlaceListCommand extends Command {
    List places = new ArrayList();
    public GetPlaceListCommand(STSession session){
        super(session,LoggingBotConstant.LIST_PLACES);
    }
    public void handleResult(String result) {
        System.out.println("Place List from server:" + result);
        if(null == result){
            return;
        }
        String [] appNames = result.split(",");
        for(int i=0; i<appNames.length; i++){
            
            LoggingBotClientPlace place = new LoggingBotClientPlace(session,appNames[i]);
            this.places.add(place);
        }        
        LoggingBotView.INSTANCE.handlePlaceAdded(places);
    } 
}         
 

                          
public LoggingBotClientPlace(STSession session,String appName) {
    this.session = session;
    this.appName = appName;
    PlacesService placesService = (PlacesService) session
            .getCompApi(PlacesService.COMP_NAME);        
    place = placesService.createPlace(
            appName,
            appName, 
            EncLevel.ENC_LEVEL_DONT_CARE, 
            0);
    placeListener = new PlaceHandler();
    msgListener = new MyMsgHandler();        
}
public void enter() {    
    place.addPlaceListener(placeListener);
    place.enter();
}
public void left() {
    ... ...
    place.removePlaceListener(placeListener);
    place.leave(0);
}

                
public void handlePlaceAdded(final List places) {
    this.comp.getDisplay().asyncExec(new Runnable() {
        public void run() {
            createTab(places);
        }
    });
}

                
// 用户订阅了应用的Log
private void subscribeLog(String appName) {        
    LoggingBotClientPlace place = (LoggingBotClientPlace) this.places
            .get(appName);
    if (!place.isInPlace()) {
        System.out.println("Currently not in place, begin to enter");
        place.enter();
        return;
    } else {
        System.out.println("Already in place");
    }
}
// 接收到Log 以后，通知LoggingBotView进行更新
public class MyMsgHandler implements MyMsgListener {
        ... ...

        public void textReceived(MyselfEvent e) {
            System.out.println("Log received :" + e.getText());
            LoggingBotView.INSTANCE.handleLogReceived(appName,e.getText());
        }
}
//向Logging Bot View中添加Log
public void handleLogReceived(String appName, final String logMsg) {
    final Text txtLogMsg = (Text) this.logMsgTexts.get(appName);
    txtLogMsg.getDisplay().asyncExec(new Runnable() {
        public void run() {
            if (txtLogMsg.isDisposed()) {
                return;
            }
            if("".equals(txtLogMsg.getText())){
                txtLogMsg.setText(logMsg + "\r\n");
            }
            else{
                txtLogMsg.setText( txtLogMsg.getText() + logMsg + "\r\n");
            }                
        }
    });
}