1.开始着手一个一对一的信息发送

// 记录是否已经初始化 private boolean isInit = false; @Override public void onCreate() { super.onCreate(); initFresco(); initEasemob(); } private void initFresco() { Fresco.initialize(this, FrescoConfig.getsImagePipelineConfig(this)); } private void initEasemob() { // 获取当前进程 id 并取得进程名 int pid = android.os.Process.myPid(); String processAppName = getAppName(pid); /** * 如果app启用了远程的service，此application:onCreate会被调用2次 * 为了防止环信SDK被初始化2次，加此判断会保证SDK被初始化1次 * 默认的app会在以包名为默认的process name下运行，如果查到的process name不是app的process name就立即返回 */ if (processAppName == null || !processAppName.equalsIgnoreCase(this.getPackageName())) { // 则此application的onCreate 是被service 调用的，直接返回 return; } if (isInit) { return; } /** * SDK初始化的一些配置 * 关于 EMOptions 可以参考官方的 API 文档 * http://www.easemob.com/apidoc/android/chat3.0/classcom_1_1hyphenate_1_1chat_1_1_e_m_options.html */ EMOptions options = new EMOptions(); // 设置Appkey，如果配置文件已经配置，这里可以不用设置 // options.setAppKey("lzan13#hxsdkdemo"); // 设置自动登录 options.setAutoLogin(true); // 设置是否需要发送已读回执 options.setRequireAck(true); // 设置是否需要发送回执，TODO 这个暂时有bug，上层收不到发送回执 options.setRequireDeliveryAck(true); // 设置是否需要服务器收到消息确认 options.setRequireDeliveryAck(true); // 收到好友申请是否自动同意，如果是自动同意就不会收到好友请求的回调，因为sdk会自动处理，默认为true options.setAcceptInvitationAlways(false); // 设置是否自动接收加群邀请，如果设置了当收到群邀请会自动同意加入 options.setAutoAcceptGroupInvitation(false); // 设置（主动或被动）退出群组时，是否删除群聊聊天记录 options.setDeleteMessagesAsExitGroup(false); // 设置是否允许聊天室的Owner 离开并删除聊天室的会话 options.allowChatroomOwnerLeave(true); // 调用初始化方法初始化sdk EMClient.getInstance().init(this, options); // 设置开启debug模式 EMClient.getInstance().setDebugMode(true); // 设置初始化已经完成 isInit = true; } /** * 根据Pid获取当前进程的名字，一般就是当前app的包名 * * @param pid 进程的id * @return 返回进程的名字 */ private String getAppName(int pid) { String processName = null; ActivityManager activityManager = (ActivityManager) this.getSystemService(Context.ACTIVITY_SERVICE); List list = activityManager.getRunningAppProcesses(); Iterator i = list.iterator(); while (i.hasNext()) { ActivityManager.RunningAppProcessInfo info = (ActivityManager.RunningAppProcessInfo) (i.next()); try { if (info.pid == pid) { // 根据进程的信息获取当前进程的名字 processName = info.processName; // 返回当前进程名 return processName; } } catch (Exception e) { e.printStackTrace(); } } // 没有匹配的项，返回为null return null; }

2.看一下聊天页面(我没有用easeUI，太大了。。。)

import android.app.Activity; import android.content.Context; import android.content.Intent; import com.fanyafeng.wechat.util.StringUtil; import com.hyphenate.EMMessageListener; import com.hyphenate.chat.EMClient; import com.hyphenate.chat.EMConversation; import com.hyphenate.chat.EMImageMessageBody; import com.hyphenate.chat.EMMessage; import com.hyphenate.chat.EMTextMessageBody; import java.util.ArrayList; import java.util.List; /** * Author： fanyafeng * Data： 17/2/21 上午11:29 * Email: fanyafeng@live.cn */ public class ChatPresenter implements ChatContract.Presenter, EMMessageListener { private Context context; private ChatContract.View chatView; private Intent intent; private EMMessageListener emMessageListener; private List< ChatBean> chatBeanList = new ArrayList<>(); public ChatPresenter(Context context, ChatContract.View chatView) { this.context = context; this.chatView = chatView; } @Override public void start() { emMessageListener = this; EMClient.getInstance().chatManager().addMessageListener(emMessageListener); intent = chatView.initIntent(); EMConversation emConversation = EMClient.getInstance().chatManager().getConversation(intent.getStringExtra("from")); if (emConversation != null) { List< EMMessage> emMessageList = emConversation.getAllMessages(); for (EMMessage emMessage : emMessageList) { ChatBean chatBean = new ChatBean(); if (emMessage.getBody() instanceof EMTextMessageBody) { chatBean.setTextMessage(((EMTextMessageBody) emMessage.getBody()).getMessage()); } else if (emMessage.getBody() instanceof EMImageMessageBody) { chatBean.setTextMessage("[图片]"); } chatBean.setType(EMClient.getInstance().getCurrentUser().equals(emMessage.getFrom()) ? 1 : 0); chatBeanList.add(chatBean); } } chatView.initRecycleView(chatBeanList); if (chatBeanList.size() > 0) { chatView.scrollToPosition(chatBeanList.size() - 1); } } @Override public void onMessageReceived(List< EMMessage> list) { for (EMMessage emMessage : list) { ChatBean chatBean = new ChatBean(); if (emMessage.getBody() instanceof EMTextMessageBody) { chatBean.setTextMessage(((EMTextMessageBody) emMessage.getBody()).getMessage()); } if (intent.getStringExtra("from").equals(emMessage.getFrom())) { chatBeanList.add(chatBean); } } ((Activity) context).runOnUiThread(new Runnable() { @Override public void run() { chatView.notifyChanged(); chatView.scrollToPosition(chatBeanList.size() - 1); } }); } @Override public void onCmdMessageReceived(List< EMMessage> list) { } @Override public void onMessageRead(List< EMMessage> list) { } @Override public void onMessageDelivered(List< EMMessage> list) { } @Override public void onMessageChanged(EMMessage emMessage, Object o) { } @Override public void removeMessageListener() { EMClient.getInstance().chatManager().removeMessageListener(emMessageListener); } @Override public void sendMessage() { if (!StringUtil.isNullOrEmpty(chatView.getMessage())) { EMMessage emMessage = EMMessage.createTxtSendMessage(chatView.getMessage(), chatView.initIntent().getStringExtra("from")); EMClient.getInstance().chatManager().sendMessage(emMessage); ChatBean chatBean = new ChatBean(); chatBean.setTextMessage(chatView.getMessage()); chatBean.setType(1); chatBeanList.add(chatBean); chatView.notifyChanged(); chatView.scrollToPosition(chatBeanList.size() - 1); chatView.clearInput(); } else { //消息为空 } } }

3.看一下运行效果，我这里是用的两个账号测试的（一个动图，一个非动图）