分佈式環境中的中間件應用程序

我想開發一個應用程序，它將數據從一個應用程序傳輸到另一個應用程序。現在，我的一個應用程序是在.Net框架中，而另一個是在Spring框架（Java）中實現的。

哪種編程技術最適合這種環境？
是的！數據會很重，它會包含BLOB。此外，轉移期間有可能發生網絡中斷，因此，它必須是交易;因爲我當然不想丟失數據。

您如何看待XML over HTTP？

請建議我應該實施什麼樣的應用程序來傳輸數據。分佈式環境中的中間件應用程序

來源

2012-10-19 Femme Fatale

使用Java，JMS提供了一種將應用程序與提供數據的傳輸層分離的方法。通過使用所需提供者的JNDI信息，可以使用相同的Java類與不同的JMS提供者進行通信。這些類首先使用連接工廠連接到隊列或主題，然後使用填充和發送或發佈消息。在接收端，客戶端接收或訂閱消息。

我用SonicMQ messaging system和thier Java Message Services很穩定......你可以查看有關如何使用它here我一點樣品，有一個.Net implementation

編纂可以很簡單：

/** 
* 
* This file is part of Jms.publisher sample. 
* 
* Jms.publisher is free software: you can redistribute it and/or modify 
* it under the terms of the GNU General Public License as published by 
* the Free Software Foundation, either version 3 of the License, or 
* (at your option) any later version. 
* 
* Jms.publisher is distributed in the hope that it will be useful, 
* but WITHOUT ANY WARRANTY; without even the implied warranty of 
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 
* GNU General Public License for more details. 
* 
* You should have received a copy of the GNU General Public License 
* along with Jms.publisher. If not, see <http://www.gnu.org/licenses/>. 
* 
* 
* AccessManager.Java 
* Create by Iván Jaimes on 03/09/2012 
* 
*/ 
package sonic; 

import javax.jms.JMSException; 
import javax.jms.Session; 
import javax.jms.TextMessage; 
import javax.jms.TopicConnection; 
import javax.jms.TopicPublisher; 
import javax.jms.TopicSession; 
import javax.jms.TopicConnectionFactory; 

import config.ConnectionInfo; 

public class AccessManager 
{ 
    private TopicConnection connection = null; 
    private TopicSession session = null; 
    private TopicPublisher topicPublisher = null;  
    private TopicConnectionFactory connectionFactory = null; 
    private ConnectionInfo info = null; 

    public AccessManager(ConnectionInfo connectionInfo) throws JMSException 
    { 
     info = connectionInfo; 
    } 

    public final void connect() throws JMSException 
    { 
     connectionFactory = new progress.message.jclient.TopicConnectionFactory(info.getSonicAddress()); 
     connection = connectionFactory.createTopicConnection(info.getUserName(), info.getPassword()); 
     connection.start(); 
     session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); 
     topicPublisher = session.createPublisher(info.getTopic()); 
     assert (isConnected()); 
    } 

    public void send(String text) throws JMSException 
    { 
     TextMessage message = session.createTextMessage(text); // send method 
     topicPublisher.publish(message); 
    } 
    /** 
    * Disconnect. 
    * @throws JMSException 
    */ 
    public final void disconnect() throws JMSException 
    { 
     if (topicPublisher != null) 
     { 
      topicPublisher.close(); 
      session.close(); 
      connection.close(); 
     } 

     connection = null; 
     session = null; 
    } 

    /** 
    * Checks if is connected. 
    * 
    * @return true, if is connected 
    */ 
    public final boolean isConnected() { 
     if (session != null) { 
      return true; 
     } 
     return false; 
    } 
}

有更多的資源看：

來源

2012-10-19 22:31:40 Iver

分佈式環境中的中間件應用程序

回答

相關問題