Discussoes de Programacao e Tecnologia

Configurar Host de uma fila JMS no Glassfish?

9 respostas
J
javanotucupi

Configurar Host de uma fila JMS no Glassfish?

Pessoal, estou começando a olhar JMS agora e estou utilizando o servidor que já com o Glassfish 3, embutido no NetBeans 6.9

Consegui configurar uma fila localmente, enviar/receber mensagens dessa fila.

A minha dúvida é como faço para acessar uma fila que esteja em outro servidor, em outro HOST.

PS: Eu encontrei dentro da pagina web de configuração do Glassfish o item Configuração -> Java Message Sevice -> Hosts JMS como criar um novo HOST JMS. E tb encontrei onde modificar o HOST DEFAULT do Glassfish. Mas eu queria saber onde posso setar esse host pra cada fila configurada. :?

Obrigado.

Alura Desenvolvimento Back-End Java Sua Carreira em desenvolvimento back-end Java: dos fundamentos à arquitetura de sistemas...

9 Respostas

R
romarcio

Isso não seria feito no código?

Pelo que sei de JMS no servidor vc cria a fila, mas a aplicação que vai enviar ou ler alguma coisa da fila deve ter o IP da máquina que possui o servidor, no seu caso o GlassFish.

Posta o seu código, o que faz o acesso a fila, vamos ver como vc está configurando.

J
javanotucupi

Segui um tutorial de uma revista Java pra fazer essas classes, mas no tutorial a fila é local.
Gostaria de saber onde mudaria se essa fila estivesse em outro servidor, separado do envio/recepção.

Obrigado pela ajuda.

classe de envio de mensagem JMS (Managed Bean JSF)

@Named(value="JMSBean")
@Dependent
public class JMSBean {

    @Resource(name="jms/CF")
    ConnectionFactory qcf;
    
    @Resource(name="jms/Quotes")
    Destination dest;

    static int counter;

  public void send () throws JMSException {
    Connection conn = null;
    try {
      conn = qcf.createConnection();
      Session session = conn.createSession(true,
      Session.AUTO_ACKNOWLEDGE);
      MessageProducer  prod = session.createProducer(dest);
      TextMessage msg = session.createTextMessage
      ("^BVSP = $" + (counter++));
      prod.send(msg);
    }
    finally {
      if (conn != null) conn.close();
    }
  }
}

classe de recepção de mensagens JMS (Message-Driven Bean)

@MessageDriven(mappedName = "jms/Quotes", activationConfig =  {
        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
    })
public class QuotesConsumerBean implements MessageListener {

    private static BlockingQueue<String> msgsRecebidas = new LinkedBlockingQueue<String>();

    
    public QuotesConsumerBean() {
    }

    public void onMessage(Message message) {
        try {
          TextMessage msg = (TextMessage)message;
          msgsRecebidas.offer(msg.getText());
          System.out.println(msg.getText());
        } catch (final JMSException e) {
          System.out.println("Deu pau! - " + e);
        }
    }

    @Named(value="QuotesConsumerBean")
    @Dependent
    public static class Reader {
        public static String next () throws
        InterruptedException {
          return msgsRecebidas.poll();
        }
    }
}
R
romarcio

Nunca usei JMS com GlassFish e nem com anotações, costuma utilizar com JBoss 4.2.3-GA.

Mas pelo que entendi, vc está fazendo uma aplicação que já está rodando dentro do GlassFlish, por isso não foi preciso setar IP e Porta de acesso no código.

Eu costumo fazer assim:

InitialContext initialContext = null; Properties properties = new Properties(); properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory"); //teria que ver qual URL_PKG_PREFIXES usar para o glassfish properties.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces"); properties.put(Context.PROVIDER_URL, "jnp://" + "172. 16.1.8" + ":" + "1099"); initialContext = new InitialContext(properties);

Tenta inserir esse código no seu código, mas dai tem que saber qual é a porta do GlassFish que está reservada para as filas.

Mas seria só um teste, não posso garantir que vai funcionar no GlassFish.

