Android - 极光推送 即时通讯

极光推送 即时通讯

• 准备应用
• 集成极光推送sdk

准备应用

Demo 项目地址github

1. 打开极光官网 链接: 极光 到极光推送官方网站注册开发者帐号；

2. 登录进入管理控制台，创建应用程序，得到 Appkey（SDK 与服务器端通过 Appkey 互相识别）；

3. 在推送设置中给 Android
   设置包名、给 iOS 上传证书、启用 WinPhone，根据你的需求进行选择;

4. 集成sdk

集成极光推送sdk

Jcenter 自动集成步骤

使用 jcenter 自动集成的开发者，不需要在项目中添加 jar 和 so，
jcenter 会自动完成依赖；在 AndroidManifest.xml 中不需要添加任何JPush SDK 相关的配置，jcenter 会自动导入。添加依赖implementation 'cn.jiguang.sdk:jpush:3.8.5'  // 此处以JPush 3.8.5 版本为例。 推送implementation 'cn.jiguang.sdk:jmessage:2.9.2'  // 此处以JMessage 2.9.2 版本为例。  即时通讯implementation 'cn.jiguang.sdk:jcore:2.5.5'  // 此处以JCore 2.5.5 版本为例。

//在moudle的build.gradle
defaultConfig{ndk {//选择要添加的对应 cpu 类型的 .so 库。abiFilters 'armeabi', 'armeabi-v7a', 'arm64-v8a'// 还可以添加 'x86', 'x86_64', 'mips', 'mips64'}manifestPlaceholders = [JPUSH_PKGNAME : "com.demo.message",//包名JPUSH_APPKEY : "21d83f3cf12878c554ef54b6", //极光开发平台上注册的包名对应的appkey.JPUSH_CHANNEL : "developer-default", //暂时填写默认值即可.]}

	<uses-permission android:name="android.permission.INTERNET" /><uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" /><uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />

  <!-- Since JCore2.0.0 Required SDK核心功能 --><!-- 可配置android:process参数将Service放在其他进程中；android:enabled属性不能是false --><!-- 这个是自定义Service，要继承极光JCommonService，可以在更多手机平台上使得推送通道保持的更稳定 --><serviceandroid:name=".JPush.JPService"android:enabled="true"android:exported="false"android:process=":pushcore"><intent-filter><action android:name="cn.jiguang.user.service.action" /></intent-filter></service> <!-- Required since 3.0.7 --><!-- 新的 tag/alias 接口结果返回需要开发者配置一个自定的广播 --><!-- 3.3.0开始所有事件将通过该类回调 --><!-- 该广播需要继承 JPush 提供的 JPushMessageReceiver 类, 并如下新增一个 Intent-Filter --><receiverandroid:name=".JPush.JPReceiver"android:enabled="true"android:exported="false"><intent-filter><action android:name="cn.jpush.android.intent.RECEIVE_MESSAGE" /><category android:name="com.demo.message" /></intent-filter></receiver><serviceandroid:name="cn.jpush.android.service.PushService"android:process=":multiprocess"tools:node="replace"></service>

在Application中初始化sdk

		JPushInterface.setDebugMode(true);JPushInterface.init(this);//推送JMessageClient.init(context,true);//即时通讯

注册

/*** 注册* 参数说明* String username 用户名* String password 用户密码* RegisterOptionalUserInfo optionalUserInfo 注册时的用户其他信息* BasicCallback callback 结果回调*/public void register(final Context context, String username, String password, final JPCallBack.RegisterCallBack registerCallBack) {JMessageClient.register(username, password, new BasicCallback() {@Overridepublic void gotResult(int i, String s) {Log.i("TAG", "register：code：" + i + "  msg：" + s);if (i == 0) {registerCallBack.onResult(i, s);} else {checkCode(context, i);}}});}

登录

 /*** 登录* 参数说明* String username 用户名* String password 用户密码* BasicCallback callback 结果回调*/public void login(final Context context, String username, String password, final JPCallBack.RegisterCallBack registerCallBack) {JMessageClient.login(username, password, new BasicCallback() {@Overridepublic void gotResult(int i, String s) {Log.i("TAG", "register：code：" + i + "  msg：" + s);if (i == 0) {registerCallBack.onResult(i, s);} else {checkCode(context, i);}}});}

/*** 创建单聊会话* 参数说明* String username 会话对象的username.* String appkey 用户所属应用的appkey,如果填空则默认为本应用的appkey*/public void createConversation(String userName) {Conversation singleConversation = Conversation.createSingleConversation(userName, BaseContract.APP_KEY);mConversation = singleConversation;}

/*** 发送消息     使用默认的配置参数发送* 参数说明* Message message 消息对象*/public void sendMessage(Context context, String userName, String text, JPCallBack.SendCallBack sendCallBack) {Message message = JMessageClient.createSingleTextMessage(userName, BaseContract.APP_KEY, text);JMessageClient.sendMessage(message);checkSendResult(context, message, sendCallBack);}

 /*** 发送消息    附带控制参数的消息发送* 参数说明* Message message 消息对象*/public void sendMessage(String text, MessageSendingOptions options) {}

 /*** 校验消息发送结果监听** @param message* @param sendCallBack*/private void checkSendResult(final Context context, Message message, final JPCallBack.SendCallBack sendCallBack) {message.setOnSendCompleteCallback(new BasicCallback() {@Overridepublic void gotResult(int i, String s) {Log.i("TAG", "register：code：" + i + "  msg：" + s);if (i == 0) {sendCallBack.onResult(i, s);} else {checkCode(context, i);}}});}

 /*** 校验JMessage返回值** @param context* @param i*/private void checkCode(Context context, int i) {switch (i) {case 871102:ToastUtils.showToast(context, "请求失败，请检查网络");break;case 871103:case 871104:ToastUtils.showToast(context, "服务器内部错误");break;case 871105:ToastUtils.showToast(context, "请求的用户信息不存在");break;case 871201:ToastUtils.showToast(context, "响应超时");break;case 871303:ToastUtils.showToast(context, "用户名不合法");break;case 871304:ToastUtils.showToast(context, "密码不合法");break;case 871305:ToastUtils.showToast(context, "名称不合法");break;case 871308:ToastUtils.showToast(context, "SDK尚未初始化");break;case 871310:ToastUtils.showToast(context, "网络连接已断开，请检查网络");break;case 898001:ToastUtils.showToast(context, "用户已存在");break;case 801003:ToastUtils.showToast(context, "登录的用户名未注册，登录失败");break;case 801004:ToastUtils.showToast(context, "登录的用户密码错误，登录失败");break;case 801005:ToastUtils.showToast(context, "登录的用户设备有误，登录失败");break;case 801006:ToastUtils.showToast(context, "登录的用户被禁用，登录失败");break;case 872100:ToastUtils.showToast(context, "音视频引擎初始化失败，appkey为空");break;case 872101:ToastUtils.showToast(context, "音视频引擎由于一些问题初始化失败，详情请看日志");break;case 872102:ToastUtils.showToast(context, "音视频引擎初始化失败，由于网络异常造成");break;case 872103:ToastUtils.showToast(context, "音视频引擎初始化失败，由于服务器端返回内容错误造成");break;case 872104:ToastUtils.showToast(context, "音视频引擎初始化失败，由于服务器端内部错误造成");break;case 872105:ToastUtils.showToast(context, "音视频引擎初始化失败，由于需要的权限没有获取成功造成");break;case 872106:ToastUtils.showToast(context, "音视频引擎还未初始化");break;}}

消息处理

//用户在线期间收到的消息都会以MessageEvent的方式上抛public void onEvent(MessageEvent event) {Message msg = event.getMessage();checkMessage(msg);}//用户离线期间收到的消息会以OfflineMessageEvent的方式上抛，处理方式类似上面的//MessageEventpublic void onEvent(OfflineMessageEvent event) {List<Message> msgs = event.getOfflineMessageList();for (Message msg : msgs) {checkMessage(msg);}}

处理消息

//处理消息通知事件  需要注册绑定
JMessageClient.registerEventReceiver(context);//事件接收类的注册JMessageClient.unRegisterEventReceiver(context);//事件接收类的解绑

private void checkMessage(Message msg) {switch (msg.getContentType()) {case text://处理文字消息TextContent textContent = (TextContent) msg.getContent();final String message = textContent.getText();this.runOnUiThread(new Runnable() {@Overridepublic void run() {datas.add(new MessageBean(MessageBean.LEFT, message));adapter.setNewData(datas);adapter.reflush();}});//                adapter.notifyDataSetChanged();break;case image://处理图片消息ImageContent imageContent = (ImageContent) msg.getContent();imageContent.getLocalPath();//图片本地地址imageContent.getLocalThumbnailPath();//图片对应缩略图的本地地址break;case voice://处理语音消息VoiceContent voiceContent = (VoiceContent) msg.getContent();voiceContent.getLocalPath();//语音文件本地地址voiceContent.getDuration();//语音文件时长break;case custom://处理自定义消息CustomContent customContent = (CustomContent) msg.getContent();customContent.getNumberValue("custom_num"); //获取自定义的值customContent.getBooleanValue("custom_boolean");customContent.getStringValue("custom_string");break;case eventNotification://处理事件提醒消息EventNotificationContent eventNotificationContent = (EventNotificationContent) msg.getContent();switch (eventNotificationContent.getEventNotificationType()) {case group_member_added://群成员加群事件break;case group_member_removed://群成员被踢事件break;case group_member_exit://群成员退群事件break;case group_info_updated://since 2.2.1//群信息变更事件break;}break;case unknown:// 处理未知消息，未知消息的Content为PromptContent 默认提示文本为“当前版本不支持此类型消息，请更新sdk版本”，上层可选择不处理PromptContent promptContent = (PromptContent) msg.getContent();promptContent.getPromptType();//未知消息的type是unknown_msg_typepromptContent.getPromptText();//提示文本，“当前版本不支持此类型消息，请更新sdk版本”break;}}

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！