java之間的跨源通信（JAVA跨平台的原理）

本文目錄一覽：

• 1、java 進程間通訊的有幾種方法？
• 2、如何實現兩個java程序之間的相互通訊，不想用Socket
• 3、兩個Java項目之間如何通信

java 進程間通訊的有幾種方法？

進程間通信的方法主要有以下幾種：

  （1）管道（Pipe）：管道可用於具有親緣關係進程間的通信，允許一個進程和另一個與它有共同祖先的進程之間進行通信。

  （2）命名管道（named pipe）：命名管道克服了管道沒有名字的限制，因此，除具有管道所具有的功能外，它還允許無親緣關 系 進程間的通信。命名管道在文件系統中有對應的文件名。命名管道通過命令mkfifo或系統調用mkfifo來創建。

  （3）信號（Signal）：信號是比較複雜的通信方式，用於通知接受進程有某種事件發生，除了用於進程間通信外，進程還可以發送 信號給進程本身；linux除了支持Unix早期信號語義函數sigal外，還支持語義符合Posix.1標準的信號函數sigaction（實際上，該函數是基於BSD的，BSD為了實現可靠信號機制，又能夠統一對外接口，用sigaction函數重新實現了signal函數）。

（4）消息（Message）隊列：消息隊列是消息的鏈接表，包括Posix消息隊列system V消息隊列。有足夠權限的進程可以向隊列中添加消息，被賦予讀權限的進程則可以讀走隊列中的消息。消息隊列克服了信號承載信息量少，管道只能承載無格式位元組流以及緩衝區大小受限等缺

  （5）共享內存：使得多個進程可以訪問同一塊內存空間，是最快的可用IPC形式。是針對其他通信機制運行效率較低而設計的。往往與其它通信機制，如信號量結合使用，來達到進程間的同步及互斥。

  （6）內存映射（mapped memory）：內存映射允許任何多個進程間通信，每一個使用該機制的進程通過把一個共享的文件映射到自己的進程地址空間來實現它。

  （7）信號量（semaphore）：主要作為進程間以及同一進程不同線程之間的同步手段。

  （8）套接口（Socket）：更為一般的進程間通信機制，可用於不同機器之間的進程間通信。起初是由Unix系統的BSD分支開發出來的，但現在一般可以移植到其它類Unix系統上：Linux和System V的變種都支持套接字。

而在java中我們實現多線程間通信則主要採用”共享變量”和”管道流”這兩種方法

方法一 通過訪問共享變量的方式(注:需要處理同步問題)

方法二 通過管道流

其中方法一有兩種實現方法,即

方法一a)通過內部類實現線程的共享變量

代碼如下:

public class Innersharethread {

public static void main(String[] args) {

Mythread mythread = new Mythread();

mythread.getThread().start();

mythread.getThread().start();

mythread.getThread().start();

mythread.getThread().start();

}

}

class Mythread {

int index = 0;

private class InnerThread extends Thread {

public synchronized void run() {

while (true) {

System.out.println(Thread.currentThread().getName()

+ “is running and index is ” + index++);

}

}

}

public Thread getThread() {

return new InnerThread();

}

}

/**

* 通過內部類實現線程的共享變量

*

*/

public class Innersharethread {

public static void main(String[] args) {

Mythread mythread = new Mythread();

mythread.getThread().start();

mythread.getThread().start();

mythread.getThread().start();

mythread.getThread().start();

}

}

class Mythread {

int index = 0;

private class InnerThread extends Thread {

public synchronized void run() {

while (true) {

System.out.println(Thread.currentThread().getName()

+ “is running and index is ” + index++);

}

}

}

public Thread getThread() {

return new InnerThread();

}

}

b)通過實現Runnable接口實現線程的共享變量

代碼如下：

public class Interfacaesharethread {

public static void main(String[] args) {

Mythread mythread = new Mythread();

new Thread(mythread).start();

new Thread(mythread).start();

new Thread(mythread).start();

new Thread(mythread).start();

}

}

/* 實現Runnable接口 */

class Mythread implements Runnable {

int index = 0;

public synchronized void run() {

while (true)

System.out.println(Thread.currentThread().getName() + “is running and

the index is ” + index++);

}

}

/**

* 通過實現Runnable接口實現線程的共享變量

*/

public class Interfacaesharethread {

public static void main(String[] args) {

Mythread mythread = new Mythread();

new Thread(mythread).start();

new Thread(mythread).start();

new Thread(mythread).start();

new Thread(mythread).start();

}

}

/* 實現Runnable接口 */

class Mythread implements Runnable {

int index = 0;

public synchronized void run() {

while (true)

System.out.println(Thread.currentThread().getName() + “is running and

the index is ” + index++);

}

}

方法二(通過管道流）:

代碼如下：

public class CommunicateWhitPiping {

public static void main(String[] args) {

/**

* 創建管道輸出流

*/

PipedOutputStream pos = new PipedOutputStream();

/**

* 創建管道輸入流

*/

PipedInputStream pis = new PipedInputStream();

try {

/**

* 將管道輸入流與輸出流連接 此過程也可通過重載的構造函數來實現

*/

pos.connect(pis);

} catch (IOException e) {

e.printStackTrace();

}

/**

* 創建生產者線程

*/

Producer p = new Producer(pos);

/**

* 創建消費者線程

*/

Consumer c = new Consumer(pis);

/**

* 啟動線程

*/

p.start();

c.start();

}

}

/**

* 生產者線程(與一個管道輸入流相關聯)

*

*/

class Producer extends Thread {

private PipedOutputStream pos;

public Producer(PipedOutputStream pos) {

this.pos = pos;

}

public void run() {

int i = 8;

try {

pos.write(i);

} catch (IOException e) {

e.printStackTrace();

}

}

}

/**

* 消費者線程(與一個管道輸入流相關聯)

*

*/

class Consumer extends Thread {

private PipedInputStream pis;

public Consumer(PipedInputStream pis) {

this.pis = pis;

}

public void run() {

try {

System.out.println(pis.read());

} catch (IOException e) {

e.printStackTrace();

}

}

}

如何實現兩個java程序之間的相互通訊，不想用Socket

不用也可以。

通訊就是對數據進行交換，數據可以保存在硬盤上。

設置硬盤上的文件為數據溝通的橋樑就可以實現不用Socket進行兩個程序間的通訊了(同一主機上)。

更具體一點的實現可以是：

兩個程序間要進行通訊(a、b)，設置兩個文件夾(d://a、d://b)，程序a將要發送的消息通過文件的方式放在文件夾a中，b程序的消息放b文件夾，每一個消息都是一個單獨的文件，文件名用當前時間命名。

a程序中監控b文件夾中的文件數量，每當文件數量增加便讀取新文件所包涵的信息，當文件夾中的文件數量超過10就清空一次文件，防止無用數據一直佔著存儲空間，b程序和a程序基本一致，只不過監控的文件夾換成了文件夾a。

如果真有這方面的需求，需要用這種方式實現，先做個框架會方便很多。

兩個Java項目之間如何通信

主要有以下方式：

1、RPC（遠程過程調用）；

2、webservice接口；

3、http接口，RESTful風格接口實現很優雅；

4、消息中間件，apache kafka、rabbitmq等。

這幾種方式中推薦使用http接口和消息中間件，rpc代碼耦合性太強，webservice過於重量級，http和消息中間件是最近比較流行的。