Tag: 分布式

如何为Java应用程序创建简单的分布式Map？: 我正在寻找一个Map来分享在不同机器上运行的Java Web应用程序的两个实例之间的信息。对此映射的读取和写入需要非常快，并且不必是事务性的，即如果一个实例有一段时间的陈旧数据就可以。有什么建议？我需要跟踪用户上次在应用程序中执行某些操作的情况，因此如果此信息已过期，则非常糟糕。速度和易用性很重要。我不希望写入Map以影响响应时间。

Java是否有现成的时钟同步解决方案？: 我们有一个大型高性能软件系统，它由多个交互式Java进程（而不是EJB）组成。每个进程可以在同一台机器上，也可以在不同的机器上。某些事件在一个进程中生成，然后以不同的方式传播到其他进程以进行进一步处理，依此类推。出于基准测试的目的，我们需要创建一个日志，记录每个事件何时通过“检查点”，最终将这些日志组合起来，以获得每个事件如何通过系统传播的时间线以及延迟（当然，流程切换和IPC添加延迟，这没关系。当然，问题是时钟同步。所以这是我的问题： 1）如果所有进程都在同一台机器上，是否保证currentTimeMilis在通话时是准确的？ ITP的错误是否存在一定的约束？ 2）如果某些进程可能在不同的机器上，那么是否存在用于时钟同步的现成解决方案（也是免费或开源的）？我最好寻找可以绕过操作系统（Windows或Linux）并直接从Java工作的解决方案。我也非常理想地寻找能够以微秒精度运行的东西。我考虑过NTP，但我不确定它是否可以通过Java而不是通过操作系统获得，而且我不确定它的复杂性。 3）有没有办法确定在特定配置（或我最终使用的任何解决方案）中使用NTP的误差范围，以便我可以在计算延迟时给出误差范围？谢谢！

Java Hadoop：我如何创建捕获器作为输入文件并提供输出，即每个文件中的行数？: 我是Hadoop的新手，我已经设法运行wordCount示例： http ：//hadoop.apache.org/common/docs/r0.18.2/mapred_tutorial.html 假设我们有一个包含3个文件的文件夹。我希望每个文件都有一个映射器，这个映射器只计算行数并将其返回到reducer。然后，reducer将输入每个映射器的行数作为输入，并将所有3个文件中存在的行总数作为输出。所以，如果我们有以下3个文件 input1.txt input2.txt input3.txt 并且映射器返回： mapper1 -> [input1.txt, 3] mapper2 -> [input2.txt, 4] mapper3 -> [input3.txt, 9] 减速器将输出 3+4+9 = 16 我在一个简单的java应用程序中完成了这个，所以我想在Hadoop中完成它。我只有一台计算机，并希望尝试在伪分布式环境中运行。我怎样才能实现这个目标？我应该采取什么适当的措施？我的代码应该在apache的示例中看起来像那样吗？我将有两个静态类，一个用于mapper，一个用于reducer？或者我应该有3个类，每个映射器一个？如果你能指导我完成这个，我不知道如何做到这一点，我相信如果我设法编写一些代码来做这些东西，那么我将来能够编写更复杂的应用程序。谢谢！

在RMI中通过引用问题？: 有人可以告诉我，为什么这个RMI聊天应用程序无法正常工作，我的目标是通过远程对象或序列化对象实现客户端，服务器和逻辑之间的分离。 import javax.swing.*; import java.awt.event.*; import java.rmi.*; import java.rmi.server.*; public class ChatClient1 implements ICallback { JFrame frame = new JFrame(“Chat Client”); private JTextArea myText; private static JTextArea TAUinDispMsg; private JScrollPane myTextScroll; private JScrollPane TAUinDispMsgScroll; private String textString = “”; private boolean firstMessage = true; private static String name = null; private static final int HOR_SIZE […]

使用Hadoop分布式缓存时出现FileNotFoundException: 这次有人应该放心，我正在努力使用分布式的cahe来运行我的代码。我已经在hdfs上的文件，但当我运行此代码时： import java.awt.image.BufferedImage; import java.awt.image.DataBufferByte; import java.awt.image.Raster; import java.io.BufferedReader; import java.io.ByteArrayInputStream; import java.io.DataInputStream; import java.io.FileNotFoundException; import java.io.FileReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.URISyntaxException; import java.util.logging.Level; import java.util.logging.Logger; import javax.imageio.ImageIO; import org.apache.hadoop.filecache.*; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.*; import org.apache.hadoop.mapred.*; import java.lang.String; import java.lang.Runtime; import java.net.URI; import java.util.StringTokenizer; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; public class blur2 […]