推送sdk （类似百度 推送 ） android mina (待优化... )
16lz
2021-01-23
推送sdk （类似百度 推送 ） android mina (待优化... )
本demo 研究的是原理，不要计较太多。。。。 至于token生成，service 保活，定时启动 不做说明。
下载：http://download.csdn.net/download/knight_black_bob/9823413
双开模拟器 进行验证。。。。
package cn.baoyou.curiousby.com.imsdk.service;import android.app.Service;import android.content.Intent;import android.os.Binder;import android.os.IBinder;import android.support.annotation.Nullable;import android.util.Log;import com.alibaba.fastjson.JSON;import org.apache.mina.core.session.IoSession;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.TimeUnit;import cn.baoyou.curiousby.com.imsdk.core.ClientSocket;import cn.baoyou.curiousby.com.imsdk.core.ServerSocket;import cn.baoyou.curiousby.com.imsdk.core.callback.IRecieveCallBack;import cn.baoyou.curiousby.com.imsdk.message.Message;import cn.baoyou.curiousby.com.imsdk.session.SessionManager;/** * Created by cmcc-B100036 on 2017/4/18. */public class MinaService extends Service{ public static boolean send(Message msg){ Log.i("baoy","--------------------"); if (SessionManager.getInstance().isConnectable()){ try { Log.i("baoy","write start" + msg.toString()); SessionManager.getInstance().write(msg); Log.i("baoy","write end"); return true; } catch (Exception e) { return false; } } return false; } private IRecieveCallBack iRecieveCallBack = new IRecieveCallBack() { @Override public void recieve(Message msg) { Log.i("baoy","recievie msg ==== service " + msg.toString()); Intent intent=new Intent(); intent.setAction("cn.baoyou.curiousby.com.imsdk.msgrecieve"); intent.putExtra("recieveMsg", JSON.toJSONString( msg)); intent.putExtra("recieveMsgBytes",JSON.toJSONString( msg).getBytes()); sendBroadcast(intent); } }; public final class MinaBinder extends Binder { public MinaService getService() { return MinaService.this; } } @Nullable @Override public IBinder onBind(Intent intent) { return null; } ClientSocket instance = null; ServerSocket instancee = null; @Override public void onCreate() { super.onCreate(); ExecutorService service = Executors.newFixedThreadPool(2); service.execute(new Runnable() { @Override public void run() { instance = ClientSocket.getInstance(); instance.setiRecieveCallBack(iRecieveCallBack); instance.init(); IoSession ioSession = null; try { instance.start(); }catch (Exception e) { } } }); service.execute(new Runnable() { @Override public void run() { instancee = ServerSocket.getInstance(); instancee.init(); IoSession ioSession = null; try { instancee.start(); }catch (Exception e) { } } }); service.shutdown(); } @Override public void onDestroy() { super.onDestroy(); instance.stop(); } @Override public boolean onUnbind(Intent intent) { return super.onUnbind(intent); } @Override public void onRebind(Intent intent) { super.onRebind(intent); }} package cn.baoyou.curiousby.com.imsdk.broadcastreceiver;import android.content.BroadcastReceiver;import android.content.Context;import android.content.Intent;import android.provider.SyncStateContract;import android.util.Log;import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map;import cn.baoyou.curiousby.com.imsdk.constants.Constants;import cn.baoyou.curiousby.com.imsdk.message.Message;import cn.baoyou.curiousby.com.imsdk.message.MessageFactory;import cn.baoyou.curiousby.com.imsdk.operater.IMOriginalCallBack;/** * Created by cmcc-B100036 on 2017/4/19. */public class MsgReciever extends BroadcastReceiver { private IMOriginalCallBack iMOriginalCallBack; private static Map<Class,IMOriginalCallBack> map = new HashMap<>(); public MsgReciever setRecieve(Class clazz ,IMOriginalCallBack iMOriginalCallBack) { this.iMOriginalCallBack = iMOriginalCallBack; MsgReciever.map.put(clazz,iMOriginalCallBack); return this; } @Override public void onReceive(Context context, Intent intent) { if(Constants.ACTION .equals(intent.getAction())){ String recieveMsg = intent.getStringExtra("recieveMsg"); Log.i("baoy","=========msgrecieve==================="+recieveMsg); Message msg = MessageFactory.build(recieveMsg); for ( Map.Entry<Class,IMOriginalCallBack> entry : map.entrySet()) { Log.i("baoy","=========msgrecieve callback==================="+msg); Log.i("baoy","=========msgrecieve callback==================="+entry.getKey()); Log.i("baoy","=========msgrecieve callback==================="+entry.getValue()); ((IMOriginalCallBack) entry.getValue()).recieve(msg); } } }} package cn.baoyou.curiousby.com.imsdk.core;import android.util.Log;import org.apache.mina.core.service.IoHandlerAdapter;import org.apache.mina.core.session.IdleStatus;import org.apache.mina.core.session.IoSession;import cn.baoyou.curiousby.com.imsdk.core.callback.IRecieveCallBack;import cn.baoyou.curiousby.com.imsdk.core.callback.IReconnect;import cn.baoyou.curiousby.com.imsdk.message.ConnectionMessage;import cn.baoyou.curiousby.com.imsdk.message.Message;import cn.baoyou.curiousby.com.imsdk.message.MessageFactory;import cn.baoyou.curiousby.com.imsdk.message.ShortMessage;import cn.baoyou.curiousby.com.imsdk.message.enums.MessageTag;import cn.baoyou.curiousby.com.imsdk.session.SessionManager;public class ClientHandler extends IoHandlerAdapter { // private static Logger log = Logger.getLogger(ClientHandler.class); private IRecieveCallBack iRecieveCallBack; private IReconnect iReconnect; volatile static boolean isConnected = false; public ClientHandler(IReconnect iReconnect,IRecieveCallBack iRecieveCallBack) { this.iRecieveCallBack = iRecieveCallBack; this.iReconnect = iReconnect; } @Override public void sessionOpened(IoSession session) throws Exception { Log.i("baoy","session created opened"); super.sessionOpened(session); } @Override public void sessionCreated(IoSession session) throws Exception { Log.i("baoy","session created start"); super.sessionCreated(session); Log.i("baoy","session created end"); isConnected = true; buildConnection(session); } @Override public void sessionClosed(IoSession session) throws Exception { Log.i("baoy","session created closed"); super.sessionClosed(session); isConnected = false; } @Override public void messageSent(IoSession session, Object message) throws Exception { Log.i("baoy","session created sent"); super.messageSent(session, message); } @Override public void exceptionCaught(IoSession session, Throwable cause) throws Exception { Log.i("baoy","session created caught"); super.exceptionCaught(session, cause); isConnected = false; } @Override public void sessionIdle(IoSession session, IdleStatus status) throws Exception { Log.i("baoy","session created idle"); super.sessionIdle(session, status); } @Override public void messageReceived(IoSession session, Object json) throws Exception { super.messageReceived(session, json); Log.i("baoy","recievie msg 00 === (" + json.toString() +")MessageFactory.isChecked(json.toString()"+MessageFactory.isChecked(json.toString()) ); if(MessageFactory.isChecked(json.toString()).equals( MessageTag.msg)) { Log.i("baoy","recievie msg 01 === " ); Message build = MessageFactory.build(json.toString()); if (iRecieveCallBack != null) { Log.i("baoy", "recievie msg 1 ===" + json.toString()); iRecieveCallBack.recieve(build); Log.i("baoy", "recievie msg 2 ===" + json.toString()); } } } public void buildConnection(IoSession session){ if(session.isConnected()) { ConnectionMessage msg = new ConnectionMessage(); msg.setUserKey("2"); msg.setJson("connect"); session.write(com.alibaba.fastjson.JSON.toJSONString(msg)); } }} package cn.baoyou.curiousby.com.imsdk.core;import android.util.Log;import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;import org.apache.mina.core.filterchain.IoFilter;import org.apache.mina.core.future.ConnectFuture;import org.apache.mina.core.service.IoConnector;import org.apache.mina.core.session.IoSession;import org.apache.mina.filter.codec.ProtocolCodecFilter;import org.apache.mina.filter.codec.textline.TextLineCodecFactory;import org.apache.mina.filter.logging.LoggingFilter;import org.apache.mina.transport.socket.nio.NioSocketConnector;import java.net.InetSocketAddress;import java.nio.charset.Charset;import cn.baoyou.curiousby.com.imsdk.codec.CodecFactory;import cn.baoyou.curiousby.com.imsdk.constants.Constants;import cn.baoyou.curiousby.com.imsdk.core.callback.IRecieveCallBack;import cn.baoyou.curiousby.com.imsdk.core.callback.IReconnect;import cn.baoyou.curiousby.com.imsdk.message.ConnectionMessage;import cn.baoyou.curiousby.com.imsdk.service.MinaService;public class ClientSocket implements IReconnect{IoConnector connector=null;private ClientSocket(){}private static ClientSocket instance = new ClientSocket();public static ClientSocket getInstance(){return instance;}private static IRecieveCallBack iRecieveCallBack;public static void setiRecieveCallBack(IRecieveCallBack iRecieveCallBack) {ClientSocket.iRecieveCallBack = iRecieveCallBack;}public void init(){ connector = new NioSocketConnector(); ClientHandler handler = new ClientHandler(this,iRecieveCallBack);connector.setHandler(handler);IoFilter filter = new ProtocolCodecFilter(new CodecFactory());connector.getFilterChain().addLast("codec", filter);connector.getFilterChain().addLast("logging", new LoggingFilter());}public boolean start(){ConnectFuture connect = connector.connect(new InetSocketAddress(Constants.CLIENT_SOCKET_ADDRESS,Constants.CLIENT_SOCKET_PORT));connect.awaitUninterruptibly();return true;}public void stop(){if(connector != null){connector.dispose();}}@Overridepublic void reconnection() {while(true) {if (!ClientHandler.isConnected) { start();}try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}}}} package cn.baoyou.curiousby.com.imorginal;import android.content.DialogInterface;import android.content.Intent;import android.support.v7.app.AppCompatActivity;import android.os.Bundle;import android.util.Log;import android.view.View;import android.widget.EditText;import android.widget.TextView;import cn.baoyou.curiousby.com.imsdk.broadcastreceiver.MsgReciever;import cn.baoyou.curiousby.com.imsdk.message.Message;import cn.baoyou.curiousby.com.imsdk.message.ShortMessage;import cn.baoyou.curiousby.com.imsdk.operater.IMOriginalCallBack;import cn.baoyou.curiousby.com.imsdk.service.MinaService;public class MainActivity extends AppCompatActivity implements View.OnClickListener ,IMOriginalCallBack{ private EditText sendText; private TextView recieveText; private MsgReciever reciever = new MsgReciever().setRecieve(MainActivity.class , this); @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); Intent intent = new Intent(getApplicationContext(), MinaService.class); this.startService(intent); this.findViewById(R.id.bt_send_button).setOnClickListener(this); recieveText = (TextView) this.findViewById(R.id.id_recieveMsg); sendText = (EditText) this.findViewById(R.id.id_sendmsg); } @Override public void onClick(View v) { switch (v.getId()){ case R.id.bt_send_button: Log.i("baoy","=========================send"+sendText.getText().toString()); ShortMessage shortMessage = new ShortMessage(); shortMessage.setUserKey("2"); shortMessage.setForm("2"); shortMessage.setTo("1"); shortMessage.setJson(sendText.getText().toString()); blackboard += ""+((ShortMessage)shortMessage ).getForm()+"对" +((ShortMessage)shortMessage ).getTo() +" 说:"+shortMessage.getJson() +"\n"; recieveText.setText(blackboard); MinaService.send(shortMessage); Log.i("baoy","========================"); break; } } static String blackboard = ""; @Override public void recieve(Message msg) { Log.i("baoy","=====main activity callback===================" + msg); blackboard += ""+((ShortMessage)msg ).getForm()+"对" +((ShortMessage)msg ).getTo() +" 说:"+msg.getJson() +"\n"; recieveText.setText(blackboard); }} 捐助开发者
在兴趣的驱动下,写一个免费的东西，有欣喜，也还有汗水，希望你喜欢我的作品，同时也能支持一下。 当然，有钱捧个钱场（支持支付宝和微信 以及扣扣群），没钱捧个人场，谢谢各位。
个人主页：http://knight-black-bob.iteye.com/
谢谢您的赞助，我会做的更好！
更多相关文章
- android模拟器SD卡使用
- Android: 模拟器system分区没有可用空间的问题
- Android 4.0 开发者指南(28) —— Resource Types - More Types
- 在Android2.2模拟器上安装Android Market
- 手动部署Android-apk应用到模拟器
- android模拟器无法启动 找不到设备
- Android Studio 连接夜神模拟器
- Android 模拟器中AVD路径的修改
- android模拟器发送短信和打电话