REDHAWK——连接(续)(三)

简介: REDHAWK——连接(续)(三)

REDHAWK——连接(续)(二)https://developer.aliyun.com/article/1474068

3、查看消息

消息是事件,其有效负载定义与组件属性中的结构相关联。查看消息可以使用用于查看事件的相同技术。

要在终端窗口查看发送到事件通道的事件和消息:

eventviewer <domain name> <event channel>

实用程序的帮助:

eventviewer --help

eventviewer REDHAWK_DEV testchan

示例输出:

这里出现了错误,还未找到解决办法,待后续找到后修改

4、连接生产者和消费者

生产者和消费者可以点对点连接,也可以通过IDE 中的事件通道连接。将生产者直接连接到消费者不需要应用程序,并且可以在沙箱中完成:

from ossie.utils import sb
sb.catalog()
#['structs_test', 'm_in', 'prop_changes', 'm_out','pass']
prod=sb.launch("m_out")
cons=sb.launch("m_in")
prod.connect(cons)
#True
sb.start()

这里出现了错误,还未找到解决办法,待后续找到后修改

5、连接回调

在组件中,许多 REDHAWK 中的 Uses 端口类支持在连接建立或断开时进行通知。支持的端口类型和语法因语言而异。

①、C++

在 C++ 中,Bulk 输入/输出(BulkIO)、Burst 输入/输出(BurstIO)和消息 Uses 端口的连接通知机制已标准化。连接和断开回调被注册在端口上。

以下示例假设一个 C++ 组件具有 BulkIO 浮点输出端口,dataFloat_out;然而,对于 BurstIO 和消息端口,语法是相同的。

在组件头文件中,将回调声明为私有成员函数。连接和断开回调都接收单一参数,连接 ID(一个引用的 std::string):

void dataFloatConnected(const std::string& connectionId);
void dataFloatDisconnected(const std::string& connectionId);

在组件源文件中,实现回调函数:

void MyComponent_i::dataFloatConnected(const std::string& connectionId)
{
  LOG_INFO(MyComponent_i, "New connection " << connectionId << " on dataFloat_out");
}
void MyComponent_i::dataFloatDisconnected(const std::string& connectionId)
{
  LOG_INFO(MyComponent_i, "Disconnected " << connectionId << " on dataFloat_out");
}

然后,在组件 constructor() 中注册回调函数

dataFloat_out->addConnectListener(this, &MyComponent_i::dataFloatConnected);
dataFloat_out->addDisconnectListener(this, &MyComponent_i::dataFloatDisconnected);

addConnect Listener()addDisconnectListener() 接受两个参数:目标对象(通常是this)和一个指向成员函数的指针。

没有必要同时注册连接和断开回调。

6、自定义 IDL 接口

REDHAWK提供前端接口(FEI)和标准核心框架(CF)接口(如 CF::Resource),用于控制实体并促进互操作性。在某些用例中,您可能会发现需要使用自定义接口描述语言(IDL)来控制实体。对于这些用例,您可以在 IDE 中创建自定义 IDL 项目。

将端口从 FEI 接口或自定义 IDL 接口添加到组件或设备中,允许该实体通过 CORBA 控制其他实体。由于这些端口的通用性质,不可能创建像 BulkIO 这样的语言映射,因此交互是通过标准的 CORBA API 进行的,其完整描述超出了本手册的范围。然而,REDHAWK 代码生成器将生成简化与端口交互的端口。以下部分解释了使用(输出)端口的情况,因为它们最有可能被生成,例如,用于控制 FEI 设备。

①、连接反馈

在所有三种支持的语言中,FEI、标准 CF 或自定义 IDL 端口将有所有方法和属性映射到端口,并且端口将委托调用给远程连接。在 REDHAWK 中,端口可能没有连接、有一个连接或多个连接。这些条件中的每一个都可能为使用端口进行通信的人创建问题;例如,如果发送了一个控制请求并且没有连接,那么用户应该被告知请求没有发送到任何地方。

同时,并非所有方法都是相同的。一些方法只在一个方向上推送数据,一些方法有返回值,一些方法有作为指针的参数,需要用信息填充(输出或输入/输出参数)。当调用端口方法并且端口无法进行调用或调用无法明确时(例如,如果存在两个连接并且函数包含返回值),则在用户代码中引发 PortCallError。下表描述了满足的方法签名标准及其对应的行为。