Ou talvez tenha alguma anotação para isso, ou mesmo alguma propriedade na anotação @Resource para setar o Ip.

J
javanotucupi

Alguém aí que já tenha feito isso com Glassfish?
Realmente não sei como fazer isso.

Se eu tiver um servidor de fila em um IP 127.0.0.5, onde configuro esse ip. Acredito que seja dentro do glassfish, só não sei onde.

J
javanotucupi

Pra deixar mais claro a minha dúvida.

Gostaria de saber como fazer se a minha fila JMS estiver em um outro servidor.
O que eu preciso configurar e onde?
Seria no GlassFish ou na classe utilizando alguma annotation?

Agradeço muito a quem puder me ajudar.

Obrigado.

J
javanotucupi

Consegui enviar a mensagem para um topico Glassfish que está um servidor diferente da aplicação que está enviando a JMS.

Agora só falta descobrir como configurar o Message-Driven Bean para consumir esse topico.

Alguem tem alguma sugestão? :lol:

PS: O MSB está em um outro servidor, diferente de onde está o Topico.

J
javanotucupi

Utilizando o código abaixo eu consegui enviar para a fila local(usando o “localhost”), mas qdo altero “localhost” para o número do ip, a aplicação fica parada tentando conectar, e depois dá uma exceção, tb postei a excessão abaixo do codigo.

Uma duvida, eu preciso configurar alguma coisa na Escuta do IIOP no servidor glassfish 10.73.3.152???

Obrigado. :slight_smile:

Properties props = new Properties();        
        props.setProperty("org.omg.CORBA.ORBInitialHost", "iiop://10.73.3.152");
        //props.setProperty("org.omg.CORBA.ORBInitialHost", "localhost");
        props.setProperty("org.omg.CORBA.ORBInitialPort", "3700");

        try {
            System.out.println("INICIA CONTEXTO");
            jndiContext = new InitialContext(props);

            System.out.println("CONEXAO");
            connectionFactory = (ConnectionFactory)jndiContext.lookup("jms/FabricaConexoes");
            
            System.out.println("FILA");
            queue = (Queue)jndiContext.lookup("jms/FilaServidor");

            connection = connectionFactory.createConnection();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            // ---- Same sample with a queue ----
            messageProducer = session.createProducer(queue);
            //messageProducer = session.createProducer(topic);
            Quotes quote = new Quotes("^BVSP", new Date(), counter++, 0, 0, 0, (int)(Math.random() * 100));
            msg = session.createObjectMessage(quote);
            msg.setStringProperty("symbol", quote.symbol);
            msg.setFloatProperty("volume", quote.volume);

            messageProducer.send(msg);
            System.out.println("MENSAGEM ENVIADA PARA A QUEUE: " + quote);

            connection.close();

        } catch (NamingException e) {
            Logger.getLogger(JMSEnvio.class.getName()).log(Level.SEVERE, null, e);
        }
        catch (JMSException e) {
            Logger.getLogger(JMSEnvio.class.getName()).log(Level.SEVERE, null, e);
        }
        finally {
            System.out.println("ENDED.");
            //System.out.println("PROVIDER_URL: " + properties.get(Context.PROVIDER_URL));
            if (connection != null) connection.close();
        }

INFO: INICIA CONTEXTO

INFO: CONEXAO

GRAVE: org.omg.CORBA.COMM_FAILURE:   vmcid: SUN  minor code: 201  completed: No

at com.sun.corba.ee.impl.logging.ORBUtilSystemException.connectFailure(ORBUtilSystemException.java:3431)

at com.sun.corba.ee.impl.logging.ORBUtilSystemException.connectFailure(ORBUtilSystemException.java:3452)

at com.sun.corba.ee.impl.transport.SocketOrChannelConnectionImpl.(SocketOrChannelConnectionImpl.java:256)

at com.sun.corba.ee.impl.transport.SocketOrChannelConnectionImpl.(SocketOrChannelConnectionImpl.java:269)

at com.sun.corba.ee.impl.transport.SocketOrChannelContactInfoImpl.createConnection(SocketOrChannelContactInfoImpl.java:125)

