正文
java远程通信源代码 java远程通信及应用的研究
提示：扫一扫查出行【扫一扫了解最新限行尾号】
复制提示
JAVA程序在广域网上如何实现通信
一般可以使用socket或者RMI编程进行通信，推荐使用RMI，因为比较简单，给你看看rmi通信的例子
1.接口Hello代码
======================================================================
import java.rmi.*;
public interface Hello extends Remote {
public String sayHello(String s) throws RemoteException;
}
2.实现类HelloImpl代码
======================================================================
import java.rmi.*;
import java.rmi.server.*;
public class HelloImpl extends UnicastRemoteObject implements Hello {
public HelloImpl() throws RemoteException{}
public String sayHello(String s) throws RemoteException {
return "Echo:"+s;
}
}
3.服务器类RMIServer代码
======================================================================
import java.rmi.*;
class RMIServer {
public static void main (String []args) throws Exception {
HelloImpl hi=new HelloImpl();
Naming.rebind("hello",hi);
}
}
4.客户端类RMIClient代码
======================================================================
import java.rmi.*;
class RMIClient {
public static void main (String []args) throws Exception {
Hello h=(Hello)Naming.lookup("hello");
System.out.println(h.sayHello("Hello World!"));
}
}
5.编译
======================================================================
javac *.java 编译所有.java文件
rmic HelloImpl 产生stub,Skeleton文件,Stub是远程对象的客户端代理
是远程对象的服务器代理
6.运行
======================================================================
打开一个dos窗口,输入rmiregistry
打开另一个dos窗口,输入java RMIServer,启动服务器
打开最后一个dos窗口,输入java RMIClient,启动客户端
又可以看见Hello World了
相关问答
Q1: java中telnet到远程服务器,然后执行cmd命令，求代码，谢谢了
package place.in.javaeye;
import java.io.InputStream;
import java.io.PrintStream;
import org.apache.commons.net.telnet.TelnetClient;
public class Shell
{
private TelnetClient telnet = new TelnetClient();
private InputStream in;
private PrintStream out;
private char prompt = '$';// 普通用户结束
public Shell(String ip, int port, String user, String password)
{
try
{
telnet.connect(ip, port);
in = telnet.getInputStream();
out = new PrintStream(telnet.getOutputStream());
// 根据root用户设置结束符
this.prompt = user.equals("root") ? '#' : '';
login(user, password);
}
catch (Exception e)
{
e.printStackTrace();
}
}
/**
* 登录
*
* @param user
* @param password
*/
public void login(String user, String password)
{
// readUntil("login:");
readUntil("login:");
write(user);
readUntil("Password:");
write(password);
readUntil(prompt + "");
}
/**
* 读取分析结果
*
* @param pattern
* @return
*/
public String readUntil(String pattern)
{
try
{
char lastChar = pattern.charAt(pattern.length() - 1);
StringBuffer sb = new StringBuffer();
char ch = (char)in.read();
while (true)
{
sb.append(ch);
if (ch == lastChar)
{
if (sb.toString().endsWith(pattern))
{
return sb.toString();
}
}
ch = (char)in.read();
System.out.print(ch);
}
}
catch (Exception e)
{
e.printStackTrace();
}
return null;
}
/**
* 写操作
*
* @param value
*/
public void write(String value)
{
try
{
out.println(value);
out.flush();
}
catch (Exception e)
{
e.printStackTrace();
}
}
/**
* 向目标发送命令字符串
*
* @param command
* @return
*/
public String sendCommand(String command)
{
try
{
write(command);
return readUntil(prompt + "");
}
catch (Exception e)
{
e.printStackTrace();
}
return null;
}
/**
* 关闭连接
*/
public void disconnect()
{
try
{
telnet.disconnect();
}
catch (Exception e)
{
e.printStackTrace();
}
}
public static void main(String[] args) {
TelnetClient telnet = new TelnetClient();
try {
Shell she =new Shell("10.**.***.***", 23, "***", "***");
System.out.println(she);
System.out.println(she.sendCommand("ls"));
she.disconnect();
}catch (Exception e) {
// TODO: handle exception
}
}
}
Q2: 谁有java本地监听与远程端口扫描 源程序
本地端口监听
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class SocketServer
{
private ServerSocket serverSocket;
private ExecutorService executorService;// 线程池
private final int POOL_SIZE = 600;// 单个CPU线程池大小
public SocketServer() throws IOException
{
serverSocket = new ServerSocket(9888);//监听的端口号
// Runtime的availableProcessor()方法返回当前系统的CPU数目.
executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * POOL_SIZE);
System.out.println("服务器启动");
}
public void service()
{
while (true)
{
Socket socket = null;
try
{
// 接收客户连接,只要客户进行了连接,就会触发accept();从而建立连接
socket = serverSocket.accept();
executorService.execute(new Handlers(socket));
//这里就是放业务逻辑的地方例如获取数据等等
} catch (Exception e)
{
e.printStackTrace();
System.out.println("socket Exception:" + e);
}
}
}
public static void main(String[] args) throws IOException
{
//Thread thread = new Thread(new PringtThread());
//thread.start();
new SocketServer().service();
}
}
端口扫描代码
import java.io.IOException;
import java.net.Socket;
public class SearchPort implements Runnable
{
public static void main(String[] args)
{
SearchPort searchPort = new SearchPort();
Thread thread = new Thread(searchPort);
thread.start();
}
@Override
public void run()
{
searchPort("192.168.1.2", 0, 9999);
}
public void searchPort(String ip,int begin, int end) {
// 1-65535
Socket s = null;
for (int i = begin; i end; i++) {
boolean flag = false;
try {
s = new Socket(ip, i);
flag = s.isConnected();
} catch (IOException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
}
if (flag) {
System.out.println("port " + i + " is open");
try {
s.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} else {
// System.out.println("port " + i + " is close");
}
}
//System.out.println("seach port ：" + begin + " to " + end + " ok..");
}
}
第一个端口监听的采用了线程池的技术，当大数据来的时候也不怕（某大型企业的部分源码），第二个例子是端口扫描器，采用了多线程扫描，代码直接复制就可以用的，从10点50分打代码11点半，不容易，望楼主采纳，有什么问题可以问我
Q3: Java Rmi如何实现两个客户端之间的通信 求说的具体点
RMI的开发步骤
先创建远程接口及声明远程方法，注意这是实现双方通讯的接口，需要继承Remote
开发一个类来实现远程接口及远程方法，值得注意的是实现类需要继承UnicastRemoteObject
通过javac命令编译文件，通过java -server 命令注册服务，启动远程对象
最后客户端查找远程对象，并调用远程方法
首先为服务建立一个Model层，注意因为此对象需要现实进行远程传输，所以必须继承Serializable
代码
package rmi.model;
import java.io.Serializable;
//注意对象必须继承Serializable
publicclass PersonEntity implements Serializable {
privateint id;
private String name;
privateint age;
publicvoid setId(int id) {
this.id = id;
}
publicint getId() {
return id;
}
publicvoid setName(String name) {
this.name = name;
}
public String getName() {
return name;
}
publicvoid setAge(int age) {
this.age = age;
}
publicint getAge() {
return age;
}
}
创建远程接口PersonService,注意远程接口需要继承Remote
代码
package rmi.service;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.util.List;
import rmi.model.*;
//此为远程对象调用的接口，必须继承Remote类
publicinterface PersonService extends Remote {
public ListPersonEntity GetList() throws RemoteException;
}
建立PersonServiceImpl实现远程接口，注意此为远程对象实现类，需要继承UnicastRemoteObject
代码
package rmi.serviceImpl;
import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
import java.util.LinkedList;
import java.util.List;
import rmi.model.PersonEntity;
import rmi.service.*;
//此为远程对象的实现类，须继承UnicastRemoteObject
publicclass PersonServiceImpl extends UnicastRemoteObject implements PersonService {
public PersonServiceImpl() throws RemoteException {
super();
// TODO Auto-generated constructor stub
}
@Override
public ListPersonEntity GetList() throws RemoteException {
// TODO Auto-generated method stub
System.out.println("Get Person Start!");
ListPersonEntity personList=new LinkedListPersonEntity();
PersonEntity person1=new PersonEntity();
person1.setAge(25);
person1.setId(0);
person1.setName("Leslie");
personList.add(person1);
PersonEntity person2=new PersonEntity();
person2.setAge(25);
person2.setId(1);
person2.setName("Rose");
personList.add(person2);
return personList;
}
}
建立服务器端，在服务器端注册RMI通讯端口与通讯路径，然后通讯javac命令编译文件，通过java -server 命令注册服务。以下面代码为例，如果阁下将项目建立于D:\\RMI\RemotingService文件夹上时，则先输入D:\\RMI\RemotingService\srcjavac rmi/remotingservice/Program.java获取Program.class（如何阁下使用的MyEclipse等开发工具，可跳过此步，直接在*/bin文件夹中直接调用已经生成的Program.class），然后输入D:\\RMI\RemotingService\srcjava rmi/remotingservice/Program启动服务。
代码
package rmi.remotingservice;
import java.rmi.Naming;
import java.rmi.registry.LocateRegistry;
import rmi.service.*;
import rmi.serviceImpl.*;
publicclass Program{
publicstaticvoid main(String[] args) {
try {
PersonService personService=new PersonServiceImpl();
//注册通讯端口
LocateRegistry.createRegistry(6600);
//注册通讯路径
Naming.rebind("rmi://127.0.0.1:6600/PersonService", personService);
System.out.println("Service Start!");
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
最后建立客户端进行测试，注意客户调用的RMI路径必须服务器配置一致
代码
package rmi.remotingclient;
import java.rmi.Naming;
import java.util.List;
import rmi.model.PersonEntity;
import rmi.service.*;
publicclass Program {
publicstaticvoid main(String[] args){
try{
//调用远程对象，注意RMI路径与接口必须与服务器配置一致
PersonService personService=(PersonService)Naming.lookup("rmi://127.0.0.1:6600/PersonService");
ListPersonEntity personList=personService.GetList();
for(PersonEntity person:personList){
System.out.println("ID:"+person.getId()+" Age:"+person.getAge()+" Name:"+person.getName());
}
}catch(Exception ex){
ex.printStackTrace();
}
}
}
常见错误
在命令提示符调用java命令时，显示并无此命令。这是因为未在“环境变量”中绑定JAVA的JDK命令造成的，你首先单击“计算机右键”-“属性”-“高级”-“环境变量”。在系统变量Path设置中加载为JDK的路径 .;D:\Program Files\Genuitec\Common\binary\com.sun.java.jdk.win32.x86_1.6.0.013\bin。然后在ClassPath加载服务器端的Program.class地址 .;D:\\RMI\RemotingService\bin
在调用javac命令时出现“javac 找不到文件 ..... ”此错误，可能是因为阁下输入的文件路径出现错误造成，注意不要把D:\\RMI\RemotingService\srcjavac rmi/remotingservice/Program.java写错为D:\\RMI\RemotingService\srcjavac rmi.remotingservice.Program.java
在调用D:\\RMI\RemotingService\binjava rmi/remotingservice/Program命令时出现“Exception in thread 'main' java.lang.NoClassEdfoundError”错误，第一这可能是阁下把Program错写为Program.class，注意java命令不需要加后缀名。第二可能是阁下把“java rmi/remotingservice/Program”错写为“java rmi\remotingservice\Program"。
Q4: 求段java代码，根据数据库中的IP和用户名密码，远程telnet到设备
直接给你java关于telnet的一个例子
public class Main { public static void main(String[] args) { try {
TelnetClient telnetClient = new TelnetClient("vt200"); //指明Telnet终端类型，否则会返回来的数据中文会乱码
telnetClient.setDefaultTimeout(5000); //socket延迟时间：5000ms
telnetClient.connect("127.0.0.1",23); //建立一个连接,默认端口是23
InputStream inputStream = telnetClient.getInputStream(); //读取命令的流
PrintStream pStream = new PrintStream(telnetClient.getOutputStream()); //写命令的流
byte[] b = new byte[1024]; int size;
StringBuffer sBuffer = new StringBuffer(300); while(true) { //读取Server返回来的数据，直到读到登陆标识，这个时候认为可以输入用户名
size = inputStream.read(b); if(-1 != size) {
sBuffer.append(new String(b,0,size)); if(sBuffer.toString().trim().endsWith("login:")) { break;
}
}
}
System.out.println(sBuffer.toString());
pStream.println("exit"); //写命令
pStream.flush(); //将命令发送到telnet Server
if(null != pStream) {
pStream.close();
}
telnetClient.disconnect();
} catch (SocketException e) { // TODO Auto-generated catch block e.printStackTrace();
} catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace();
}
}
}
Q5: JAVA 远程 调用的几种实现方式简析 详细�0�3
基本原理 要实现网络机器间的通讯，首先得来看看计算机系统网络通信的基本原理，在底层层面去看，网络通信需要做的就是将流从一台计算机传输到另外一台计算机，基于传输协议和网络 IO 来实现，其中传输协议比较出名的有 http、tcp、 udp 等等，http、tcp、udp 都是在基于Socket 概念上为某类应用场景而扩展出的传输协议，网络IO，主要有bio、nio、aio 三种方式，所有的分布式应用通讯都基于这个原理而实现，只是为了应用的易用，各种语言通常都会提供一些更为贴近应用易用的应用层协议。 应用级协议 远程服务通讯，需要达到的目标是在一台计算机发起请求，另外一台机器在接收到请求后进行相应的处理并将结果返回给请求端，这其中又会有诸如 onewayrequest、同步请求、异步请求等等请求方式，按照网络通信原理，需要实现这个需要做的就是将请求转换成流，通过传输协议传输至远端，远端计算机在接收到请求的流后进行处理，处理完毕后将结果转化为流，并通过传输协议返回给调用端。原理是这样的，但为了应用的方便，业界推出了很多基于此原理之上的应用级的协议，使得大家可以不用去直接操作这么底层的东西，通常应用级的远程通信协议会提供: 1.为了避免直接做流操作这么麻烦，提供一种更加易用或贴合语言的标准传输格式;2.网络通信机制的实现，就是替你完成了将传输格式转化为流，通过某种传输协议传输至远端计算机，远端计算机在接收到流后转化为传输格式，并进行存储或以某种方式通知远端计算机。 所以在学习应用级的远程通信协议时，我们可以带着这几个问题进行学习: 1.传输的标准格式是什么?2.怎么样将请求转化为传输的流?3.怎么接收和处理流?4.传输协议是? 不过应用级的远程通信协议并不会在传输协议上做什么多大的改进，主要是在流操作方面，让应用层生成流和处理流的这个过程更加的贴合所使用的语言或标准，至于传输协议则通常都是可选的，在java 领域中知名的有:RMI、 XML-RPC、Binary-RPC、SOAP、CORBA、JMS，来具体的看看这些远程通信的应用级协议: RMIRMI 是个典型的为java 定制的远程通信协议，我们都知道，在 singlevm 中，我们可以通过直接调用javaobjectinstance 来实现通信，那么在远程通信时，如果也能按照这种方式当然是最好了，这种远程通信的机制成为RPC(RemoteProcedureCall)，RMI 正是朝着这个目标而诞生的。 来看下基于RMI 的一次完整的远程通信过程的原理: 1.客户端发起请求，请求转交至RMI 客户端的stub 类;2.stub 类将请求的接口、方法、参数等信息进行序列化;3.基于socket 将序列化后的流传输至服务器端;4.服务器端接收到流后转发至相应的skelton 类;5.skelton 类将请求的信息反序列化后调用实际的处理类;6.处理类处理完毕后将结果返回给 skelton 类;7.Skelton 类将结果序列化，通过socket 将流传送给客户端的 stub;8.stub 在接收到流后反序列化，将反序列化后的JavaObject 返回给调用者。 根据原理来回答下之前学习应用级协议带着的几个问题: 1.传输的标准格式是什么?是JavaObjectStream。2.怎么样将请求转化为传输的流?基于Java 串行化机制将请求的javaobject 信息转化为流。3.怎么接收和处理流?根据采用的协议启动相应的监听端口，当有流进入后基于Java 串行化机制将流进行反序列化，并根据RMI 协议获取到相应的处理对象信息，进行调用并处理，处理完毕后的结果同样基于java 串行化机制进行返回。4.传输协议是?Socket。 XML-RPCXML-RPC 也是一种和RMI 类似的远程调用的协议，它和RMI 的不同之处在于它以标准的 xml 格式来定义请求的信息(请求的对象、方法、参数等)，这样的好处是什么呢，就是在跨语言通讯的时候也可以使用。 来看下XML-RPC 协议的一次远程通信过程: 1.客户端发起请求，按照XML-RPC 协议将请求信息进行填充;2.填充完毕后将xml 转化为流，通过传输协议进行传输;3.接收到在接收到流后转换为xml，按照XML-RPC 协议获取请求的信息并进行处理;4.处理完毕后将结果按照XML- RPC 协议写入xml 中并返回。 同样来回答问题: 1.传输的标准格式是?标准格式的XML。2.怎么样将请求转化为传输的流? 将XML 转化为流。3.怎么接收和处理流?通过监听的端口获取到请求的流，转化为XML，并根据协议获取请求的信息，进行处理并将结果写入XML 中返回。4. 传输协议是?Http。 Binary-RPCBinary-RPC 看名字就知道和XML-RPC 是差不多的了，不同之处仅在于传输的标准格式由XML 转为了二进制的格式。 同样来回答问题: 1.传输的标准格式是?标准格式的二进制文件。2.怎么样将请求转化为传输的流?将二进制格式文件转化为流。3.怎么接收和处理流?通过监听的端口获取到请求的流，转化为二进制文件，根据协议获取请求的信息，进行处理并将结果写入XML 中返回。4.传输协议是?Http。 SOAPSOAP 原意为SimpleObjectAccessProtocol，是一个用于分布式环境的、轻量级的、基于XML 进行信息交换的通信协议，可以认为SOAP 是XMLRPC 的高级版，两者的原理完全相同，都是http+XML，不同的仅在于两者定义的XML 规范不同，SOAP 也是Webservice 采用的服务调用协议标准，因此在此就不多加阐述了。 CORBACommonObjectRequestBrokerArchitecture(公用对象请求代理[调度]程序体系结构)，是一组用来定义"分布式对象系统"的标准，由 OMG(ObjectMenagementGroup)作为发起和标准制定单位。CORBA 的目的是定义一套协议，符合这个协议的对象可以互相交互，不论它们是用什么样的语言写的，不论它们运行于什么样的机器和操作系统。CORBA 在我看来是个类似于SOA 的体系架构，涵盖可选的远程通信协议，但其本身不能列入通信协议这里来讲，而且CORBA 基本淘汰，再加上对CORBA 也不怎么懂，在此就不进行阐述了。 JMSJMS 呢，是实现java 领域远程通信的一种手段和方法，基于JMS 实现远程通信时和RPC 是不同的，虽然可以做到RPC 的效果，但因为不是从协议级别定义的，因此我们不认为JMS 是个RPC 协议，但它确实是个远程通信协议，在其他的语言体系中也存在着类似JMS 的东西，可以统一的将这类机制称为消息机制，而消息机制呢，通常是高并发、分布式领域推荐的一种通信机制，这里的主要一个问题是容错(详细见ErLang 论文)。 来看JMS 中的一次远程通信的过程: 1.客户端将请求转化为符合JMS 规定的Message;2.通过JMSAPI 将Message 放入JMSQueue 或Topic 中;3.如为JMSQueue，则发送中相应的目标Queue 中，如为Topic，则发送给订阅了此Topic 的JMSQueue。4.处理端则通过轮训 JMSQueue，来获取消息，接收到消息后根据JMS 协议来解析Message 并处理。 回答问题: 1.传输的标准格式是?JMS 规定的Message。2.怎么样将请求转化为传输的流?将参数信息放入Message 中即可。3.怎么接收和处理流?轮训JMSQueue 来接收Message，接收到后进行处理，处理完毕后仍然是以Message 的方式放入 Queue 中发送或Multicast。4.传输协议是?不限。 基于JMS 也是常用的实现远程异步调用的方法之一。
java远程通信源代码的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于java远程通信及应用的研究、java远程通信源代码的信息别忘了在本站进行查找喔。
