小编spa*_*rkr的帖子

有什么参考,我可以找到如何为DateTimeOffset创建一个格式,使我能够生成这样的字符串？

2016-10-01T06:00:00.000000+02:00

我有一个可以使用的DateTimeOffset,但我不确定如何格式化它以产生上面的字符串表示？

我有一组从一个特征继承的case对象,如下所示:

  sealed trait UserRole
  case object SuperAdmin extends UserRole
  case object Admin extends UserRole
  case object User extends UserRole

我想将其序列化为JSON,我只使用了Format机制:

implicit val userRoleFormat: Format[UserRole] = Json.format[UserRole]

但不幸的是,编译器不满意,它说:

No unapply or unapplySeq function found

我的案例对象出了什么问题？

我认为这很容易让 docker 守护进程在我启动机器时不启动，但似乎并非如此。我手动安装了 docker，然后在安装后使用了以下简单的行：

sudo systemctl disable docker

但令我惊讶的是，这并没有太大作用，我仍然可以看到守护进程愉快地跑来跑去！

joesan@joesan-InfinityBook-S-14-v5:~$ docker ps
CONTAINER ID        IMAGE               COMMAND             CREATED             STATUS              PORTS               NAMES
joesan@joesan-InfinityBook-S-14-v5:~$ 

有什么我想念的吗？有什么线索吗？

在Play框架中是否有默认捕获所有后备路由？如果是这样,我如何在我的路线文件中配置它？目前,有些网址我不希望用户给他们打电话,即使他们打电话,我也不希望出现错误页面,而是希望他们转到我的网络应用程序的登录页面!有没有办法在路由配置文件中执行此操作？

我有一个在我的远程Ubuntu机器上的特定端口上运行的进程,我通过HTTP公开该端口.当我尝试使用curl连接我的客户端时,我无法连接,但如果我在本地远程计算机上执行相同的调用,我可以看到它连接.所以我很确定这是一个网络问题,但不确定它是什么？

即使尝试远程主机,如果我给出机器的实际IP地址,我也会得到同样的错误!

Joes-MacBook-Pro:~ joe$ curl --verbose --insecure --cert .docker/cert.pem --key .docker/key.pem https://my.ip.address:1234/images/json  
* About to connect() to my.ip.address port 1234 (#0)  
*   Trying my.ip.address... Connection refused  
* couldn't connect to host  
* Closing connection #0  
curl: (7) couldn't connect to host  
Joes-MacBook-Pro:~ joe$ 

Play 框架向我的应用程序公开的线程数量是否有限制？Play 应用程序内的线程大小真的那么珍贵吗？如果我在应用程序中使用自己创建的线程池而不使用 Play 提供的线程池，会怎么样？这是推荐的吗？谁能解释一下 Play 如何处理线程？

我有一个场景，我必须通过用户的 ID 获取用户的详细信息。这是一个传入 HTTP 处理程序层的 HTTP 请求，我利用从请求中获取的 id，向 Actor 发送一条消息，然后 Actor 与数据库服务通信以获取用户。

现在，由于这是一个 HTTP 请求，我需要通过发回响应来满足该请求。所以我想到使用 Akka Ask 模式，但我有以下问题：

1. 这会阻塞我当前的线程吗？

2. 在我的例子中，使用询问模式来获取用户是一个可扩展的解决方案吗？我的意思是，在任何给定时间点，我都可能有数百到一百万用户调用此端点。使用询问模式来获取用户是一个好主意吗？

在代码中，它在我的 HTTP 控制器中看起来像这样

val result: Future[Any] = userActor ? FetchUser(id)

在我的演员中，我会做以下事情：

case fetchUser: FetchUser => sender ! myService.getUser(fetchUser.id)

我们有一个系统（例如系统A），该系统通过HTTP接收时间序列数据，并且该数据通过OpenTSDB的REST接口保存在OpenTSDB中。我现在想将Apache Kafka引入系统。我的想法是要运行Kafka服务器，系统A在接收到时间序列消息后立即将其发布到Apache Kafka服务器。

然后，我可以有一个使用者，该使用者从主题中读取数据并将其写入OpenTSDB。我对这种方法有两个疑问：

关于设计生产者和消费者：

1. 我可以有一个独立的客户端吗，在那里我将编写仅从Kafka主题消费的使用者，并将消息写入OpenTSDB

2. 生产者将成为系统A的一部分，并将针对相应主题发布消息

关于Kafka主题，时间序列数据是一些具有键和值的指标，其示例如下：

 "metric.metricType.tagName"

我将拥有数百个甚至数千个这些不同的tagName。如何构造这些信息并将其表示为Apache Kafka中的主题。我不确定我可以创建的主题数是否有限制。

每个tagName是否应该有一个主题？分区主题有什么处理？

关于Apache Kafka分区，我有以下问题：

1. 如果我有一个主题“主题A”，并且已将该主题的分区设置为4，并且我的生产者写了该分区，那么此消息在该主题的哪个分区中可用？同一主题内的每个分区上是否有相同的消息？

2. 如果我为该分区主题编写使用者，我的意思是，该使用者将收到来自分区的消息吗？

3. 如果这个分区主题有多个使用者，那么所有这些使用者都会收到相同的消息吗？我的意思是，如果主题（TP1，TP2，TP3，TP4）中有4个分区，并且我有4个使用者组（CG1，CG2，CG3，CG4），那么在每个使用者组中，我都有一个使用者从中读取消息。各自的主题分区（C1从TP1读取，C2从TP2读取，依此类推）。如果我的所有消费者组都将收到的消息写到同一数据库中，我是否会收到重复的消息？

我想深入了解Scala中的类型级编程,并开始做一些小练习.我开始在类型级别实现Peano数字.这是下面的代码!

sealed trait PeanoNumType { // Type at the end indicates to the reader that we are dealing with types
  type plus[That <: PeanoNumType] <: PeanoNumType
}

sealed trait ZeroType extends PeanoNumType {
  type plus[That <: PeanoNumType] = That
}

sealed trait NextType[This <: PeanoNumType] extends PeanoNumType {
   type plus[That <: PeanoNumType] = NextType[This#plus[That]]
}

现在问题是,上述实施会给我带来什么？我该如何使用它？

我想添加一个徽章,计算我在GitHub上的一个项目所发生的下载总数.我遇到了这个包含所有图像屏蔽的页面

https://shields.io/


关于如何将其添加到GitHub中的项目的任何想法？