Windows Server（1.1）上使用Java和AMQP 1.0的服务总线消息大小问题

Question

我们使用下面的AMQP JAR将消息从java发送到windows server（1.1）上service bus中的队列设置。发送小消息时没有问题，但无法发送pre-prod中大小超过45kb、prod中大小超过160kb的消息。消息根本没有进入队列，java端也没有异常。

geronimo-jms\u 1.1\u spec-1.0.1。jar qpid-amqp-1-0-client-0.22。jar qpid-amqp-1-0-client-jms-0.22。jar qpid-amqp-1-0-common-0.22。罐子

接收到的消息在网关配置中正确配置。

我只是想知道是什么导致了邮件大小的限制？任何帮助都将不胜感激。

谢谢你，斯里。

Answer 1

我有同样的问题。无法发送大于256kb的消息。出错链接已分离。

问题在于服务总线的配置。默认情况下，SB不允许大于256kb的消息。我们不得不更改配置以允许更大的消息。

Answer 2

这是我编写的发送一条消息（109 kb）的小测试程序。我在java端没有收到任何异常，而且消息也没有出现在服务总线队列中。

import org.apache.qpid.amqp_1_0.jms.impl.*;
import javax.jms.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import java.net.URLEncoder;
import java.util.Hashtable;
import java.io.*;

public class ServiceBusPublisher {

public static void main(String[] args) throws Exception {               
    String userName = "test";
    String password = "test";       
    String fqdn = "[e-mail]";

    String connectionString = "amqps://" + encode(userName) + ":" + encode(password) + "@" + fqdn;


        File file = new File("D:\\temp\\test.xml");
    FileReader fileReader = new FileReader(file);
    BufferedReader bufferedReader = new BufferedReader(fileReader);
    StringBuffer stringBuffer = new StringBuffer();
    String line;
    while ((line = bufferedReader.readLine()) != null) {
        stringBuffer.append(line);
        stringBuffer.append("\n");
    }
    bufferedReader.close();
    fileReader.close();

    String messageText = stringBuffer.toString();         

    System.out.print("Initial setup\n");
        Hashtable<String, String> env = new Hashtable<String, String>();
        env.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory");
        env.put(Context.PROVIDER_URL, "blah.txt");
        env.put("connectionfactory.ServiceBusConnectionFactory", connectionString);
        Context context = null;
        ConnectionFactory connectionFactory = null;
        Connection connection = null;
        try
        {
            System.out.print("Creating context\n");
            context = new InitialContext(env);
            System.out.print("Creating connection factory\n");
            connectionFactory = (ConnectionFactory)context.lookup("ServiceBusConnectionFactory");
            System.out.print("Creating connection\n");
            connection = connectionFactory.createConnection();
        }
        catch (Exception e)
        {
            System.out.print("Exception creating context/connection factory/connection\n");
            System.out.print(e.toString());
            return;
        }

        Session session = null;
        MessageProducer producer = null;
        try
        {
            System.out.print("Creating session\n");
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            System.out.print("Creating producer\n");
            producer = session.createProducer(QueueImpl.createQueue("MessageProcessingService-PRE/testqueue"));                                                        
        }
        catch (Exception e)
        {
            System.out.print("Exception creating session/producer\n");
            System.out.print(e.toString());
            return;
        }

        try
        {
            System.out.print("Creating message\n");
            BytesMessage message = session.createBytesMessage();                
            message.writeBytes(messageText.getBytes("UTF-8"));              
            message.setStringProperty("JMSXGroupID", "MessageProcessingService-PRE/testqueue");
            System.out.print("Sending\n");
            producer.send(message);             
        }
        catch (Exception e)
        {
            System.out.print("Exception creating message and sending\n");
            System.out.print(e.toString());
            return;
        }           

        try
        {
            System.out.print("Cleaning up\n");
            producer.close();
            session.close();
            connection.stop();
            connection.close();
        }
        catch (Exception e)
        {
            System.out.print("Exception closing producer and session\n");
            System.out.print(e.toString());
        }
}

public static String encode(String encodee)
    {
        String retval = "";
        try { retval = URLEncoder.encode(encodee, "UTF-8"); } catch (Exception e) { System.out.print("Encoding failed\n"); }
        return retval;
    }

}