AllJoyn+Android开发案例-android跨设备调用方法

大家好，又见面了，我是你们的朋友全栈君。

AllJoyn+Android开发案例-android跨设备调用方法

项目需要涉及AllJoyn开源物联网框架。前面主要了解了一些AllJoyn基本的概念，像总线，总线附件，总线对象，总线接口这样的概念，以及之间的关系和跨设备、平台的调用功能。项目最终的目的实现是，跨平台的方法调用如：windows调用android，以及对于设备事件的订阅功能。

入手的步骤：

1.实现android端的跨设备方法（自定义）调用案例-java

2.实现windows端的跨设备方法（自定义）调用案例-c++

3.实现windows端和android端的跨设备方法调用案例-（window用C++，android用java）

4.结合实际项目实现跨平台、跨设备的方法调用和订阅功能

现阶段我们来尝试实现android端的跨设备方法（自定义）调用案例-java

上面一篇关于博客–AllJoyn+Android开发的一般步骤，主要概念上描述了如何实现调用，这篇文章我们结合android代码实现，走一遍流程，加深理解和记忆。参考地址http://blog.csdn.net/jsjdtb356/article/details/51084886。

官网参考地址（很重要）：https://allseenalliance.org/framework/documentation/develop/api-guide/core/java

开源代码（core API+很多实例-android studio可运行）：https://allseenalliance.org/framework/download

step1：

新建android studio project，选择file/project structrue 设置好java sdk，android sdk，android ndk的路径。

step2：

添加两个库文件，一个是alljoyn.jar库文件，一个是liballjoyn_java.so库文件，下载地址是https://allseenalliance.org/framework/download。版本我下载的是15.04，如下图。

我的.jar的绝对路径：G:\alljoyn\alljoyn-android\core\alljoyn-15.04.00b-rel\java\jar\alljoyn.jar

我的.so的绝对路径：G:\alljoyn\alljoyn-android\core\alljoyn-15.04.00b-rel\java\lib\liballjoyn_java.so

大家根据自己的解压位置去找就好了。

添加到工程后如下图所示：

project视图下，添加的路径和文件夹名称，没有文件夹则建立对应名称的文件夹。然后将jar添加作库。

step3：

实现流程
大致画一个示意图：

server代码实现：一个activity用于交互，button开启一个service；service中具体实现alljoyn代码；一个总线接口，总线对象要实现的接口；service上代码如下。

package com.example.siemens.testgetmethod;

import android.app.Service;
import android.content.Intent;
import android.net.wifi.WifiConfiguration;
import android.os.Handler;
import android.os.HandlerThread;
import android.os.IBinder;
import android.os.Looper;
import android.os.Message;
import android.util.Log;
import android.widget.Toast;

import org.alljoyn.bus.BusAttachment;
import org.alljoyn.bus.BusObject;
import org.alljoyn.bus.Mutable;
import org.alljoyn.bus.SessionOpts;
import org.alljoyn.bus.SessionPortListener;
import org.alljoyn.bus.Status;

import javax.net.ssl.SSLEngineResult;

public class MyService extends Service {

    private final String TAG="MyService";

    public MyService() {
//        super();
    }

    @Override
    public IBinder onBind(Intent intent) {
        // TODO: Return the communication channel to the service.
//        throw new UnsupportedOperationException("Not yet implemented");
        return null;
    }

    public int onStartCommand(Intent intent, int flags, int startId) {
//        Log.i(TAG, "onStartCommand()");
        return START_STICKY;
    }

    public void onDestroy() {
//        backgroundHandler.exit();
    }

    public void onCreate(){
        Log.i(TAG,"onCreate method.");
        //mbus初始化
        mBus=new BusAttachment(getPackageName(),BusAttachment.RemoteMessage.Receive);
        startBusThread();
        if(backgroundHandler!=null)
            backgroundHandler.connect();
        else
            return;
    }

    private void startBusThread(){
        HandlerThread handlerThread=new HandlerThread("My HandlerThread");
        handlerThread.start();
        Looper loop=handlerThread.getLooper();
        backgroundHandler=new BackgroundHandler(loop);
        Log.i(TAG,"startBusThread method.");
    }

    //请求都在线程中执行
    private BackgroundHandler backgroundHandler=null;
    private final int CONNECT=2;

