极光推送 即时通讯
准备应用
Demo 项目地址github
1.打开极光官网 链接: 极光 到极光推送官方网站注册开发者帐号
2.登录进入管理控制台，创建应用程序，得到 Appkey（SDK 与服务器端通过 Appkey 互相识别）
3.在推送设置中给 Android设置包名、给 iOS 上传证书、启用 WinPhone，根据你的需求进行选择
4.集成sdk
集成极光推送sdk
Jcenter 自动集成步骤
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 版本为例。
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.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，可以在更多手机平台上使得推送通道保持的更稳定 -->
<service
android: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 -->
<receiver
android: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>
<service
android: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() {
@Override
public 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() {
@Override
public 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() {
@Override
public 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的方式上抛，处理方式类似上面的
//MessageEvent
public 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() {
@Override
public 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_type
promptContent.getPromptText();//提示文本，“当前版本不支持此类型消息，请更新sdk版本”
break;
}
}
原文链接："https://blog.csdn.net/weixin_45680654/article/details/110926700"
网友评论