Alljoyn 框架 - Java - 信号。 BUS_NO_SUCH_INTERFACE
Alljoyn framework - Java - Signals . BUS_NO_SUCH_INTERFACE
这是一个非常具体的问题,但是在同一个地方停留了几天并且在 Alljoyn 论坛上没有得到任何回应之后,我决定在这里 post 解决这个问题。也许有人使用过这个框架。
我正在做一个项目,我需要使用Alljoyn框架提供的信号机制。但是,我确实需要会话内的信号,并且 api 核心中提供的示例是无会话的。
在我的例子中,我需要服务(服务器)发出信号,客户端接收它,但我收到了这个错误。按照 api 示例,我设法创建了一个简单的应用程序,它通过接口中定义的方法交换消息,因此我知道通信正常。在这种情况下,服务会一直等到客户端连接并发送信号。客户端在注册信号后立即加入会话,我收到 BUS_NO_SUCH_INTERFACE 错误。我也尝试在发送信号之后和之前注册,同样的问题。我认为由于某种原因,客户端没有找到 bussignalhandler,但我不知道为什么。我也把它放在外部 class 中,但没有用。
我正在遵循核心 api 指南中的示例:
https://allseenalliance.org/developers/develop/api-guide/core/android
这是服务注册并发出信号的部分:
SignalEmitter emitter = new SignalEmitter(mySignalInterface, joinerName,
sessionId,
SignalEmitter.GlobalBroadcast.Off);
myInterface = emitter.getInterface(SampleInterface.class);
// Emitting signals myInterface.buttonClicked(1);
myInterface.playerPosition(12, 1, -24);
但是,在该示例中,我看不到 myInterface
的定义。我知道这不是一个错误,他们的意思是 mySignalInterface
,因为方法 getInterface
要求一个接口对象,而 mySignalInterface
是一个实现该接口的 class。
我把我创建的例子放在这里,我会上传文件以防有人想尝试。
@BusInterface(name = "org.alljoyn.bus.samples.simple.SimpleInterface")
public interface SimpleInterface {
@BusMethod
String Ping(String inStr) throws BusException;
@BusSignal
public void playerPosition(int x, int y, int z) throws BusException;
}
服务:
Class 在服务内部实现信号和方法
class SimpleService implements SimpleInterface, BusObject {
public String Ping(String inStr) {
mHandler.sendMessage(mHandler.obtainMessage(MESSAGE_PING, inStr));
return inStr;
}
public void playerPosition(int x, int y, int z) { /* no implementation needed here*/}
}
这里是在服务中建立连接的部分代码:
case CONNECT: {
org.alljoyn.bus.alljoyn.DaemonInit.PrepareDaemon(getApplicationContext());
mBus = new BusAttachment(getPackageName(), BusAttachment.RemoteMessage.Receive);
mBus.registerBusListener(new BusListener());
Status status = mBus.registerBusObject(mSimpleService, "/SimpleService");
if (status != Status.OK) {...}
status = mBus.connect();
logStatus("BusAttachment.connect()", status);
if (status != Status.OK) {...}
int flag = 0;
status = mBus.requestName(SERVICE_NAME, flag);
logStatus(String.format("BusAttachment.requestName(%s, 0x%08x)", SERVICE_NAME, flag), status);
if (status == Status.OK) {
status = mBus.advertiseName(SERVICE_NAME, SessionOpts.TRANSPORT_ANY);
logStatus(String.format("BusAttachement.advertiseName(%s)", SERVICE_NAME), status);
if (status != Status.OK) {...}
}
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 + SessionOpts.TRANSPORT_WFD;
status = mBus.bindSessionPort(contactPort, sessionOpts, new SessionPortListener() {
@Override
public boolean acceptSessionJoiner(short sessionPort, String joiner, SessionOpts sessionOpts) {
return sessionPort == CONTACT_PORT;
}
@Override
public void sessionJoined(short port, int id, String s) {
sessionId = id; joinerName = s; sessionEstablished = true;
}
});
logStatus(String.format("BusAttachment.bindSessionPort(%d, %s)",
contactPort.value, sessionOpts.toString()), status);
if (status != Status.OK) {...}
try {
while (!sessionEstablished) {
Thread.sleep(10);
}
SignalEmitter emitter = new SignalEmitter(mSimpleService, joinerName, sessionId, SignalEmitter.GlobalBroadcast.Off);
SimpleInterface myInterface = emitter.getInterface(SimpleInterface.class);
myInterface.playerPosition(12,1,1);
}
catch (BusException ex) {... }
}
客户:
/*On create of the activity which has a button and a text view to send text to the server */
mEditText.setOnEditorActionListener(new TextView.OnEditorActionListener() {
public boolean onEditorAction(TextView view, int actionId, KeyEvent event) {
if (actionId == EditorInfo.IME_NULL
&& event.getAction() == KeyEvent.ACTION_UP) {
/* Call the remote object's Ping method. */
Message msg = mBusHandler.obtainMessage(BusHandler.PING,
view.getText().toString());
mBusHandler.sendMessage(msg);
}
return true;
}
});
private static final String SERVICE_NAME = "org.alljoyn.bus.samples.simple";
private static final short CONTACT_PORT=42;
private BusAttachment mBus;
private ProxyBusObject mProxyObj;
private SimpleInterface mSimpleInterface;
case CONNECT: {
org.alljoyn.bus.alljoyn.DaemonInit.PrepareDaemon(getApplicationContext());
mBus = new BusAttachment(getPackageName(), BusAttachment.RemoteMessage.Receive);
mBus.registerBusListener(new BusListener() {
@Override
public void foundAdvertisedName(String name, short transport, String namePrefix) {
if(!mIsConnected) {
Message msg = obtainMessage(JOIN_SESSION);
msg.arg1 = transport;
msg.obj = name;
sendMessage(msg);
}
}
});
Status status = mBus.connect();
logStatus("BusAttachment.connect()", status);
if (Status.OK != status) {...}
status = mBus.findAdvertisedName(SERVICE_NAME);
logStatus(String.format("BusAttachement.findAdvertisedName(%s)", SERVICE_NAME), status);
if (Status.OK != status) {...}
break;
}
case (JOIN_SESSION): {
if (mIsStoppingDiscovery) {
break;
}
short contactPort = CONTACT_PORT;
SessionOpts sessionOpts = new SessionOpts();
sessionOpts.transports = (short)msg.arg1;
Mutable.IntegerValue sessionId = new Mutable.IntegerValue();
Status status = mBus.joinSession((String) msg.obj, contactPort, sessionId, sessionOpts, new SessionListener() {
@Override
public void sessionLost(int sessionId, int reason) {
mIsConnected = false;
logInfo(String.format("MyBusListener.sessionLost(sessionId = %d, reason = %d)", sessionId,reason));
mHandler.sendEmptyMessage(MESSAGE_START_PROGRESS_DIALOG);
}
});
if (status == Status.OK) {
mProxyObj = mBus.getProxyBusObject(SERVICE_NAME,
"/SimpleService",
sessionId.value,
new Class<?>[] { SimpleInterface.class });
mSimpleInterface = mProxyObj.getInterface(SimpleInterface.class);
mSessionId = sessionId.value;
mIsConnected = true;
mHandler.sendEmptyMessage(MESSAGE_STOP_PROGRESS_DIALOG);
}
break;
status = mBus.registerSignalHandlers(this);
if (status != Status.OK) {...}
}
case PING: {
try {
if (mSimpleInterface != null) {
sendUiMessage(MESSAGE_PING, msg.obj);
String reply = mSimpleInterface.Ping((String) msg.obj);
sendUiMessage(MESSAGE_PING_REPLY, reply);
} catch {...}
}
...here some more code...
@BusSignalHandler(iface="org.alljoyn.bus.samples.simple.SimpleInterface", signal="playerPosition")
public void playerPosition(int x, int y, int z) {
sendUiMessage(MESSAGE_POST_TOAST, "Signal captured");
}
在这个例子中,我的客户端有一个文本视图,我可以在其中添加文本并向服务器发送 ping。如果我摆脱注册信号部分,这将起作用。我尝试按照 api 核心所说的那样,使用 Thread.sleep 但也不起作用。
在这里,我根据 alljoyn api 中的示例添加了我的两个应用程序(客户端和服务器)的代码。
https://github.com/JavierT/Alljoyn_signal_sample
如果您有任何疑问,请告诉我,很难将所有信息集中在一起post。
提前谢谢你。
当您调用 registerSignalHandlers
时,您必须传递一个实现接口 SimpleInterface
的对象,并且当您收到信号时,将在该对象中调用方法 playerPosition
。
我相信(我很快阅读了代码,希望我没有错)你传递了你的 BusHandler
对象,它没有实现 SimpleInterface
.
请更改:
private static final String SERVICE_NAME = "org.alljoyn.bus.samples.simple";
到
"org.alljoyn.bus.samples.simple.SimpleInterface
" 因为你有接口名称,
两者应该相同。因为调用 BusObject 的 Get 方法时接口名称不匹配。
我认为这应该可以解决您的问题
可以使用以下任一方法来注释信号处理程序:
@BusSignalHandler(iface = "org.sample.MyInterface", signal = "MySignal")
public void handleSignal(String str)
{
}
@BusSignalHandler(iface = "org.myapp.IMyInterface", signal = "EmitMySignal")
public void handleSignal(String str)
{
}
当 IMyInterface
通过之前调用 BusAttachment.registerBusObject(BusObject, String)
或 BusAttachment.getProxyBusObject(String, String, int, Class[])
.
为 BusAttachment
所知时,可以成功使用第一个示例
当 IMyInterface
对 BusAttachment
未知时,可以成功使用第二个示例。
使用第二个示例应该可以解决您的问题。
此外,根据上面提供的 link,在您的客户端程序中,
@BusSignalHandler(iface="org.alljoyn.bus.samples.simple.SimpleInterface", signal="playerPosition")
应替换为
@BusSignalHandler(iface="org.alljoyn.bus.samples.simpleclient.SimpleInterface", signal="playerPosition")
这是一个非常具体的问题,但是在同一个地方停留了几天并且在 Alljoyn 论坛上没有得到任何回应之后,我决定在这里 post 解决这个问题。也许有人使用过这个框架。
我正在做一个项目,我需要使用Alljoyn框架提供的信号机制。但是,我确实需要会话内的信号,并且 api 核心中提供的示例是无会话的。
在我的例子中,我需要服务(服务器)发出信号,客户端接收它,但我收到了这个错误。按照 api 示例,我设法创建了一个简单的应用程序,它通过接口中定义的方法交换消息,因此我知道通信正常。在这种情况下,服务会一直等到客户端连接并发送信号。客户端在注册信号后立即加入会话,我收到 BUS_NO_SUCH_INTERFACE 错误。我也尝试在发送信号之后和之前注册,同样的问题。我认为由于某种原因,客户端没有找到 bussignalhandler,但我不知道为什么。我也把它放在外部 class 中,但没有用。
我正在遵循核心 api 指南中的示例: https://allseenalliance.org/developers/develop/api-guide/core/android
这是服务注册并发出信号的部分:
SignalEmitter emitter = new SignalEmitter(mySignalInterface, joinerName,
sessionId,
SignalEmitter.GlobalBroadcast.Off);
myInterface = emitter.getInterface(SampleInterface.class);
// Emitting signals myInterface.buttonClicked(1);
myInterface.playerPosition(12, 1, -24);
但是,在该示例中,我看不到 myInterface
的定义。我知道这不是一个错误,他们的意思是 mySignalInterface
,因为方法 getInterface
要求一个接口对象,而 mySignalInterface
是一个实现该接口的 class。
我把我创建的例子放在这里,我会上传文件以防有人想尝试。
@BusInterface(name = "org.alljoyn.bus.samples.simple.SimpleInterface")
public interface SimpleInterface {
@BusMethod
String Ping(String inStr) throws BusException;
@BusSignal
public void playerPosition(int x, int y, int z) throws BusException;
}
服务:
Class 在服务内部实现信号和方法
class SimpleService implements SimpleInterface, BusObject {
public String Ping(String inStr) {
mHandler.sendMessage(mHandler.obtainMessage(MESSAGE_PING, inStr));
return inStr;
}
public void playerPosition(int x, int y, int z) { /* no implementation needed here*/}
}
这里是在服务中建立连接的部分代码:
case CONNECT: {
org.alljoyn.bus.alljoyn.DaemonInit.PrepareDaemon(getApplicationContext());
mBus = new BusAttachment(getPackageName(), BusAttachment.RemoteMessage.Receive);
mBus.registerBusListener(new BusListener());
Status status = mBus.registerBusObject(mSimpleService, "/SimpleService");
if (status != Status.OK) {...}
status = mBus.connect();
logStatus("BusAttachment.connect()", status);
if (status != Status.OK) {...}
int flag = 0;
status = mBus.requestName(SERVICE_NAME, flag);
logStatus(String.format("BusAttachment.requestName(%s, 0x%08x)", SERVICE_NAME, flag), status);
if (status == Status.OK) {
status = mBus.advertiseName(SERVICE_NAME, SessionOpts.TRANSPORT_ANY);
logStatus(String.format("BusAttachement.advertiseName(%s)", SERVICE_NAME), status);
if (status != Status.OK) {...}
}
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 + SessionOpts.TRANSPORT_WFD;
status = mBus.bindSessionPort(contactPort, sessionOpts, new SessionPortListener() {
@Override
public boolean acceptSessionJoiner(short sessionPort, String joiner, SessionOpts sessionOpts) {
return sessionPort == CONTACT_PORT;
}
@Override
public void sessionJoined(short port, int id, String s) {
sessionId = id; joinerName = s; sessionEstablished = true;
}
});
logStatus(String.format("BusAttachment.bindSessionPort(%d, %s)",
contactPort.value, sessionOpts.toString()), status);
if (status != Status.OK) {...}
try {
while (!sessionEstablished) {
Thread.sleep(10);
}
SignalEmitter emitter = new SignalEmitter(mSimpleService, joinerName, sessionId, SignalEmitter.GlobalBroadcast.Off);
SimpleInterface myInterface = emitter.getInterface(SimpleInterface.class);
myInterface.playerPosition(12,1,1);
}
catch (BusException ex) {... }
}
客户:
/*On create of the activity which has a button and a text view to send text to the server */
mEditText.setOnEditorActionListener(new TextView.OnEditorActionListener() {
public boolean onEditorAction(TextView view, int actionId, KeyEvent event) {
if (actionId == EditorInfo.IME_NULL
&& event.getAction() == KeyEvent.ACTION_UP) {
/* Call the remote object's Ping method. */
Message msg = mBusHandler.obtainMessage(BusHandler.PING,
view.getText().toString());
mBusHandler.sendMessage(msg);
}
return true;
}
});
private static final String SERVICE_NAME = "org.alljoyn.bus.samples.simple";
private static final short CONTACT_PORT=42;
private BusAttachment mBus;
private ProxyBusObject mProxyObj;
private SimpleInterface mSimpleInterface;
case CONNECT: {
org.alljoyn.bus.alljoyn.DaemonInit.PrepareDaemon(getApplicationContext());
mBus = new BusAttachment(getPackageName(), BusAttachment.RemoteMessage.Receive);
mBus.registerBusListener(new BusListener() {
@Override
public void foundAdvertisedName(String name, short transport, String namePrefix) {
if(!mIsConnected) {
Message msg = obtainMessage(JOIN_SESSION);
msg.arg1 = transport;
msg.obj = name;
sendMessage(msg);
}
}
});
Status status = mBus.connect();
logStatus("BusAttachment.connect()", status);
if (Status.OK != status) {...}
status = mBus.findAdvertisedName(SERVICE_NAME);
logStatus(String.format("BusAttachement.findAdvertisedName(%s)", SERVICE_NAME), status);
if (Status.OK != status) {...}
break;
}
case (JOIN_SESSION): {
if (mIsStoppingDiscovery) {
break;
}
short contactPort = CONTACT_PORT;
SessionOpts sessionOpts = new SessionOpts();
sessionOpts.transports = (short)msg.arg1;
Mutable.IntegerValue sessionId = new Mutable.IntegerValue();
Status status = mBus.joinSession((String) msg.obj, contactPort, sessionId, sessionOpts, new SessionListener() {
@Override
public void sessionLost(int sessionId, int reason) {
mIsConnected = false;
logInfo(String.format("MyBusListener.sessionLost(sessionId = %d, reason = %d)", sessionId,reason));
mHandler.sendEmptyMessage(MESSAGE_START_PROGRESS_DIALOG);
}
});
if (status == Status.OK) {
mProxyObj = mBus.getProxyBusObject(SERVICE_NAME,
"/SimpleService",
sessionId.value,
new Class<?>[] { SimpleInterface.class });
mSimpleInterface = mProxyObj.getInterface(SimpleInterface.class);
mSessionId = sessionId.value;
mIsConnected = true;
mHandler.sendEmptyMessage(MESSAGE_STOP_PROGRESS_DIALOG);
}
break;
status = mBus.registerSignalHandlers(this);
if (status != Status.OK) {...}
}
case PING: {
try {
if (mSimpleInterface != null) {
sendUiMessage(MESSAGE_PING, msg.obj);
String reply = mSimpleInterface.Ping((String) msg.obj);
sendUiMessage(MESSAGE_PING_REPLY, reply);
} catch {...}
}
...here some more code...
@BusSignalHandler(iface="org.alljoyn.bus.samples.simple.SimpleInterface", signal="playerPosition")
public void playerPosition(int x, int y, int z) {
sendUiMessage(MESSAGE_POST_TOAST, "Signal captured");
}
在这个例子中,我的客户端有一个文本视图,我可以在其中添加文本并向服务器发送 ping。如果我摆脱注册信号部分,这将起作用。我尝试按照 api 核心所说的那样,使用 Thread.sleep 但也不起作用。
在这里,我根据 alljoyn api 中的示例添加了我的两个应用程序(客户端和服务器)的代码。 https://github.com/JavierT/Alljoyn_signal_sample
如果您有任何疑问,请告诉我,很难将所有信息集中在一起post。 提前谢谢你。
当您调用 registerSignalHandlers
时,您必须传递一个实现接口 SimpleInterface
的对象,并且当您收到信号时,将在该对象中调用方法 playerPosition
。
我相信(我很快阅读了代码,希望我没有错)你传递了你的 BusHandler
对象,它没有实现 SimpleInterface
.
请更改:
private static final String SERVICE_NAME = "org.alljoyn.bus.samples.simple";
到
"org.alljoyn.bus.samples.simple.SimpleInterface
" 因为你有接口名称,
两者应该相同。因为调用 BusObject 的 Get 方法时接口名称不匹配。
我认为这应该可以解决您的问题
可以使用以下任一方法来注释信号处理程序:
@BusSignalHandler(iface = "org.sample.MyInterface", signal = "MySignal")
public void handleSignal(String str)
{
}
@BusSignalHandler(iface = "org.myapp.IMyInterface", signal = "EmitMySignal")
public void handleSignal(String str)
{
}
当 IMyInterface
通过之前调用 BusAttachment.registerBusObject(BusObject, String)
或 BusAttachment.getProxyBusObject(String, String, int, Class[])
.
BusAttachment
所知时,可以成功使用第一个示例
当 IMyInterface
对 BusAttachment
未知时,可以成功使用第二个示例。
使用第二个示例应该可以解决您的问题。
此外,根据上面提供的 link,在您的客户端程序中,
@BusSignalHandler(iface="org.alljoyn.bus.samples.simple.SimpleInterface", signal="playerPosition")
应替换为
@BusSignalHandler(iface="org.alljoyn.bus.samples.simpleclient.SimpleInterface", signal="playerPosition")