标签: consumer

我正在寻找一个帮助我构建OAuth提供程序的Java库.我必须能够接收OAuth签名请求并确定它们是否有效(检查签名,时间戳和现时值).

你知道是否有什么能让这项工作更容易吗？

我正在使用RabbitMQ,我有一个包含电子邮件的队列.我的消费者服务将消息排队并尝试发送消息.如果由于任何原因,我的消费者无法发送消息,我想重新排队消息再次发送.我意识到我可以做一个basicNack并将requeue标志设置为true,但是,我不想无限期地重新排列该消息(例如,如果我们的电子邮件系统出现故障,我不想连续重新排队未发送的消息).我想定义有限次数,我可以重新排列要再次发送的消息.但是,当我将它出列并发送一个nack时,我无法在电子邮件消息对象上设置字段.更新的字段不存在于队列中的消息上.还有其他方法可以解决这个问题吗？提前致谢.

我正在使用OAuth2.0在PHP中设计API.我的最终目标是在javascript(使用AngularJS)中构建一个直接访问此API的前端应用程序.我知道传统上没有办法在javascript中保护交易,因此直接访问API是不可行的.前端需要与服务器代码进行通信,而服务器代码又直接与API通信.但是,在研究OAuth2时,看起来用户代理流程似乎是为了帮助解决这种情况.

我需要帮助的是在javascript中实现OAuth2用户代理流程(特别是AngularJS,如果可能的话,因为我正在使用我的前端).我无法找到任何这样做的示例或教程.我真的不知道从哪里开始,不想阅读整个OAuth2规范,至少没有看到我将要做的事情的例子.因此,非常感谢任何示例,教程,链接等.

我在C#3.0和Monitor.Enter中使用Generic.Queue,等待,在使用队列之前退出等待(等待元素入队).现在我转到C#4.

任何人都可以建议我哪一个是快速的,尤其是避免锁定..

BlockingCollection vs concurrentQueue或其他任何东西......

注意.我不想限制我的制片人

提前致谢..

我需要在代码块中使用流中的'n'项然后完成,实质上:

 public static <T> void eat(Stream<T> stream, int n) 
     // consume n items of the stream (and throw them away)
 }

在我的情况下,我无法改变签名返回Stream<T>简单return stream.skip(n); 我必须实际丢弃流中的一些元素(不是简单的逻辑) - 为下游消费者做好准备,这不需要知道这是怎么发生的,甚至不知道发生了什么.

最简单的方法是使用limit(n),但我必须调用流终止方法来激活流,所以本质上我有:

public static <T> void skip(Stream<T> stream, int n) {
    stream.limit(n).forEach(t -> {});
}

注意:此代码完全简化了实际代码,仅用于说明目的.实际上,限制将不起作用,因为存在围绕什么/如何消耗元素的逻辑.可以把它想象成从流中消费"header"元素,然后让消费者使用"body"元素.

这个问题是关于"无所事事"的lambda t -> {}.

在JDK中的某个地方是否有"无所事事"的消费者,比如"无所事事"功能Function.identity()？

我是Java 8的新手,我遇到了Consumer java doc,它说:"预计消费者将通过副作用进行操作." 有人可以解释为什么这么说？

我创建了一些web apis,当发生错误时,api返回使用CreateErrorResponse消息创建的HttpResponseMessage.像这样的东西:

return Request.CreateErrorResponse(
              HttpStatusCode.NotFound, "Failed to find customer.");

我的问题是我无法弄清楚如何在消费者应用程序中检索消息(在这种情况下" 找不到客户. ").

以下是消费者的样本:

private static void GetCustomer()
{
    var client = new HttpClient();
    client.DefaultRequestHeaders.Accept.Add(
                new MediaTypeWithQualityHeaderValue("application/json"));
    string data =
        "{\"LastName\": \"Test\", \"FirstName\": \"Test\"";

    var content = new StringContent(data, Encoding.UTF8, "application/json");

    var httpResponseMessage = 
                 client.PostAsync(
                    new Uri("http://localhost:55202/api/Customer/Find"),
                    content).Result;
    if (httpResponseMessage.IsSuccessStatusCode)
    {
        var cust = httpResponseMessage.Content.
                  ReadAsAsync<IEnumerable<CustomerMobil>>().Result;
    }
}

任何帮助是极大的赞赏.

我读过每个kinesis流可以有多个消费者应用程序.

http://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers-with-kcl.html

但是,我听说你每个碎片只能使用消费者.这是真的？我没有找到任何支持这一点的文档,也无法想象如果多个消费者正在从同一个流中读取数据.当然,这并不意味着生产者需要为不同的消费者重复不同分片中的内容.

我更改了侦听 Kafka 主题的 Web 服务的消费者组 ID。现在，旧的组ID仍然注册到主题，但是没有具有该组ID的消费者。因此，它是滞后的。如何从特定主题中删除特定消费者组？

我试过这个：

kafka-consumer-groups --bootstrap-server kafka01.myserver.com:9092 --topic notification-topic --delete --group old-consumer-group --execute

但它返回：“消费者不支持从消费者组删除特定于主题的偏移量。 ”

我应该完全删除消费者组吗？我使用相同的组ID收听其他主题，它们会受到影响吗？

我有一个 RabbitMQ 队列，我在其中发布数千条消息。我需要一个后台服务来：

• 批量检索消息，每组消息 100 条
• 将这 100 条消息存储在数据库中
• 一次性确认全部 100 条消息
• 继续处理下一批 100 条消息

我正在使用 RabbitMQ 客户端来监听消息，但我不知道如何“批处理”它们。

有没有人有一个关于如何一次获取 100-100 条消息并在将它们保存在数据库中后立即确认所有消息的工作示例？

提前非常感谢