小编use*_*024的帖子

EntityManager何时提交?

我有以下服务......

@Stateless
@LocalBean
public class RandomService {

    @EJB RandomString stringTokenizer;

    @PersistenceContext
    EntityManager em;

    public String generate(Actions action)
    {
        Token token = new Token();
        token.setAction(action);
        token.setExpiry(new Date());
        token.setToken(stringTokenizer.randomize());

        em.persist(token);
        //em.flush();

        return String.format("%010d", token.getId()) + token.getToken();
    }
}
Run Code Online (Sandbox Code Playgroud)

如果我没有放入em.flush()那么行token.getId()将返回null(使用DB GENERATED SEQUENCE)虽然我知道如果我将Token而不是字符串返回给调用服务,则设置id.因此,当服务返回令牌对象时,EM似乎会刷新,但是当我放置String时,EM则不会刷新.通过把冲洗我得到我需要的是正确的吗?

jpa jersey entitymanager ejb-3.1

4
推荐指数
1
解决办法
1万
查看次数

Elasticsearch是否会产生结果?

Elasticsearch是在"计算"时对流查询结果进行流式处理还是计算所有内容,然后将最终响应返回给客户端?

elasticsearch

3
推荐指数
1
解决办法
4464
查看次数

如何确定Elasticsearch的合格主节点数?

运行ES 1.4.3

所以我有4个集群节点.所有节点都配置为默认节点(双功能数据/主节点).

那么在默认配置中我们可以拥有4个符合条件的节点吗?

所以N/2 + 1 = discovery.zen.minimum_master_nodes:3

现在假设我决定将我的集群扩展到20个节点,并获得主节点的专用物理盒...

我应该为专用主节点购买多少个盒子,现在20个节点是严格的数据节点?

elasticsearch

3
推荐指数
1
解决办法
1046
查看次数

预先JAVA 7 JDBC API与JAVA 7一起使用资源吗?

只需将应用程序转换为JAVA 7,并想知道是否有人遇到过使用资源和c3p0连接池的问题.

我想现在,如果你使用try with resources,JAVA会自动关闭数据库,准备好的语句和语句.

这是否意味着诸如JDBC驱动程序和c3p0之类的底层API必须实现AutoClosable?

我使用的是c3p0 0.9.2.1和jtds 1.3.0

jdbc c3p0 java-7 autocloseable

2
推荐指数
1
解决办法
177
查看次数

分离器导致重复键异常,而for循环不

我正在使用Java 8流。

当我使用分隔符将其添加到地图中时,会得到重复的键异常,但是使用标准的for循环不会引发异常。

// This works
Map<Integer, String> myMap = new HashMap<>();
for (Row row : result.result()) {
    myMap.put(row.get(0, Integer.class), null);
}

// This throws exception
myMap = StreamSupport.stream(result.result().spliterator(), true)
    .collect(Collectors.toMap(row -> row.get(0, Integer.class), row -> ""));
Run Code Online (Sandbox Code Playgroud)

如果有什么不同,则结果为Cassandra结果集,行为Cassandra行。

java cassandra java-8 java-stream

2
推荐指数
1
解决办法
64
查看次数

Kafka Streams 输出主题可以在单独的集群上吗?

我有一个主题,其中所有日志都推送到集中主题,但如果可能,我想将其中一些记录过滤到单独的主题和集群。

谢谢

apache-kafka apache-kafka-streams kafka-topic

2
推荐指数
1
解决办法
1552
查看次数

对Surround scm的任何想法?

所以看看不同的版本控制系统:subversion,accurev,surround,tfs,bitkeeper/git/mercurial

  • 颠覆:我认为它是非常受欢迎的标准
  • Accurev:周围似乎有一种爱恨交织.
  • 环绕声和TFS:我没有看到很多关于它们的评论.
  • Bitkeeper/Git/Mercurial:看起来很受欢迎,但我认为"分发"可能会吓到我的经理大声笑

出于某种原因,他似乎被Surround所吸引,这不是因为销售推销.我们最初下载了它以进行评估,但没有任何结果.所以现在我们回过头来看看scm并想再试一次.到目前为止,我还没有像其他版本控制系统那样看到任何嗡嗡声.对于TFS也是如此

version-control surroundscm

1
推荐指数
2
解决办法
3805
查看次数

Netty 服务器处理程序中的异步客户端连接

我需要打开与 Netty 服务器业务处理程序的 TCP/IP 客户端连接。

所以

  • 在服务器套接字上接收请求,保持套接字打开
  • 穿过管道并到达业务处理程序......
  • 在业务处理程序中打开异步客户端连接,向第三方发送请求
  • 当收到来自第三方的响应时,会回复原始客户端。

那么,在“业务”处理程序中,有没有一种方法可以向第 3 方发起异步调用,然后当第 3 方回复时,如何附加回该通道并回复回源?

或者只是简单地,在向第三方开放的业务处理程序中,发送、接收、回复关闭通道。

它基本上是一种 1 对 1 类型的事物,发出 1 个请求,来自第 3 方的 1 个请求/响应,并返回结果。

netty

1
推荐指数
1
解决办法
2075
查看次数

Java 8 Date如何检查时间是否早于X秒?

使用新的Java 8 DateTime API(java.time),我们如何检查"最后"捕获时间是否早于配置的秒集?

例...

上次拍摄时间:13:00:00当前时间:13:00:31

if (last captured time is older then 30 seconds) then
    do something
Run Code Online (Sandbox Code Playgroud)

java date java-8 java-time

-6
推荐指数
1
解决办法
2758
查看次数