基于宝贝鱼(CshBBrain)开发聊天类应用 群发消息的问题?报错

public Response service(Client sockector, HashMap<String, String> requestData){
		if(requestData == null){
			return null;
		}
		
		log.info(requestData.get(Constants.FILED_MSG));
		Response responseMessage = null;
		try{
			if(!MyStringUtil.isBlank(requestData.get(Constants.HANDSHAKE))){
				responseMessage = Response.msgOnlyBody(requestData.get(Constants.FILED_MSG));
			}else{
				responseMessage = Response.msgOnlyBody("Hello," + requestData.get(Constants.FILED_MSG));				
			}
		}catch(Exception e){
			e.printStackTrace();
			responseMessage = Response.msgOnlyBody("500处理失败了");			
		}
		
		return responseMessage;
	}

 请问，在Service中我如何广播消息。我尝试过这样

Response responseMessage = null;
			if(!MyStringUtil.isBlank(requestData.get(Constants.HANDSHAKE))){
				responseMessage = Response.msgOnlyBody(requestData.get(Constants.FILED_MSG));
			}else{
				responseMessage = Response.msgOnlyBody("Hello," + requestData.get(Constants.FILED_MSG));				
			}
MasterServer.addBroadMessage(responseMessage);

但是会报如下错误信息

java.lang.NullPointerException
	at com.jason.server.Response.msgRespose(Response.java:120)

麻烦您时间方便请指点一下该怎样实现。

看了下你的问题，CshBBrain最新版本有个问题修改下就可以了。我直接贴代码：

MyStringUtil.java

添加属性：
public static final String CSHBBRAIN_CONTENT = "CSHBBRAIN_CONTENT";

修改方法：

public static HashMap<String,String> parseKeyValue(String msg){    
    if(isBlank(msg)){
            return null;
        }
    
    String values = null;
        try{
        values = URLDecoder.decode(msg, CoderUtils.UTF8);
        }catch(UnsupportedEncodingException e){
            throw new UnsupportedCharsetException(CoderUtils.UTF8);
        }
        
        HashMap<String,String> requestData = new HashMap<String,String>();
        
        requestData.put(CSHBBRAIN_CONTENT, values);// 所有信息
    
        Matcher m = PARAM_PATTERN.matcher(values);
        int pos = 0;
        while (m.find(pos)) {
            pos = m.end();            
            requestData.put(m.group(1), m.group(2)); 
        }
        
        return requestData;
    }


Service.java
public Response service(Client sockector, HashMap<String, String> requestData){
if(requestData == null){
return null;
}

Response responseMessage = null;

try{
if(!MyStringUtil.isBlank(requestData.get(Constants.HANDSHAKE))){
responseMessage = Response.msgOnlyBody(requestData.get(Constants.FILED_MSG));
}else{
MasterServer.addBroadMessage(Response.msgOnlyBody("hello " + requestData.get(MyStringUtil.CSHBBRAIN_CONTENT)));
responseMessage = Response.msgOnlyBody("hello " + requestData.get(MyStringUtil.CSHBBRAIN_CONTENT));
//responseMessage = Response.msgOnlyBody("var taskKey= " + requestData.get("taskKey")  + "; var resultData= '<-" + requestData.get("taskKey") +"->'");
}
}catch(Exception e){
e.printStackTrace();
responseMessage = Response.msgOnlyBody("500处理失败了");
}

return responseMessage;
}