at com.sun.corba.ee.impl.protocol.CorbaClientRequestDispatcherImpl.beginRequest(CorbaClientRequestDispatcherImpl.java:188)

at com.sun.corba.ee.impl.protocol.CorbaClientDelegateImpl.request(CorbaClientDelegateImpl.java:186)

at com.sun.corba.ee.impl.protocol.CorbaClientDelegateImpl.is_a(CorbaClientDelegateImpl.java:352)

at org.omg.CORBA.portable.ObjectImpl._is_a(ObjectImpl.java:112)

at org.omg.CosNaming.NamingContextHelper.narrow(NamingContextHelper.java:69)

at com.sun.enterprise.naming.impl.SerialContext.narrowProvider(SerialContext.java:355)

at com.sun.enterprise.naming.impl.SerialContext.getRemoteProvider(SerialContext.java:327)

at com.sun.enterprise.naming.impl.SerialContext.getProvider(SerialContext.java:271)

at com.sun.enterprise.naming.impl.SerialContext.lookup(SerialContext.java:430)

at javax.naming.InitialContext.lookup(InitialContext.java:392)

at javax.naming.InitialContext.lookup(InitialContext.java:392)

at JMSEnvio.enviarMensagem(JMSEnvio.java:92)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)

at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)

at java.lang.reflect.Method.invoke(Method.java:597)

at javax.el.BeanELResolver.invokeMethod(BeanELResolver.java:737)

at javax.el.BeanELResolver.invoke(BeanELResolver.java:467)

at javax.el.CompositeELResolver.invoke(CompositeELResolver.java:246)

at com.sun.el.parser.AstValue.getValue(AstValue.java:111)

at com.sun.el.parser.AstValue.getValue(AstValue.java:163)

at com.sun.el.ValueExpressionImpl.getValue(ValueExpressionImpl.java:219)

at org.jboss.weld.el.WeldValueExpression.getValue(WeldValueExpression.java:71)

at com.sun.faces.facelets.el.ELText$ELTextVariable.toString(ELText.java:207)

at com.sun.faces.facelets.compiler.AttributeInstruction.write(AttributeInstruction.java:82)

at com.sun.faces.facelets.compiler.UIInstructions.encodeBegin(UIInstructions.java:75)

at com.sun.faces.facelets.compiler.UILeaf.encodeAll(UILeaf.java:176)

at javax.faces.component.UIComponent.encodeAll(UIComponent.java:1616)

at javax.faces.component.UIComponent.encodeAll(UIComponent.java:1616)

at com.sun.faces.application.view.FaceletViewHandlingStrategy.renderView(FaceletViewHandlingStrategy.java:380)

at com.sun.faces.application.view.MultiViewHandler.renderView(MultiViewHandler.java:126)

at javax.faces.application.ViewHandlerWrapper.renderView(ViewHandlerWrapper.java:273)

at com.sun.faces.lifecycle.RenderResponsePhase.execute(RenderResponsePhase.java:127)

at com.sun.faces.lifecycle.Phase.doPhase(Phase.java:101)

at com.sun.faces.lifecycle.LifecycleImpl.render(LifecycleImpl.java:139)

at javax.faces.webapp.FacesServlet.service(FacesServlet.java:313)

at org.apache.catalina.core.StandardWrapper.service(StandardWrapper.java:1523)

at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:279)

at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:188)

at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:641)

at com.sun.enterprise.web.WebPipeline.invoke(WebPipeline.java:97)

at com.sun.enterprise.web.PESessionLockingStandardPipeline.invoke(PESessionLockingStandardPipeline.java:85)

at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:185)

at org.apache.catalina.connector.CoyoteAdapter.doService(CoyoteAdapter.java:325)

at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:226)

at com.sun.enterprise.v3.services.impl.ContainerMapper.service(ContainerMapper.java:165)

at com.sun.grizzly.http.ProcessorTask.invokeAdapter(ProcessorTask.java:791)

at com.sun.grizzly.http.ProcessorTask.doProcess(ProcessorTask.java:693)

at com.sun.grizzly.http.ProcessorTask.process(ProcessorTask.java:954)