如果一个方法作为其非异常 API 的一部分有任何形式的返回值(表现为非 void 返回值,或一个输出或输入/输出参数),那么如果端口有多于一个的连接,就会引发一个异常。此外,如果尝试调用时实际上没有连接,就会引发一个错误。

②、连接选择

虽然当所需的连接不明确时,生成的端口类会触发一个错误,但它也包含一个 API,允许开发者选择应该使用哪个连接。每个方法都有一个可选参数,connection_id,允许调用者明确应该使用哪个连接。默认值行为将使用最后建立的连接。如果指定的 connection_id 不存在,将引发 PortCallError。

在以下部分中,用于明确连接的相同模式在所有三种支持的语言中都提供了。

以下代码示例使用调用 CF::File 接口的 read 方法时的默认行为。

CF::OctetSequence_var _data = new CF::OctetSequence();
 CF::OctetSequence_out data(_data);
 this->file_out->read(data, 10); // read 10 characters from the last connection made to the port

以下代码示例将读取调用明确指向一个特定的连接,connection1。

CF::OctetSequence_var _data = new CF::OctetSequence();
 CF::OctetSequence_out data(_data);
 this->file_out->read(data, 10, "connection1"); // read 10 characters from the connection called "connection1"

要查看可用的连接,请使用以下代码:

std::vector<std::string> _connection_ids = this->file_out->getConnectionIds();

③、方法映射

方法名称映射遵循在连接选择中描述的模式;即方法名称与 IDL 中描述的名称相同,但增加了一个额外的参数(可选地使用),可以指定应使用哪个连接。属性被映射为对 CORBA 对象的函数。REDHAWK 提供额外的 API 来消除对多个连接的调用的歧义。

④、读取属性

通过调用属性的名称作为函数来执行读取属性。例如,如果端口 my_port 包含字符串属性 greeting,则可以如下检索 greeting 的值:

std::string _greeting = this->my_port->greeting();

要从特定连接检索值,需要_get_前缀:

std::string _greeting = this->my_port->_get_greeting("some_connection_name");

⑤、写入属性

在 C++ 中写入属性涉及使用适当的参数调用函数:

this->my_port->greeting("hello"); // write "hello" to the attribute "greeting"
 this->my_port->greeting("hello", "some_connection_name"); // write "hello" to the attribute "greeting" over connection "some_connection_name"
目录
相关文章
|
1天前
|
XML IDE C++
REDHAWK——连接(续)(一)
REDHAWK——连接(续)(一)
43 0
|
1天前
|
IDE Java 开发工具
REDHAWK——组件结构
REDHAWK——组件结构
47 0
|
1天前
|
C++
REDHAWK——连接(续)(二)
REDHAWK——连接(续)(二)
20 0
|
1天前
|
C++ Python
REDHAWK——连接(三)
REDHAWK——连接(三)
16 0
|
1天前
|
存储 算法 中间件
REDHAWK——连接(二)
REDHAWK——连接(二)
34 1
|
1天前
|
XML 区块链 C++
REDHAWK——连接(一)
REDHAWK——连接(一)
55 0
|
1天前
|
IDE 算法 中间件
初识REDHAWK
初识REDHAWK
40 2
|
存储 测试技术 C语言
西门子S7-200 SMART自由口通信参数如何设置?如何编写发送程序和接收程序?如何测试?
西门子S7-200 SMART除了支持以太网通信,还可以通过CPU上或信号板上的RS485接口实现串口通信。支持的串口协议,包括自由口协议、USS协议、MODBUS协议和PPI协议。STEP7 Micro/WIN SMART编程软件安装时自动集成串口通信所需要的功能块和子程序。
西门子S7-200 SMART自由口通信参数如何设置?如何编写发送程序和接收程序?如何测试?
|
SQL 大数据 开发者
连接操作_连接类型_inner | 学习笔记
快速学习连接操作_连接类型_inner
65 0
连接操作_连接类型_inner | 学习笔记
|
移动开发 小程序 iOS开发
小程序和h5之间的通讯及注意事项
起因:在小程序中嵌入已有的h5页面,用于快速开发。但是h5和小程序中的事件通讯是需要解决的问题。参照官网后实践之后得出结论。
852 0