我正在处理一个客户机-服务器应用程序，我想在通过socket.The代码收到停止消息时关闭服务器，我的服务器如下所示 public class Server extends Thread {
logger
浏览 22提问于2020-04-11得票数 0
2回答
我有一个用Java编写的服务器，它可以在监听、处理和更新Firebase数据时接收关闭信号。因为Firebase线程是Java中的守护进程线程，所以我想在主线程中添加一些延迟，以便完成写操作。我目前的想法是锁存方法:使用一些并发计数器来跟踪挂起的写入操作，并在没有线程时让主线程退出。计数器将在onComplete()回调中得到更新，因此我想知道：
在Firebase客户端中，何时可能永远不会调用onComplete()回调？僵局是否有合理的危险？
浏览 7提问于2014-09-29得票数 2
回答已采纳
我正在寻找任何教程/示例，它们展示了编写独立Java类的最佳实践，该类将像服务器一样运行(不退出)，并且可以通过从不同的JVM调用发出另一个命令来停止(有点像Tomcat服务器)。在java.util.concurrent中查找类是最好的方式吗?因为那里有一些有趣的类，比如CountDownLatch？举个例子会很有帮助。谢谢。
浏览 0提问于2011-07-22得票数 0
回答已采纳
3回答
当我向外部系统发送请求时，我希望实现严格的循环调度。有两个外部系统服务器。第一个请求应该转到'System1‘，第二个请求必须转到'System2’，下一个请求到'System1‘等等。由于我只有两台服务器可以发送请求，而且我希望在没有任何阻塞和上下文切换的情况下获得最大性能，所以我选择了AtomicBoolean，因为它使用了CAS操作。1.(Class (带有静态AtomicBoolean对象)
package com.concurrenc
浏览 9提问于2015-04-13得票数 7
回答已采纳
2回答
使用并发共享变量
、、
我正在尝试编写一个具有多个线程的Java程序。我有两个变量是在启动时创建的。一个是AtomicBoolean，它告诉整个程序何时关闭(即关闭客户端)。另一个变量是一个ConcurrentHashMap，它包含一组在启动时加载的命令。有些线程包含在客户端被接受时运行的客户端可运行的线程(每个客户端一个线程)。ServerSocket, etc. */
private final ConcurrentHashMap<String,
浏览 1提问于2016-12-21得票数 1
回答已采纳
当我们只在变量上做读操作时，应该使用易失性，因为一个线程更新的值对另一个线程是可见的，即使前一个线程失去CPU并退出同步块。对吗？当需要使用原子行为时，将使用原子原语。这就是应该使用AtomicBoolean的情况吗？如果是，为什么不能使用synchronized来处理？
浏览 0提问于2013-06-18得票数 1
1回答
我让SQL2012运行在两个不同的服务器上，具有公共的静态IP地址。我希望实现复制的方式将使两个服务器始终保持同步，而不管哪个服务器实际上正在接收数据。我一直在阅读关于订阅者/发行者模型的文章，但我不确定哪个应该是哪个。关于我们的设置的一些事实：
我在努力实现故障转移。如果服务器A发生故障，我需要服务器B能够运行，并且拥有所有的最新数据，或者尽可能接近。反之亦然。当服务器恢复联机时，我需要复制以快速捕获并重新开始工作。我需要失败才能优雅，
浏览 2提问于2014-01-02得票数 0
回答已采纳
4回答
我使用套接字运行了几个测试，遇到了一些奇怪的行为: ServerSocket将在第50个客户端套接字连接到它之后拒绝连接，即使该客户端套接字在打开下一个套接字之前已经关闭，即使在连接之间添加了延迟。但是，如果Socket[] clients的数组大小超过50，服务器套接字将拒绝在第50次连接后试图连接的任何客户端套接字。 } catch (Exception e) { }
}
浏览 2提问于2012-10-19得票数 13
回答已采纳
我想要一个when循环运行，只要按钮是切换和停止时，按钮是切换关闭。现在，在程序中，when循环在我按下按钮时会激活，但是当我关闭按钮时，循环不会停止。当我关闭按钮时，有没有什么东西让循环停止？import java.util.HashMap;import java.util.concurrent.atomic.AtomicBoolean</em
浏览 2提问于2016-09-13得票数 1
回答已采纳
关闭TCP套接字有4个步骤。客户端关闭FIN_WAIT_1 FIN M =>服务器客户端TIME_WAIT <= FIN N服务器LAST_ACK
如果客户端进程在服务器发送响应之前被终止，那么客户端是否不能发送最后一个ACK，因为它已经死了？127.0.0.1.6000 FI
浏览 1提问于2019-07-15得票数 0
以下是我所走的步骤：
import static org.awaitility.Awaitility.await;
import java.util
浏览 0提问于2018-03-18得票数 1
1回答
上下文：
我在java中有一个cmd应用程序，它是在不同的服务器中以对等模式工作的。一旦服务器启动，所有其他实例都必须停止。因此，我编写了一段代码，运行在低优先级线程中，并监视AtomicBoolean值autoClose，每当autoClose设置为true时，线程将关闭应用程序。(P.S.(也就是说，JVM可以在子句中选择将切换到另一个线程并调用Thread.currentThread() )，因此此时当前线程将是另一个线程，而我
浏览 2提问于2021-01-30得票数 1
回答已采纳
我有一个，它在下一个可用有效负载上接收，在收到最后一个有效负载时，有一个。(以下简化代码)
从new TextWebSocketFrame(false, 0, buf)开始，用new TextWebSocketFrame(true, 0, buf)关闭。false, 0, buf)开始，用new TextWebSocketFrame(false, 0,
浏览 0提问于2019-08-22得票数 0
1回答
我从一个人那里得到了一个在android上使用多线程服务器的例子：
while(!this.serverSocket.accept();private synchronized boolean isStopped() {}
但是它如何关闭这个套接字呢原因如果你在尝试接受一个客户端时得到异常，你应该关闭由accept返回的套接字。
浏览 2提问于2011-04-17得票数 0
回答已采纳
1回答
我正在使用Java非阻塞SocketChannel编写一个服务器程序。有时我想发送一个回复消息，然后关闭通道，就像下面的代码一样。然而，close()方法中断了write()方法，我得到了一个java.nio.channels.ClosedChannelException，并且消息没有被发送。我可以弹出一个线程，在关闭通道之前等待1-2秒，但我觉得创建另一个线程太浪费了。
在有挂起的操作时，关闭SocketChannel的正确方法是什
浏览 1提问于2010-12-03得票数 4
一切都运行得很好，除了JODConverter使用了来自OpenOffice的Java库，该库使用JNI从系统中获取某些库文件。如果我在运行java时没有使用-D设置java.library.path方法，这将抛出一个异常。
我正在构建的应用程序是独立于平台的，并且有一个中央配置文件。我想让它保持原样。我正在考虑使用System.load在URE bin中添加所需的每个文件，但似乎有点多。我还在想，也许在我的初始化脚本(运行我的应用程序的脚本)中有某种方法可以动态地找到URE bin目录
浏览 4提问于2009-12-08得票数 0
回答已采纳
我用Java的编写了一个基于生产者/消费者的程序。如果所有的生产商都完成了，我正试图找到一种阻止消费者的方法。有多个生产者，但只有一个消费者。
浏览 2提问于2013-11-16得票数 1
回答已采纳
2回答
在取消部署Java应用程序时，我需要关闭一些流，以避免每次取消部署时在server.log中出现异常页面。异常表示：“输入流已完成或强制关闭，但未显式关闭”。我知道如何关闭(使用close()方法)，但我不知道何时关闭。 decisi
浏览 6提问于2010-07-23得票数 2
回答已采纳
1回答
目前，我在while循环中轮询()消息，直到ConsumerRecords.isEmpty()为真。当ConsumerRecords.isEmpty()为真时，我假设所有可用的主题记录都已被消耗。应用程序维护抵消和关闭卡夫卡消费者。
当对消息的处理完成并成功完成时，我创建一个新的KafkaConsumer并提交应用程序维护的偏移量。是否有更好的方法在特定的时间点使用所有关于主题的消息？有什么我遗漏或需要照顾的东西吗？我不认为我需要处理消费者再平衡，因为我轮询()循环中的消息，并在轮询完成后处理消息。我使用
浏览 2提问于2017-09-16得票数 0
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
