gitee/cim
1
0
Fork 0
mirror of https://gitee.com/farsunset/cim.git synced 2025-08-01 20:37:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update MessageAction.java

Browse Source
This commit is contained in:
远方夕阳 2015-06-17 11:49:21 +08:00
parent e1126717d9
commit 8218a21b03
1 changed files with 122 additions and 123 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
cim_for_mina/ichat-server/src/main/java/com/farsunset/ichat/api/action/MessageAction.java
View File

@ -1,4 +1,3 @@
package com.farsunset.ichat.api.action; package com.farsunset.ichat.api.action;
import java.util.HashMap; import java.util.HashMap;
@ -29,10 +28,10 @@ public class MessageAction extends ActionSupport implements ModelDriven<Messa
Message message = new Message(); Message message = new Message();
/** /**
* 关于http参数获取， struts2 的模型驱动 比如 http 参数 sender=xiaomao&receiver=xiaogou * 关于http参数获取， struts2 的模型驱动 比如 http 参数 sender=xiaomao&receiver=xiaogou
* struts自动会将参数的值 存入getModel()返回的对象的对应属性中，即xiaomao会存入message.sender属性,xiaogou会存入message.receiver属性 * struts自动会将参数的值 存入getModel()返回的对象的对应属性中，即xiaomao会存入message.sender属性,xiaogou会存入message.receiver属性
* 省去了request.getParameter("sender")方式获取参数，，如果参数名在getModel()返回的对象中不存在，则需要用request.getParameter()获取 * 省去了request.getParameter("sender")方式获取参数，，如果参数名在getModel()返回的对象中不存在，则需要用request.getParameter()获取
* 其他相关*Action.java中 同理，这里做统一说明! * 其他相关*Action.java中 同理，这里做统一说明!
*/ */
public String send() throws Exception { public String send() throws Exception {
@ -47,12 +46,12 @@ public class MessageAction extends ActionSupport implements ModelDriven<Messa
if(Constants.MessageType.TYPE_2.equals(message.getType())) if(Constants.MessageType.TYPE_2.equals(message.getType()))
{ {
//向客户端 发送消息 //向客户端 发送消息
ContextHolder.getBean(SystemMessagePusher.class).pushMessageToUser(message); ContextHolder.getBean(SystemMessagePusher.class).pushMessageToUser(message);
}else }else
{ {
//向客户端 发送消息 //向客户端 发送消息
ContextHolder.getBean(DefaultMessagePusher.class).pushMessageToUser(message); ContextHolder.getBean("messagePusher").pushMessageToUser(message);
} }
data.put("id", message.getMid()); data.put("id", message.getMid());
@ -72,7 +71,7 @@ public class MessageAction extends ActionSupport implements ModelDriven<Messa
/** /**
* 文件由客户端发往阿里云 OSS 存储 * 文件由客户端发往阿里云 OSS 存储
* @param messageServiceImpl * @param messageServiceImpl
*/ */
/* private void fileHandler(Message mo, HttpServletRequest request) throws IOException /* private void fileHandler(Message mo, HttpServletRequest request) throws IOException
@ -87,7 +86,7 @@ public class MessageAction extends ActionSupport implements ModelDriven<Messa
String dir = dirMap.get(fileType); String dir = dirMap.get(fileType);
if(StringUtils.isEmpty(dir)) if(StringUtils.isEmpty(dir))
{ {
throw new IllegalArgumentException("fileType:" +fileType+" 未定义" ); throw new IllegalArgumentException("fileType:" +fileType+" 未定义" );
} }
String path = request.getSession().getServletContext().getRealPath(dir); String path = request.getSession().getServletContext().getRealPath(dir);
@ -107,7 +106,7 @@ public class MessageAction extends ActionSupport implements ModelDriven<Messa
if(StringUtils.isEmpty(message.getReceiver())) if(StringUtils.isEmpty(message.getReceiver()))
{ {
throw new IllegalArgumentException("receiver 不能为空!"); throw new IllegalArgumentException("receiver 不能为空!");
} }
} }