小编Tha*_*nga的帖子

我有一个类,它是传入消息的监听器,应该永远存活(以便它可以监听传入的消息),直到我明确断开它的连接.我已将该线程声明为setDaemon(false),但它终止于调用方法终止.

请告诉我如何使该线程保持活跃,并请详细说明如何实现Spring TaskExecutor来实现相同的目标.

提前致谢.它是一个监听器,当有人发送消息时它会收到通知...所以我如何让它保持运行？

听众类

public class MyListnerImpl implements Listener {
    private final connectionImpl con;   

    public MyListnerImpl(ConnectionImpl con) {
    if (con.isAuthenticated() && con.isConnected()) {
        if (logger.isInfoEnabled()) {
            logger.info("Initializing XmppListner:");
        }
        this.itsCon = con;
        Thread t1 = new Thread(this);
        t1.setDaemon(false);
        t1.start();
    }
    }

    public final void listnerInterfaceMethod(final Chat chat, final Message message) {
        System.out.println("Message" + message);
    }

    public final void run() {
    itsCon.getChatManager().addChatListener(new ChatManagerListener() {
        public void chatCreated(final Chat chat, final boolean createdLocally) {
            if (!createdLocally) {
                chat.addMessageListener(itsFbml);
            }
        }
    }); …

因为Scala还生成字节码并由JVM执行.我想知道JVM如何区分Scala字节码和Java字节码.有人可以解释一下吗？

 Scalac Myprogram.scala
 java Myprogram

所以这句话完全没问题？

bin/kafka-topics.sh --create --topic activityTopic --zookeeper localhost:2181/kafka --partitions 1 --replication-factor 1

来自kafka的上述命令会产生错误

Error while executing topic command   org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode =  NoNode for /brokers/ids
 org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode =   NoNode for /brokers/ids
at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685)
at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413)
at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409)
at kafka.utils.ZkUtils$.getChildren(ZkUtils.scala:462)
at kafka.utils.ZkUtils$.getSortedBrokerList(ZkUtils.scala:78)
at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:170)
at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:93)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:55)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
at org.apache.zookeeper.KeeperException.create(KeeperException.java:111)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472)
at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500)
at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99)
at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416)
at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)

任何的想法？

我有一个相同原始类型的字符串数组(不知道是什么).我需要将其转换为相应的类型.有没有办法,如果我传递一个字符串,并获得该字符串中的数据的原始类型.考虑字符串应该具有基本类型或者它被视为String

例如

"5.2" - double
"5" - int (most related)
"s" - char 

所以,如果它是双,我可以解析使用 Double.parseDouble

在我的spring-boot项目中，我使用 Logback-"Mapped Diagnostic Context" MDC来记录诊断上下文。

默认情况下不记录 MDC 数据（到控制台或文件）。

有没有办法仅使用应用程序属性将此 MDC 日志记录到输出日志中？

我有一个场景,我的逻辑运算结果实现

True <op> true - true
False <op> true - false
True <op> false - true
False <op> false - true

任何想法