问题标签 [consumer]

我正在尝试将变量传递给一个分叉的函数，大多数似乎都可以工作，但我需要给每个变量一个我试图传递的 argv[5] 之前未声明的 id。我的代码不断出现段错误，我不知道为什么。有任何想法吗？

主要的

产卵

我有一个使用多处理器和共享内存的生产者-消费者任务

我有一个问题如何使用 execl() 执行另一个文件

在我的程序中将包含 3 个 c 文件

parent.c : 父进程

producer.c ：生产者进程

consumer.c ：消费者进程

在我编译文件后 -> 名称 parent,producer,consumer

如果我放目录，我放的所有文件都是：/home/assign

在 parent.c 我有一个代码可以像这样通过 fork 调用生产者和消费者

但是，当我通过 Linux 命令 ./parent 运行程序时

它显示这样的结果

我知道路径或执行命令之间有问题

你能帮忙吗

当我尝试使用 RecursiveASTVisitor 访问 AST 时，我遇到了上述问题。最后，程序中止并显示以下消息。

真的感谢帮助

我有以下配置的语言选项。

我刚刚开始使用 OSGI 技术，但基本的查询很少。这是我所做的：

在名为“com.mypackage.osgi.bundle.service”的包中创建了一个 HelloWorld 接口。这个接口公开了一个方法： public String sayHello(String arg);

在名为“com.mypackage.osgi.bundle.service.impl”的包中创建了一个 HelloWorldImpl 类。这个类实现了 HelloWorld 接口并提供了 sayHello() 方法的实现。

在名为“com.mypackage.osgi.bundle.activator”的包中创建了一个 HelloWorldActivator 类。该类实现了BundleActivator接口，实现了接口的start()和stop()方法。

在 start() 方法中，我通过“BundleContext”将此捆绑包注册为服务。代码如下所示：

公共类 HelloWorldActivator 实现 BundleActivator {

然后，我使用 maven 插件将此项目打包为 OSGI 包，并将其部署在 OSGI 容器（Equinox）上。在说明中，我将接口公开为导出包。我可以看到我的 OSGI 包已成功部署为 OSGI 容器上的服务（包 id 表示活动状态，而且我可以在 osgi 控制台上看到“服务注册”输出）。

现在我的下一步是将上述 OSGI 包作为服务使用。我知道为了做到这一点，我可以使用“ServiceReference”。

假设我现在正在创建一个全新的 java 项目（因此该项目的工作区中没有与上面创建的项目的链接），这样它将充当上面创建的服务的消费者。

我的查询是 - 我需要在这个新的 java 项目中创建 HelloWorld 接口的“副本”吗？换句话说，我需要在这个新项目的工作区中将此界面作为“存根”吗？

我问这个的原因是，如果我在新项目的工作区中没有“HelloWorld”接口的副本，我将在下面提到的第 2 行和第 3 行出现编译错误。

公共类 ConsumerActivator 实现 BundleActivator {

那么，说消费者捆绑包应该有它打算使用的服务接口的“存根”是否正确？

抱歉，如果这听起来是一个非常基本的问题，但只需要澄清一下，因为我在网上的任何地方都找不到任何提及它的内容。提供的所有示例都假定消费者和服务都是同一代码工作区的一部分。

非常感谢提前澄清。

最好的问候 LB

我知道可以修改消费者的数量：

其中“X”是消费者的数量。

但是有没有另一种改变它们的方法？因为我想从 File 中获取该数字（我读取了.properties File，然后设置了消费者的数量。

我正在使用 hornetq 2.2.14.Final 和 JBoss 5.1.0.GA

伙计们，

跟踪访问部门内 RESTful API 服务的消费者应用程序的最简单方法是什么。我们不限制访问 - 没有身份验证/授权 - 开放调用，受信任的环境。还没有像 OAuth AuthZ 服务器或 API 管理这样的工具……但可能会在某个时候出现。

目前，我们认为要求消费者只包含一些自定义 HTTP 标头，例如 X-Client-Id 并将其记录在服务器端以获取统计信息等。但是知道将来我们可能希望切换到更标准的做事方式...将来必须更改更少代码的最佳选择是什么？

• 在授权中有“clientId”：OAuth 令牌（如访问令牌）
• 在授权标头中有 JWT 令牌（看起来太多 - 签名、base 64 等用于简单的客户端 ID 跟踪......）

任何想法，将不胜感激

I am using Active MQ storage mechanism for my UDP packet processing. One UDP packet processing Program is listening UDP packets and inserting into 4 Queues which is configured. I have one consumer program which is consuming from these 4 queues by creating 4 threads. Each thread process the packet and insert into db and then call a webservice to do various functionalists and then only process the next packet. My problem is in some days when the frequency of getting packets are very high, the consumer is not consuming fastly and Queuing is happening. However in Queuing time and Non-Queuing Time the webservice processing time for a packet is same and almost constant to 50 ms.

So during this Quing time I will have to stop the webservice and restore the issue. When I am stoping the webservice the Dequeuing is happening fastly. But I want to use all the functionalities of webservice and the processing should be also high. Because of this Queuing Issue Recently I have increased the number of Qs from 4 to 6 and for some time it restored my issue. But as and when the number of packets are getting high Queuing is happening and the processing is not happening in higher rate.

Please advice how can I solve the issue ?

Thanks for you time.

场景：我向名为 JUST.CN 的队列发送五万条消息。并且每 1000 条消息设置一个消息属性字符串“myfilter='abc'”。现在我创建具有相同选择器的消费者来消费消息。但是消费速度非常慢，尤其是在 30000 条消息之后。我无法更改 activeMQ 中的默认配置。核心代码如下：

消费者代码：

我需要为 ActiveMQ 的选择器使用任何特殊设置吗？提前感谢您的任何意见。

我有一个 Oracle 11g 数据库，它连接到另一个 Oracle 数据库并具有从该源数据库收集数据的存储过程。源数据库正在替换为具有 OLEDB 数据提供程序的专有 (OSISoft PI) 数据库，我的任务是维护连接。所以...

我可以看到很多关于甲骨文 OLEDB 供应商允许甲骨文成为来源的信息，但没有关于甲骨文成为消费者的信息。所以...

Oracle 11g 能否连接到 OLEDB 数据源，以便 Oracle 中的存储过程查询 OLEDB 源？

我想使用类似的反应堆：

我的活动很简单：

然后像这样消费这些事件：

但是我收到了两个消费者的两个事件。

如果我使用选择器，它可以工作，即：

但是使用选择器我将不得不编写和维护非常多的字符串。

都是关于使用选择器的吗？还是我可以以某种方式“按参数化类类型选择”？