    //私有内部不可变类
    private final class BackgroundHandler extends Handler{
        public BackgroundHandler(Looper looper){
            super(looper);
        }

        public void connect(){
            Log.i(TAG,"backgroundHandler.connect()");
            Message msg=backgroundHandler.obtainMessage(CONNECT);//相当于message.what=2;
            backgroundHandler.sendMessage(msg);
        }

        public void handleMessage(Message msg){
            switch(msg.what){
                case CONNECT:
                    doConnect();
                    break;
                default:
                    break;
            }
        }
    }

    //创建总线附件对象,getPackageName()出现NullPointerException异常,先于构造函数执行，此时对象为null，所以放到oncreate里边去
//    private BusAttachment mBus=new BusAttachment(getPackageName(),BusAttachment.RemoteMessage.Receive);
    private BusAttachment mBus=null;
    //创建总线对象
    private MyBusObject myBusObject=new MyBusObject();
    //总线对象类，实现总线接口和总线对象接口
    class MyBusObject implements MyInterface,BusObject{
//        public void show(String args){
//            Toast.makeText(getApplicationContext(),args,Toast.LENGTH_SHORT).show();     //会调用的远程方法
//
//        }
//
//        public int add(int a,int b){                        //会调用的远程方法
//            return a+b;
//        }
        public String cat(String a,String b){
            a=a.replace('H','T');
            b=b.replace('W','B');
            return a+b;
        }
    }

    //session的端口号
    private static final short CONTACT_PORT=42;
    //总线对象，总线附件等连接到总线上的实现函数，创建的是service
    private void doConnect(){
        org.alljoyn.bus.alljoyn.DaemonInit.PrepareDaemon(getApplicationContext());  //启动守护进程

        Status status=mBus.registerBusObject(myBusObject,"/myBusObject");                     //注册总线对象
        if (Status.OK != status) {
            System.out.println("BusAttachment.registerBusObject() failed: " + status);
            System.exit(0);
            return;
        }

        //总线附件连接到总线上
        status=mBus.connect();
        if (status != Status.OK) {
            Log.i(TAG,"BusAttachment connect to bus failed.");
            System.exit(0);
            return;
        }

        //通信的session port 设置
        Mutable.ShortValue contactPort = new Mutable.ShortValue(CONTACT_PORT);
        SessionOpts sessionOpts = new SessionOpts();
        sessionOpts.traffic = SessionOpts.TRAFFIC_MESSAGES;
        sessionOpts.isMultipoint = false;
        sessionOpts.proximity = SessionOpts.PROXIMITY_ANY;
        sessionOpts.transports = SessionOpts.TRANSPORT_ANY;

        //绑定通信的session port
        status=mBus.bindSessionPort(contactPort,sessionOpts,new SessionPortListener(){
            @Override
            public boolean acceptSessionJoiner(short sessionPort, String joiner, SessionOpts sessionOpts){
                if (sessionPort == CONTACT_PORT) {
                    return true;
                } else {
                    return false;
                }
            }
        });
        if (status != Status.OK) {
            Log.i(TAG,"bind certain session port failed.");
            System.exit(0);
            return;
        }

        //向总线请求一个名称
        int flags = 0; //do not use any request name flags
        status = mBus.requestName("com.test.well.known.name", flags);
        if (status != Status.OK) {
            Log.i(TAG,"request name from bus failed.");
            System.exit(0);
            return;
        }

        //在总线上宣告name的存在
        status = mBus.advertiseName("com.test.well.known.name", SessionOpts.TRANSPORT_ANY);
        if (status != Status.OK) {
            Log.i(TAG,"advertise name on bus failed.");
            mBus.releaseName("com.test.well.know.name");
            System.exit(0);
            return;
        }else
            Toast.makeText(getApplicationContext(),"advertise name=com.test.well.known.name",Toast.LENGTH_SHORT).show();

    }

    static{
        System.loadLibrary("alljoyn_java");
    }
}

注意：静态初始化块中的loadlibrary不能少掉。上面的例子参照的是chat源码。

接口代码：

package com.example.siemens.testgetmethod;

import org.alljoyn.bus.BusException;
import org.alljoyn.bus.annotation.BusInterface;
import org.alljoyn.bus.annotation.BusMethod;

