文件名称:mina:使用Apache MINA在Java中进行分布式并行计算
文件大小:2.91MB
文件格式:ZIP
更新时间:2024-05-18 00:37:48
Java
这使用Apache Mina库和Guava FutureCallbacks实现了分布式计算范例。 您可以启动通过TCP将工作分派到多个远程客户端的服务器。 您可以指定每个客户一次可以并行处理多少个工作单元。 如果客户去世,工作将自动重新排队。 此实现使用非阻塞I / O和线程池来最大化许多连接的性能。 我已经包含了一个100 DummyWorkUnits的测试。 这些只是等待几秒钟然后停止的作业。 作业编号6配置为在运行时引发异常。 要启动服务器,请运行编译脚本。 这将编译所有类并启动服务器。 然后,使用compile2脚本在其他计算机上的同一目录中启动客户端。 (或者,您可以在不同的位置拥有不同的回购副本。) 必须在Settings.SERVER_HOSTNAME中设置服务器的主机名。 这样,客户端就可以找到服务器。 可以在Server.NUMBER_OF_THREADS_MAP中设
【文件预览】:
mina-master
----compile3(315B)
----Settings.java(7KB)
----DummyResult.java(211B)
----Server.java(8KB)
----ResultEnvelope.java(2KB)
----WorkEnvelope.java(2KB)
----GeneralThreadService.java(7KB)
----WorkUnit.java(233B)
----log4j.properties(713B)
----compile(176B)
----compile2(51B)
----Singleton.java(88B)
----Result.java(98B)
----.gitignore(30B)
----lib()
--------guava-18.0.jar(2.15MB)
--------mina-core-2.0.9.jar(618KB)
--------log4j-1.2.17.jar(478KB)
--------slf4j-api-1.7.12.jar(31KB)
--------slf4j-log4j12-1.7.12.jar(9KB)
----README.md(1KB)
----WorkUnitDatabase.java(11KB)
----create_javadoc.sh(54B)
----Client.java(5KB)
----Immutable.java(103B)
----DummyWorkUnit.java(1KB)