在上节中介绍了通过jndi方式连接到hornetq服务器上，有时候由于某些原因，我们不希望通过jndi方式连接，hornetq也支持这种方式进行

以第2章节的例子为模板，我们编写了另一个获取ConnectionFactory的方法createConnection

 

package com.crazycoder2010.hornetq;import java.util.HashMap;import java.util.Properties;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageConsumer;import javax.jms.MessageProducer;import javax.jms.Session;import javax.jms.TextMessage;import javax.naming.InitialContext;import javax.naming.NamingException;import org.hornetq.api.core.TransportConfiguration;import org.hornetq.api.jms.HornetQJMSClient;import org.hornetq.api.jms.JMSFactoryType;import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory;import org.hornetq.core.remoting.impl.netty.TransportConstants;/** * Hello world! *  */public class App4 {	public static void main(String[] args) throws Exception {		Connection connection = null;		try{			connection = createConnection();			//connection = createConnectionWithJNDI();			Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);			MessageProducer messageProducer = session.createProducer(HornetQJMSClient.createQueue("exampleQueue"));			TextMessage message = session.createTextMessage("Kevin Test01");			System.out.println("Sent message: " + message.getText());			messageProducer.send(message);						MessageConsumer consumer = session.createConsumer(HornetQJMSClient.createQueue("exampleQueue"));			connection.start();			Message received = consumer.receive(40);			System.out.println("received:"+received);		}finally{			releaseConnection(connection);		}	}	private static void releaseConnection(Connection connection)			throws JMSException {		if(connection != null){			connection.close();		}	}	private static Connection createConnection() throws JMSException {		HashMap
    
      map = new HashMap
     
      ();		map.put(TransportConstants.HOST_PROP_NAME, "192.168.1.103");		map.put(TransportConstants.PORT_PROP_NAME, 5445);		TransportConfiguration server = new TransportConfiguration(NettyConnectorFactory.class.getName(), map);		ConnectionFactory connectionFactory = (ConnectionFactory)HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF,server);		Connection connection = connectionFactory.createConnection();		return connection;	}		private static Connection createConnectionWithJNDI() throws NamingException, JMSException{		Properties properties = new Properties();		properties.put("java.naming.factory.initial",				"org.jnp.interfaces.NamingContextFactory");		properties.put("java.naming.factory.url.pkgs",				"org.jboss.naming:org.jnp.interfaces");		properties.put("java.naming.provider.url", "jnp://192.168.1.103:1099");		InitialContext initialContext = new InitialContext(properties);		ConnectionFactory connectionFactory = (ConnectionFactory) initialContext				.lookup("/ConnectionFactory");		Connection connection = connectionFactory.createConnection();		return connection;	}}
     
    

在如上的代码示例中，我们使用了hornetq客户端提供的一个静态工厂类来创建连接，要设置hornetq的连接地址和端口，这里我们使用默认的5445,这个例子只是在单机本地运行，因此调用HornetQJMSClient的xxxWithoutHA方法来执行，表示我们的连接不许要HA功能