at com.sun.grizzly.http.DefaultProtocolFilter.execute(DefaultProtocolFilter.java:170)

at com.sun.grizzly.DefaultProtocolChain.executeProtocolFilter(DefaultProtocolChain.java:135)

at com.sun.grizzly.DefaultProtocolChain.execute(DefaultProtocolChain.java:102)

at com.sun.grizzly.DefaultProtocolChain.execute(DefaultProtocolChain.java:88)

at com.sun.grizzly.http.HttpProtocolChain.execute(HttpProtocolChain.java:76)

at com.sun.grizzly.ProtocolChainContextTask.doCall(ProtocolChainContextTask.java:53)

at com.sun.grizzly.SelectionKeyContextTask.call(SelectionKeyContextTask.java:57)

at com.sun.grizzly.ContextTask.run(ContextTask.java:69)

at com.sun.grizzly.util.AbstractThreadPool$Worker.doWork(AbstractThreadPool.java:330)

at com.sun.grizzly.util.AbstractThreadPool$Worker.run(AbstractThreadPool.java:309)

at java.lang.Thread.run(Thread.java:619)

Caused by: java.lang.RuntimeException: java.net.ConnectException: Connection refused: connect

at org.glassfish.enterprise.iiop.impl.IIOPSSLSocketFactory.createSocket(IIOPSSLSocketFactory.java:340)

at com.sun.corba.ee.impl.transport.SocketOrChannelConnectionImpl.(SocketOrChannelConnectionImpl.java:239)

… 62 more

Caused by: java.net.ConnectException: Connection refused: connect

at sun.nio.ch.Net.connect(Native Method)

at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:507)

at com.sun.corba.ee.impl.orbutil.ORBUtility.openSocketChannel(ORBUtility.java:106)

at org.glassfish.enterprise.iiop.impl.IIOPSSLSocketFactory.createSocket(IIOPSSLSocketFactory.java:325)

… 63 more
R
romarcio

props.setProperty("org.omg.CORBA.ORBInitialHost", "iiop://10.73.3.152"); //props.setProperty("org.omg.CORBA.ORBInitialHost", "localhost");

Quando usa localhost, vc não colocou o ‘iiop://’, tentou o ip sem esse ‘iiop://’?

Outra coisa, e pelo nome da maquina, ao invés do Ip, chegou a tentar?

J
javanotucupi

romarcio:
props.setProperty("org.omg.CORBA.ORBInitialHost", "iiop://10.73.3.152"); //props.setProperty("org.omg.CORBA.ORBInitialHost", "localhost");

Quando usa localhost, vc não colocou o ‘iiop://’, tentou o ip sem esse ‘iiop://’?

Outra coisa, e pelo nome da maquina, ao invés do Ip, chegou a tentar?

Tirei o ‘iiop://’ e tentei com IP e com o nome da maquina.
Nesses dois cenários o aplicativo envia a mensagem, mas a mensagem não chegou na maquina de destino.

O que eu percebi é que o glassfish LOCAL está recebendo essas mensagens e criando um DESTINO FÍSICO com o nome dessa Fila destino(FilaServidor).

PS: Se eu colocar um IP de uma maquina que nao possua servidor de fila, o aplicativo dá erro. Com isso, eu cheguei a conclusão que ele está reconhecendo o servidor que está nessa maquina 10.73.3.152. Só não entendi porque a mensagem que foi enviada, ficou armazenada neste DESTINO FISICO localmente.

Criado 4 de outubro de 2010
Ultima resposta 8 de out. de 2010
Respostas 9
Participantes 2

Topicos relacionados

Imagem em JPanel 34 respostas Fila (queue) 10 respostas Programação Orientada à Aspectos ---> AspectJ 10 respostas Árvore N-ária 4 respostas Matriz inversa (java) 7 respostas
Alura O que são algoritmos e lógica de programação e como aprender? Entenda o que são algoritmos e lógica de programação e qual é a importância desses conceitos para começar a programar
Casa do Codigo Desbravando SOLID: Praticas avancadas para codigos de... Por Alexandre Aquiles — Casa do Codigo