)request.getAttribute("sessionList");
%>
@@ -92,6 +92,7 @@
头像 |
账号 |
终端 |
+ 终端版本 |
应用版本 |
设备型号 |
在线时长 |
@@ -119,7 +120,10 @@
<%=ios.getChannel()%>
- <%=ios.getAppVersion()==null?"":ios.getAppVersion()%>
+ <%=ios.getSystemVersion()==null?"":ios.getSystemVersion()%>
+ |
+
+ <%=ios.getClientVersion()==null?"":ios.getClientVersion()%>
|
<%=ios.getDeviceModel()==null?"":ios.getDeviceModel()%>
@@ -128,7 +132,7 @@
<%=(System.currentTimeMillis()-ios.getBindTime())/1000 %>秒
|
- <%=ios.getTag("location")==null?"":ios.getTag("location") %>
+ <%=ios.getAttribute("location")==null?"":ios.getAttribute("location") %>
|
diff --git a/cim_for_netty/cim-server/WebRoot/console/webclient/CIMBridge.swf b/cim_for_netty/cim-server/WebRoot/console/webclient/CIMBridge.swf
index f54bac6..21c98cd 100644
Binary files a/cim_for_netty/cim-server/WebRoot/console/webclient/CIMBridge.swf and b/cim_for_netty/cim-server/WebRoot/console/webclient/CIMBridge.swf differ
diff --git a/cim_for_netty/cim-server/WebRoot/console/webclient/MessageDialog.jsp b/cim_for_netty/cim-server/WebRoot/console/webclient/MessageDialog.jsp
index c19bade..d465596 100644
--- a/cim_for_netty/cim-server/WebRoot/console/webclient/MessageDialog.jsp
+++ b/cim_for_netty/cim-server/WebRoot/console/webclient/MessageDialog.jsp
@@ -4,10 +4,9 @@
style="display: none; width: 500px; position: absolute;min-height: 600px;box-shadow: 0 0 10px -2px #0B203A;top:50px;left:50px;">
消息列表
-
-
+
请调用接口,或者在后台页面,推送一条消息到客户端
diff --git a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/admin/action/SessionAction.java b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/admin/action/SessionAction.java
index 88e3fa8..2e9419b 100644
--- a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/admin/action/SessionAction.java
+++ b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/admin/action/SessionAction.java
@@ -1,3 +1,9 @@
+/**
+ * probject:cim
+ * @version 2.0
+ *
+ * @author 3979434@qq.com
+ */
package com.farsunset.cim.admin.action;
@@ -6,15 +12,15 @@ import java.io.IOException;
import org.apache.struts2.ServletActionContext;
import com.farsunset.cim.push.SystemMessagePusher;
-import com.farsunset.cim.server.mutual.Message;
-import com.farsunset.cim.server.session.DefaultSessionManager;
+import com.farsunset.cim.sdk.server.model.Message;
+import com.farsunset.cim.sdk.server.session.DefaultSessionManager;
import com.farsunset.cim.util.ContextHolder;
import com.opensymphony.xwork2.ActionSupport;
public class SessionAction extends ActionSupport {
/**
*
- */
+ */
private static final long serialVersionUID = 1L;
@@ -23,7 +29,7 @@ public class SessionAction extends ActionSupport {
public String list()
{
- ServletActionContext.getRequest().setAttribute("sessionList", ((DefaultSessionManager) ContextHolder.getBean("defaultSessionManager")).getSessions());
+ ServletActionContext.getRequest().setAttribute("sessionList", ((DefaultSessionManager) ContextHolder.getBean("CIMSessionManager")).queryAll());
return "list";
}
@@ -37,7 +43,7 @@ public class SessionAction extends ActionSupport {
msg.setReceiver(account);
//向客户端 发送消息
- ContextHolder.getBean(SystemMessagePusher.class).pushMessageToUser(msg);
+ ContextHolder.getBean(SystemMessagePusher.class).push(msg);
}
}
diff --git a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/api/action/MessageAction.java b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/api/action/MessageAction.java
index fbd1daa..cae3ec3 100644
--- a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/api/action/MessageAction.java
+++ b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/api/action/MessageAction.java
@@ -1,16 +1,23 @@
+/**
+ * probject:cim
+ * @version 2.0
+ *
+ * @author 3979434@qq.com
+ */
package com.farsunset.cim.api.action;
import java.util.HashMap;
-import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang.StringUtils;
import org.apache.struts2.ServletActionContext;
import org.springframework.web.bind.ServletRequestBindingException;
import com.farsunset.cim.push.DefaultMessagePusher;
import com.farsunset.cim.push.SystemMessagePusher;
-import com.farsunset.cim.server.mutual.Message;
+import com.farsunset.cim.sdk.server.model.Message;
import com.farsunset.cim.util.Constants;
import com.farsunset.cim.util.ContextHolder;
+import com.farsunset.cim.util.StringUtil;
import com.google.gson.Gson;
import com.opensymphony.xwork2.ActionSupport;
import com.opensymphony.xwork2.ModelDriven;
@@ -43,15 +50,15 @@ public class MessageAction extends ActionSupport implements ModelDriven sessions =new HashMap();
-
-
- /**
- *
- */
public void addSession(String account,CIMSession session) {
@@ -33,7 +30,7 @@ public class ClusterSessionManager implements SessionManager{
}
- public CIMSession getSession(String account) {
+ public CIMSession get(String account) {
//这里查询数据库
/*CIMSession session = database.getSession(account);
@@ -43,39 +40,40 @@ public class ClusterSessionManager implements SessionManager{
}
-
- public Collection getSessions() {
+ @Override
+ public List queryAll() {
/*//这里查询数据库
return database.getSessions();*/
return null;
}
- public void removeSession(CIMSession session) {
-
-
- //database.removeSession(session.getAttribute(CIMConstant.SESSION_KEY));*/
- }
-
- public void removeSession(String account) {
+ @Override
+ public void remove(String account) {
//database.removeSession(account);*/
}
-
-
- public boolean containsCIMSession(CIMSession ios)
- {
- //return database.containsCIMSession(session.getAccount());
-
- return false;
- }
-
- public String getAccount(CIMSession ios)
- {
- return ios.getAccount();
- }
+
+ @Override
+ public void setState(String account, int state) {
+ // TODO Auto-generated method stub
+
+ }
+
+
+ @Override
+ public void update(CIMSession session) {
+
+ }
+
+
+ @Override
+ public void add(String account, CIMSession session) {
+ // TODO Auto-generated method stub
+
+ }
diff --git a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/Constants.java b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/Constants.java
index 6546848..024cdee 100644
--- a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/Constants.java
+++ b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/Constants.java
@@ -1,3 +1,9 @@
+/**
+ * probject:cim
+ * @version 2.0
+ *
+ * @author 3979434@qq.com
+ */
package com.farsunset.cim.util;
public interface Constants {
@@ -42,32 +48,9 @@ public interface Constants {
//用户之间的普通消息
public static final String TYPE_0 = "0";
- public static final String TYPE_1 = "1";
-
//系统向用户发送的普通消息
public static final String TYPE_2 = "2";
-
- //群里用户发送的 消息
- public static final String TYPE_3 = "3";
-
- //系统定制消息---好友验证请求
- String TYPE_100 = "100";
-
- //系统定制消息---同意好友请求
- String TYPE_101 = "101";
-
- //系统定制消息---进群请求
- String TYPE_102 = "102";
-
- //系统定制消息---同意进群请求
- String TYPE_103 = "103";
-
-
- //系统定制消息---好友下线消息
- String TYPE_900 = "900";
-
- //系统定制消息---好友上线消息
- String TYPE_901 = "901";
+
}
}
diff --git a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/ContextHolder.java b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/ContextHolder.java
index ecfd01b..8f0a79a 100644
--- a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/ContextHolder.java
+++ b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/ContextHolder.java
@@ -1,13 +1,14 @@
+/**
+ * probject:cim
+ * @version 2.0
+ *
+ * @author 3979434@qq.com
+ */
package com.farsunset.cim.util;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
-/**
- * spring 动态获取bean 实现
- * @author 3979434
- *
- */
public class ContextHolder implements ApplicationContextAware{
private static ApplicationContext context;
diff --git a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/MessageDispatcher.java b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/MessageDispatcher.java
index 9a9c380..e835856 100644
--- a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/MessageDispatcher.java
+++ b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/MessageDispatcher.java
@@ -1,4 +1,9 @@
-
+/**
+ * probject:cim
+ * @version 2.0
+ *
+ * @author 3979434@qq.com
+ */
package com.farsunset.cim.util;
import java.util.ArrayList;
import java.util.List;
@@ -17,7 +22,8 @@ import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
-import com.farsunset.cim.server.mutual.Message;
+import com.farsunset.cim.sdk.server.model.Message;
+
public class MessageDispatcher {
diff --git a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/StringUtil.java b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/StringUtil.java
index 82fb185..c429684 100644
--- a/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/StringUtil.java
+++ b/cim_for_netty/cim-server/src/main/java/com/farsunset/cim/util/StringUtil.java
@@ -2,6 +2,7 @@ package com.farsunset.cim.util;
import java.text.SimpleDateFormat;
import java.util.Date;
+import java.util.UUID;
public class StringUtil {
@@ -45,6 +46,11 @@ public class StringUtil {
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
return dateFormat.format(new Date());
}
+
+ public static String getUUID() {
+ // TODO Auto-generated method stub
+ return UUID.randomUUID().toString().replaceAll("-", "");
+ }
}
diff --git a/cim_for_netty/cim-server/src/main/resource/spring-cim.xml b/cim_for_netty/cim-server/src/main/resource/spring-cim.xml
index 7e428ed..6a6ea11 100644
--- a/cim_for_netty/cim-server/src/main/resource/spring-cim.xml
+++ b/cim_for_netty/cim-server/src/main/resource/spring-cim.xml
@@ -14,7 +14,7 @@
>
-
+
-
+
\ No newline at end of file
diff --git a/cim_for_netty/cim-server/src/main/resource/spring-push.xml b/cim_for_netty/cim-server/src/main/resource/spring-push.xml
index b7959fa..d4eab02 100644
--- a/cim_for_netty/cim-server/src/main/resource/spring-push.xml
+++ b/cim_for_netty/cim-server/src/main/resource/spring-push.xml
@@ -14,10 +14,10 @@
>
-
+
-
+
\ No newline at end of file
diff --git a/cim_for_netty/client-mchat-android/AndroidManifest.xml b/cim_for_netty/client-mchat-android/AndroidManifest.xml
index cd25be2..fafbada 100644
--- a/cim_for_netty/client-mchat-android/AndroidManifest.xml
+++ b/cim_for_netty/client-mchat-android/AndroidManifest.xml
@@ -1,8 +1,8 @@
+ android:versionCode="2"
+ android:versionName="2.0.0" >
@@ -10,10 +10,10 @@
-
+
+ android:minSdkVersion="10"
+ android:targetSdkVersion="19" />
-
-
+
+
+
-
+
+
-
+
-
diff --git a/cim_for_netty/client-mchat-android/libs/android-support-v4.jar b/cim_for_netty/client-mchat-android/libs/android-support-v4.jar
deleted file mode 100644
index d006198..0000000
Binary files a/cim_for_netty/client-mchat-android/libs/android-support-v4.jar and /dev/null differ
diff --git a/cim_for_netty/client-mchat-android/libs/cim-android-sdk-2.0.jar b/cim_for_netty/client-mchat-android/libs/cim-android-sdk-2.0.jar
deleted file mode 100644
index 9afecc0..0000000
Binary files a/cim_for_netty/client-mchat-android/libs/cim-android-sdk-2.0.jar and /dev/null differ
diff --git a/cim_for_netty/client-mchat-android/libs/cim-server-sdk-2.0.jar b/cim_for_netty/client-mchat-android/libs/cim-server-sdk-2.0.jar
new file mode 100644
index 0000000..48ecc64
Binary files /dev/null and b/cim_for_netty/client-mchat-android/libs/cim-server-sdk-2.0.jar differ
diff --git a/cim_for_netty/client-mchat-android/libs/fastjson-1.1.34.android.jar b/cim_for_netty/client-mchat-android/libs/fastjson-1.1.34.android.jar
deleted file mode 100644
index bf50c46..0000000
Binary files a/cim_for_netty/client-mchat-android/libs/fastjson-1.1.34.android.jar and /dev/null differ
diff --git a/cim_for_netty/client-mchat-android/libs/fastjson-1.1.47.android.jar b/cim_for_netty/client-mchat-android/libs/fastjson-1.1.47.android.jar
new file mode 100644
index 0000000..9062508
Binary files /dev/null and b/cim_for_netty/client-mchat-android/libs/fastjson-1.1.47.android.jar differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-buffer-4.1.0.CR7.jar b/cim_for_netty/client-mchat-android/libs/netty-buffer-4.1.0.CR7.jar
new file mode 100644
index 0000000..b850bdf
Binary files /dev/null and b/cim_for_netty/client-mchat-android/libs/netty-buffer-4.1.0.CR7.jar differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-buffer-5.0.0.Alpha2.jar b/cim_for_netty/client-mchat-android/libs/netty-buffer-5.0.0.Alpha2.jar
deleted file mode 100644
index 039947c..0000000
Binary files a/cim_for_netty/client-mchat-android/libs/netty-buffer-5.0.0.Alpha2.jar and /dev/null differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-codec-4.1.0.CR7.jar b/cim_for_netty/client-mchat-android/libs/netty-codec-4.1.0.CR7.jar
new file mode 100644
index 0000000..d0092b7
Binary files /dev/null and b/cim_for_netty/client-mchat-android/libs/netty-codec-4.1.0.CR7.jar differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-codec-5.0.0.Alpha2.jar b/cim_for_netty/client-mchat-android/libs/netty-codec-5.0.0.Alpha2.jar
deleted file mode 100644
index f51892d..0000000
Binary files a/cim_for_netty/client-mchat-android/libs/netty-codec-5.0.0.Alpha2.jar and /dev/null differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-common-4.1.0.CR7.jar b/cim_for_netty/client-mchat-android/libs/netty-common-4.1.0.CR7.jar
new file mode 100644
index 0000000..606e920
Binary files /dev/null and b/cim_for_netty/client-mchat-android/libs/netty-common-4.1.0.CR7.jar differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-common-5.0.0.Alpha2.jar b/cim_for_netty/client-mchat-android/libs/netty-common-5.0.0.Alpha2.jar
deleted file mode 100644
index 894e7bb..0000000
Binary files a/cim_for_netty/client-mchat-android/libs/netty-common-5.0.0.Alpha2.jar and /dev/null differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-handler-4.1.0.CR7.jar b/cim_for_netty/client-mchat-android/libs/netty-handler-4.1.0.CR7.jar
new file mode 100644
index 0000000..066c370
Binary files /dev/null and b/cim_for_netty/client-mchat-android/libs/netty-handler-4.1.0.CR7.jar differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-resolver-4.1.0.CR7.jar b/cim_for_netty/client-mchat-android/libs/netty-resolver-4.1.0.CR7.jar
new file mode 100644
index 0000000..7c90d37
Binary files /dev/null and b/cim_for_netty/client-mchat-android/libs/netty-resolver-4.1.0.CR7.jar differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-resolver-5.0.0.Alpha2.jar b/cim_for_netty/client-mchat-android/libs/netty-resolver-5.0.0.Alpha2.jar
deleted file mode 100644
index 113143f..0000000
Binary files a/cim_for_netty/client-mchat-android/libs/netty-resolver-5.0.0.Alpha2.jar and /dev/null differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-transport-4.1.0.CR7.jar b/cim_for_netty/client-mchat-android/libs/netty-transport-4.1.0.CR7.jar
new file mode 100644
index 0000000..7dafa07
Binary files /dev/null and b/cim_for_netty/client-mchat-android/libs/netty-transport-4.1.0.CR7.jar differ
diff --git a/cim_for_netty/client-mchat-android/libs/netty-transport-5.0.0.Alpha2.jar b/cim_for_netty/client-mchat-android/libs/netty-transport-5.0.0.Alpha2.jar
deleted file mode 100644
index 299b3cc..0000000
Binary files a/cim_for_netty/client-mchat-android/libs/netty-transport-5.0.0.Alpha2.jar and /dev/null differ
diff --git a/cim_for_netty/client-mchat-android/libs/slf4j-api-1.7.5.jar b/cim_for_netty/client-mchat-android/libs/slf4j-api-1.7.5.jar
deleted file mode 100644
index 8766455..0000000
Binary files a/cim_for_netty/client-mchat-android/libs/slf4j-api-1.7.5.jar and /dev/null differ
diff --git a/cim_for_netty/client-mchat-android/libs/slf4j-nop-1.7.5.jar b/cim_for_netty/client-mchat-android/libs/slf4j-nop-1.7.5.jar
deleted file mode 100644
index e55bdd8..0000000
Binary files a/cim_for_netty/client-mchat-android/libs/slf4j-nop-1.7.5.jar and /dev/null differ
diff --git a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/adapter/MessageTimeDescComparator.java b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/adapter/MessageTimeDescComparator.java
index ac1fc61..a60ef9a 100644
--- a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/adapter/MessageTimeDescComparator.java
+++ b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/adapter/MessageTimeDescComparator.java
@@ -1,8 +1,14 @@
+/**
+ * probject:cim
+ * @version 2.0
+ *
+ * @author 3979434@qq.com
+ */
package com.farsunset.ichat.example.adapter;
import java.util.Comparator;
-import com.farsunset.cim.client.model.Message;
+import com.farsunset.cim.sdk.android.model.Message;
public class MessageTimeDescComparator implements Comparator{
diff --git a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/adapter/SystemMsgListViewAdapter.java b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/adapter/SystemMsgListViewAdapter.java
index 2dd2872..266b324 100644
--- a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/adapter/SystemMsgListViewAdapter.java
+++ b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/adapter/SystemMsgListViewAdapter.java
@@ -1,17 +1,22 @@
+/**
+ * probject:cim
+ * @version 2.0
+ *
+ * @author 3979434@qq.com
+ */
package com.farsunset.ichat.example.adapter;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
-
+import android.annotation.SuppressLint;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.widget.BaseAdapter;
import android.widget.ImageView;
import android.widget.TextView;
-
-import com.farsunset.cim.client.model.Message;
+import com.farsunset.cim.sdk.android.model.Message;
import com.farsunset.ichat.example.R;
import com.farsunset.ichat.example.ui.SystemMessageActivity;
@@ -48,12 +53,12 @@ public class SystemMsgListViewAdapter extends BaseAdapter {
{
//Collections.sort(list, new MessageTimeDescComparator());
}
+ @SuppressLint("ViewHolder")
@Override
public View getView(int position, View chatItemView, ViewGroup parent) {
final Message msg = getItem(position);
-
chatItemView =LayoutInflater.from(scactivity).inflate(R.layout.item_chat_sysmsg, null);
diff --git a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/CIMMonitorActivity.java b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/CIMMonitorActivity.java
index 8eee807..560da3a 100644
--- a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/CIMMonitorActivity.java
+++ b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/CIMMonitorActivity.java
@@ -1,26 +1,33 @@
+/**
+ * probject:cim
+ * @version 2.0
+ *
+ * @author 3979434@qq.com
+ */
package com.farsunset.ichat.example.app;
+import com.farsunset.cim.sdk.android.CIMEventListener;
+import com.farsunset.cim.sdk.android.CIMListenerManager;
+import com.farsunset.cim.sdk.android.model.Message;
+import com.farsunset.cim.sdk.android.model.ReplyBody;
import android.app.Activity;
-import android.app.ProgressDialog;
import android.net.NetworkInfo;
import android.os.Bundle;
-import android.widget.Toast;
-import com.farsunset.cim.client.android.CIMEventListener;
-import com.farsunset.cim.client.android.CIMListenerManager;
-import com.farsunset.cim.client.model.Message;
-import com.farsunset.cim.client.model.ReplyBody;
-
-public abstract class CIMMonitorActivity extends Activity implements CIMEventListener{
+public abstract class CIMMonitorActivity extends Activity implements CIMEventListener{
- private ProgressDialog progressDialog;
+ CommonBaseControl commonBaseControl;
public void onCreate(Bundle savedInstanceState)
{
super.onCreate(savedInstanceState);
CIMListenerManager.registerMessageListener(this,this);
+
+ commonBaseControl = new CommonBaseControl(this);
+
+
}
@Override
@@ -37,59 +44,47 @@ public abstract class CIMMonitorActivity extends Activity implements CIMEventL
}
- public void showProgressDialog(String title,String message)
+ public void showProgressDialog(String title,String content)
{
- if(progressDialog==null)
- {
-
- progressDialog = ProgressDialog.show(this, title, message, true, true);
- }else if(progressDialog.isShowing())
- {
- progressDialog.setTitle(title);
- progressDialog.setMessage(message);
- }
-
- progressDialog.show();
-
+ commonBaseControl.showProgressDialog(title, content);
}
public void hideProgressDialog()
{
-
- if(progressDialog!=null&&progressDialog.isShowing())
- {
- progressDialog.dismiss();
- }
-
+ commonBaseControl.hideProgressDialog();
}
public void showToask(String hint){
- Toast toast=Toast.makeText(this,hint,Toast.LENGTH_SHORT);
- toast.show();
+ commonBaseControl.showToask(hint);
}
-
- /**
- * 与服务端断开连接时回调,不要再里面做连接服务端的操作
- */
- @Override
- public void onCIMConnectionClosed(){};
- /**
- * 与服务端断开连接时成功时回调
- */
+
+
@Override
- public void onCIMConnectionSucceed() {}
- @Override
- public void onConnectionStatus(boolean isConnected){}
-
- @Override
- public void onReplyReceived(ReplyBody reply) {}
-
- @Override
- public void onMessageReceived(Message arg0) {}
+ public void onMessageReceived(Message arg0){};
@Override
- public void onNetworkChanged(NetworkInfo info){};
+ public void onNetworkChanged(NetworkInfo info){}
+
+ /**
+ * 与服务端断开连接时回调,不要在里面做连接服务端的操作
+ */
+ @Override
+ public void onConnectionClosed() {}
+
+
+ /**
+ * 连接服务端成功时回调
+ */
+
+ @Override
+ public void onConnectionSuccessed(boolean arg0) {}
+
+
+ @Override
+ public void onReplyReceived(ReplyBody arg0) {}
+ @Override
+ public void onConnectionFailed(Exception e){};
}
diff --git a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/CommonBaseControl.java b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/CommonBaseControl.java
new file mode 100644
index 0000000..038bcfd
--- /dev/null
+++ b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/CommonBaseControl.java
@@ -0,0 +1,63 @@
+/**
+ * probject:cim
+ * @version 2.0
+ *
+ * @author 3979434@qq.com
+ */
+package com.farsunset.ichat.example.app;
+
+
+
+import android.app.ProgressDialog;
+import android.content.Context;
+import android.widget.Toast;
+
+
+public class CommonBaseControl {
+
+ private ProgressDialog progressDialog;
+
+ Context mContent;
+
+
+ public CommonBaseControl(Context content)
+ {
+ this.mContent = content;
+ }
+
+
+
+ public void showProgressDialog(String title,String message)
+ {
+ if(progressDialog==null)
+ {
+
+ progressDialog = ProgressDialog.show(mContent, title, message, true, true);
+ }else if(progressDialog.isShowing())
+ {
+ progressDialog.setTitle(title);
+ progressDialog.setMessage(message);
+ }
+
+ progressDialog.show();
+
+ }
+
+ public void hideProgressDialog()
+ {
+
+ if(progressDialog!=null&&progressDialog.isShowing())
+ {
+ progressDialog.dismiss();
+ }
+
+ }
+
+ public void showToask(String hint){
+
+ Toast toast=Toast.makeText(mContent,hint,Toast.LENGTH_SHORT);
+ toast.show();
+ }
+
+
+}
diff --git a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/Constant.java b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/Constant.java
index 4d372be..bd6d5b9 100644
--- a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/Constant.java
+++ b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/app/Constant.java
@@ -1,18 +1,15 @@
-package com.farsunset.ichat.example.app;
-
-
-
-
-
-
/**
+ * probject:cim
+ * @version 2.0
*
- * @version 1.0
- */
+ * @author 3979434@qq.com
+ */
+package com.farsunset.ichat.example.app;
+
public interface Constant {
- //服务端IP地址
- public static final String CIM_SERVER_HOST = "192.168.2.3";
+ //服务端IP地址
+ public static final String CIM_SERVER_HOST = "192.168.2.3";
//服务端web地址
public static final String SERVER_URL = "http://"+CIM_SERVER_HOST+":8080/cim-server";
diff --git a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/network/HttpAPIRequester.java b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/network/HttpAPIRequester.java
index 25513a8..5ddad4d 100644
--- a/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/network/HttpAPIRequester.java
+++ b/cim_for_netty/client-mchat-android/src/com/farsunset/ichat/example/network/HttpAPIRequester.java
@@ -1,10 +1,13 @@
-
+/**
+ * probject:cim
+ * @version 2.0
+ *
+ * @author 3979434@qq.com
+ */
package com.farsunset.ichat.example.network;
import java.io.File;
-import java.lang.reflect.Type;
import java.nio.charset.Charset;
import java.util.HashMap;
-import java.util.List;
import java.util.Map;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
@@ -20,18 +23,13 @@ import org.apache.http.entity.mime.content.StringBody;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.params.CoreConnectionPNames;
import org.apache.http.util.EntityUtils;
-
import android.os.Handler;
import android.os.Message;
-
import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
public class HttpAPIRequester {
HttpAPIResponser responser;
- Type dataType;
- Type dataListType;
private static BlockingQueue queue = new LinkedBlockingQueue();
private static ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 5, 20, TimeUnit.SECONDS,queue);;
@@ -72,41 +70,20 @@ public class HttpAPIRequester {
* @exception
* @since 1.0.0
*/
- public void execute( Type dtype , Type dltype, final String url)
+ public void execute( final String url)
{
- this.dataType = dtype;
- this.dataListType = dltype;
responser.onRequest();
executor.execute(new Runnable() {
@Override
public void run() {
Message message = handler.obtainMessage();
- HashMap data = new HashMap();
+ message.getData().putString("url", url);
try {
String dataString = httpPost(url,responser.getRequestParams());
- JSONObject json = JSON.parseObject(dataString);
- data.put("code", json.getString("code"));
- data.put("url", url);
- if(json.containsKey("data") && dataType!=null)
- {
- dataString = json.getJSONObject("data").toJSONString();
- data.put("data", JSON.parseObject(dataString, dataType));
- }
- if(json.containsKey("dataList") &&dataListType!=null )
- {
- dataString = json.getJSONArray("dataList").toJSONString();
- data.put("list", JSON.parseObject(dataString, dataListType));
- }
-
- if(json.containsKey("page") &&json.getJSONObject("page")!=null)
- {
- dataString = json.getJSONObject("page").toJSONString();
- data.put("page", JSON.parseObject(dataString, Page.class));
- }
- message.getData().putSerializable("data", data);
+ message.getData().putString("data", dataString);
message.what = 0;
} catch (Exception e) {
e.printStackTrace();
@@ -157,18 +134,16 @@ public class HttpAPIRequester {
Handler handler = new Handler(){
public void handleMessage(Message message)
{
- switch(message.what)
+ String url = message.getData().getString("url");
+ switch(message.what)
{
case 0:
- HashMap data =(HashMap) message.getData().getSerializable("data");
- Page page = (Page) data.get("page");
- List |