/**
 * Created by Siemens on 2016/4/8.
 */
@BusInterface (name = "org.my.interface.name")
public interface MyInterface {
//    @BusMethod
//    void show(String test) throws BusException;
//    @BusMethod
//    int add(int a,int b) throws BusException;
    @BusMethod
    String cat(String a,String b) throws BusException;
}

注意：格式必须按照这种格式来，上面接口的name属性后面的值很重要client要对应。

client代码如下：

package com.example.siemens.testgetmethodclient;

import android.app.Service;
import android.content.Intent;
import android.os.IBinder;
import android.util.Log;
import android.widget.Toast;

import org.alljoyn.bus.BusAttachment;
import org.alljoyn.bus.BusListener;
import org.alljoyn.bus.Mutable;
import org.alljoyn.bus.ProxyBusObject;
import org.alljoyn.bus.SessionListener;
import org.alljoyn.bus.SessionOpts;
import org.alljoyn.bus.Status;

public class MyService extends Service {

    private final String TAG="MyClientService";
    public MyService() {
    }

    @Override
    public IBinder onBind(Intent intent) {
        // TODO: Return the communication channel to the service.
//        throw new UnsupportedOperationException("Not yet implemented");
        return null;
    }

    private BusAttachment mBus=null;
    private static final short CONTACT_PORT=42;

    //代理总线对象；接口对象
    private ProxyBusObject mProxyObj;
    public MyInterface mInterface;
//    public MyInterface getmInterface(){
//        return mInterface;
//    }

    //application对象
    private ClientApplication mApplication;

    @Override
    public void onCreate(){
        mApplication=(ClientApplication)getApplication();

        //守护进程不能忘
        org.alljoyn.bus.alljoyn.DaemonInit.PrepareDaemon(getApplicationContext());  //启动守护进程

        mBus=new BusAttachment(getApplication().getPackageName(),BusAttachment.RemoteMessage.Receive);

        //连接两次？
//        Status status=mBus.connect();
//        if (Status.OK != status) {
//            Log.i(TAG,"client busattachment first connect to bus failed.");
//            System.exit(0);
//            return;
//        }

        mBus.registerBusListener(new BusListener(){
            @Override
            public void foundAdvertisedName(String name, short transport,String namePrefix){
                mBus.enableConcurrentCallbacks();
                short contactPort = CONTACT_PORT;
                SessionOpts sessionOpts = new SessionOpts();
                sessionOpts.traffic = SessionOpts.TRAFFIC_MESSAGES;
                sessionOpts.isMultipoint = false;
                sessionOpts.proximity = SessionOpts.PROXIMITY_ANY;
                sessionOpts.transports = SessionOpts.TRANSPORT_ANY;

                Mutable.IntegerValue sessionId = new Mutable.IntegerValue();

                Status status = mBus.joinSession(name,contactPort,sessionId,sessionOpts,new SessionListener());

                mProxyObj = mBus.getProxyBusObject("com.test.well.known.name", "/myBusObject", sessionId.value, new Class[]{MyInterface.class});
                mInterface=mProxyObj.getInterface(MyInterface.class);

                //personal add
                mApplication.setTestInterface(mInterface);
            }
        });


        //连接两次？？官网API问题？？？
        Status status=mBus.connect();
        if (Status.OK != status) {
            Log.i(TAG,"client busattachment second connect to bus failed.");
            System.exit(0);
            return;
        }

        //找到指定名称的busAttachment
        status = mBus.findAdvertisedName("com.test.well.known.name");
        if (status != Status.OK) {
            Log.i(TAG,"client findAdvertisedName failed.");
            System.exit(0);
            return;
        }
        else
            Toast.makeText(getApplicationContext(),"find name=com.test.well.known.name success.",Toast.LENGTH_SHORT).show();

    }

    static{
        System.loadLibrary("alljoyn_java");
    }
}

同时client端app也需要知道总线接口，但是要通过代理对象获得方法的具体实现，也要包含接口类，同server接口类。

总结：有4个client和server需要统一的地方。1.advertise的那个name，客户端是根据这个名称找server。2.接口类，server和client都要知道，server提供实现，client不知道具体实现。3.session设置的端口号，client的session port要和server统一。4.client要知道，server上总线对象在总线附件上注册的路径。