小编Raj*_*hna的帖子

我正在尝试在 ECS 上运行的 Nginx 上运行一些负载测试，并且我已ulimit通过文档中提到的任务定义将 设置为更高的值 (777001) 。

在容器内，容器内的ulimit -Hn命令和cat /proc/sys/fs/file-max运行将给出与输出相同的值 ()。

在运行容器（自动扩展集群中的 EC2 之一）的 EC2 上，ulimit -Hn指定为 1024，cat /proc/sys/fs/file-max指定为 777001。

当我运行负载时，too many open files当每秒请求数达到 500 左右时出现错误。（ECS 服务的 CPU 使用率和内存使用率似乎在 25% 左右）。

在对此进行一些挖掘时，我发现了这篇中等文章，其中引用了/etc/sysconfig/docker提供给 docker 守护程序的文件和启动选项。在我的情况下，cat /etc/sysconfig/docker输出如下。

# The max number of open files for the daemon itself, and all
# running containers.  The default value of 1048576 mirrors the value …

我看过youtube ultraesb1.0.1演示用IntelliJ CE9包含的ultra-dynamic.xml可能会被ultraesb 3.2.0中的ultra-custom.xml所取代.

ultra-custom.xml

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:u="http://www.adroitlogic.org/ultraesb"
       xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://www.adroitlogic.org/ultraesb http://schemas.ultraesb.org/ultraesb-2.0.xsd">

    <u:endpoint id="echo-service">
        <u:address>http://localhost:9000/service/EchoService</u:address>
    </u:endpoint>

    <u:sequence id="error-handler">
        <u:java><![CDATA[
            logger.error("Custom error handler : " + msg.getLastException().toString());
        ]]></u:java>
    </u:sequence>


    <u:proxy id="health-check">
        <u:transport id="http-8280"/>
        <u:transport id="https-8443"/>
        <u:target>
            <u:inSequence>
                <u:java><![CDATA[
                    msg = msg.createDefaultResponseMessage();
                    mediation.sendResponse(msg,org.adroitlogic.ultraesb.api.management.
                        ServerAdminImpl.getInstance().getUserDefinedStatusCode());
                ]]></u:java>
            </u:inSequence>
        </u:target>
    </u:proxy>

</beans>

虽然我无法在互联网上找到ultra-dynamics.xml,但我会从youtube上关注ultraesb 1.0.1演示,以获得我最初的平滑输出.此外,我注意到ultra-custom.xml包含单独的独立标记,而ultra-dynamics.xml包含所有内容

任何人都可以帮忙

我知道不建议使用嵌入式Elasticsearch.我只是为了测试目的而尝试它.

我正在尝试启动一个嵌入式Elasticsearch节点,该节点提供以下elasticsearch.yml的配置

# Name for the cluster
cluster.name: elasticsearch
# Name for the embedded node
node.name: EmbeddedESNode
# Path to log files:
path.logs: logs
discovery.zen.ping.unicast.hosts: []
# Disable dynamic scripting
script.inline: false
script.stored: false
script.file: false
transport.type: local
http.type: netty3

我正在使用es 5.1.1并且我的代码启动嵌入式节点如下.

    try {
        Settings elasticsearchSetting = Settings.builder()
                // Value for path.home is required for es but will not be used as long as other properties
                // path.logs, path.data and path.conf is set.
                .put(ES_PROPERTY_PATH_HOME, "nullpath")
                .put(ES_PROPERTY_PATH_CONF, confDir)
                .build();
        Node node …

class Test{

    public static void main(String Args[]){

        Integer x;
        x = Integer.decode("0b111");
        System.out.println(x);
    }
}

对于二进制的前缀0和前缀为0的八进制,这不起作用.正确的方法是什么？

我知道TreeMap不是线程安全的.我正在尝试将TreeMap与ConcurrentSkipListMap进行比较.我使用的代码如下所示,我想确定我得到的错误是由于TreeMap不是线程安全而不是因为其他一些.

java中java.util.TreeMap.fixAfterInsertion(TreeMap.java:2127)的java.util.TreeMap.rotateLeft(TreeMap.java:2060)中的线程"pool-1-thread-52"java.lang.NullPointerException中的异常. util.TreeMap.put(TreeMap.java:574)位于java.util.concurrent.ThreadPoolExecutor $的java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)的ThreadTestTreeMap $ 1.run(ThreadTestTreeMap.java:39) java.lang.Thread.run上的Worker.run(ThreadPoolExecutor.java:615)(Thread.java:745)

import com.google.common.collect.Ordering;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ConcurrentSkipListMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ThreadTestTreeMap {
    public static Map<String, Object> map;
    public static int THREADS =  100;
    public static long averageTime = 0;

public static void main(String args[]) throws InterruptedException {
    for (int i = 0; i < 1; i++) {
        map = new TreeMap<>(Ordering.natural());
//            map = new ConcurrentSkipListMap<>(Ordering.natural());

        long time = System.nanoTime();
        ExecutorService service = …