如何在另一个客户端项目中调用 @Remote EJB

Question

我需要能够从这个简单的 swing java 应用程序调用 save() 方法到我的 Web 应用程序，该应用程序使用我用来保存新实体类型的 bean 在服务器上发布 class 角色，有姓名、地址、电子邮件。

我在我的服务器上使用 wildfly 8.x 并像这样发布我的网络应用程序：

23:51:10,641 INFO  [org.jboss.as.ejb3.deployment.processors.EjbJndiBindingsDeploymentUnitProcessor] (MSC service thread 1-3) JNDI bindings for session bean named ContactoDAO in deployment unit deployment "proyectobase.war" are as follows:

java:global/proyectobase/ContactoDAO!edu.ups.appdis.proyectobase.negocio.ContactoDAO
java:app/proyectobase/ContactoDAO!edu.ups.appdis.proyectobase.negocio.ContactoDAO
java:module/ContactoDAO!edu.ups.appdis.proyectobase.negocio.ContactoDAO
java:global/proyectobase/ContactoDAO
java:app/proyectobase/ContactoDAO
java:module/ContactoDAO

这是我的 ContactoDAO Bean：

package edu.ups.appdis.proyectobase.negocio;

import java.io.Serializable;
import java.util.List;

import javax.ejb.Remote;
import javax.ejb.Stateless;
import javax.inject.Inject;
import javax.persistence.EntityManager;
import javax.persistence.Query;

import edu.ups.appdis.proyectobase.modelo.Persona;

@Stateless
// @Remote(Serializable.class)
@Remote
public class ContactoDAO implements Serializable {

    // @Inject
    // private Logger log;

    /**
     * 
     */

    @Inject
    private EntityManager em;

    public void save(Persona persona) {
//      if (em.find(Persona.class, persona.getCodiog()) == null) {
            insertar(persona);
//      } else {
//
//          update(persona);
//      }
    }

    public void test() {
        System.out.println("si funciona ");
    }

    public void insertar(Persona persona) {
        em.persist(persona);

    }

    public void update(Persona persona) {
        em.merge(persona);

    }

    public void remove(int codigo) {   
        Persona persona = em.find(Persona.class, codigo);
        em.remove(persona);

    }

    public Persona read(int codigo) {
        System.out.println("insertado objeto persona");
        return em.find(Persona.class, codigo);
    }

    public List<Persona> getContactos() {
        String sql = "SELECT p FROM Persona p";
        Query query = em.createQuery(sql, Persona.class);
        List<Persona> personas = query.getResultList();

        return personas;
    }

}

在我的简单客户端 swing 应用程序中，我将其设置如下：

package cliente.gui;

import java.awt.EventQueue;
............
import javax.ejb.EJB;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import java.security.Security;
import java.util.Hashtable;

import edu.ups.appdis.proyectobase.modelo.Persona;
import edu.ups.appdis.proyectobase.negocio.*;

public class guiPersona {
//  @EJB(lookup = "java:global/proyectobase/ContactoDAO!edu.ups.appdis.proyectobase.negocio.ContactoDAO")
    @EJB(lookup = "java:global/proyectobase/ContactoDAO")
    ContactoDAO contactoDAO;
    private JFrame frame;
    private JTextField textNombre;
    private JTextField textDireccion;
    private JTextField textEmail;

    /**
     * Launch the application.
     */
    public static void main(String[] args) {
        EventQueue.invokeLater(new Runnable() {
            public void run() {
                try {
                    guiPersona window = new guiPersona();
                    window.frame.setVisible(true);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
    }

    /**
     * Create the application.
     * 
     * @throws NamingException
     */
    public guiPersona() {
        initialize();
    }



         ...........



JButton btnGuardar = new JButton("Guardar");
        btnGuardar.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {

                contactoDAO.test();

                if (textDireccion.getText() != "" && textEmail.getText() != "" && textNombre.getText() != "") {

                    Persona p = new Persona();

                    p.setNombre(textNombre.getText());
                    p.setDireccion(textDireccion.getText());
                    p.setEmail(textEmail.getText());

                    contactoDAO.save(p);

                    textNombre.setText("");
                    textDireccion.setText("");
                    textEmail.setText("");
                }

            }
        });

你可以在上面的代码中看到我用它来调用另一个项目中的我的 bean:

@EJB(lookup = "java:global/proyectobase/ContactoDAO")
ContactoDAO contactoDAO;

在我保存新条目的按钮上，我使用了这个：

                if (textDireccion.getText() != "" && textEmail.getText() != "" && textNombre.getText() != "") {

                    Persona p = new Persona();

                    p.setNombre(textNombre.getText());
                    p.setDireccion(textDireccion.getText());
                    p.setEmail(textEmail.getText());

                    contactoDAO.save(p);

                    textNombre.setText("");
                    textDireccion.setText("");
                    textEmail.setText("");
                }

            }
        });

我也试过用这个：

@EJB(lookup="java:global/proyectobase/ContactoDAO!edu.ups.appdis.proyectobase.negocio.ContactoDAO")

ContactoDAO contactoDAO;

我的 ContactoDAO 上一直出现空指针异常，但这可能是因为查找没有找到任何东西或者我没有正确使用它，我真的不知道。我的问题是在另一个简单的 swing 项目中从我的 bean 调用我的 save 方法的另一种方法是什么，或者我在使用 @EJB 时可能会遗漏其他东西？

编辑： 如果您想知道，这是我的 beans.xml。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://xmlns.jcp.org/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="
        http://xmlns.jcp.org/xml/ns/javaee
        http://xmlns.jcp.org/xml/ns/javaee/beans_1_1.xsd" bean-discovery-mode="all">
</beans>

Answer 1

从日志来看，您的 ContactDAO 及其所有依赖项似乎已在服务器上正确初始化。在独立的 swing 客户端上，您的 META-INF 文件夹中可能缺少 jboss-ejb-client.properties，或者您也可以显式设置初始上下文属性并手动执行 JNDI 查找。

此外，您还应确保将 jboss-client.jar 文件包含在 swing 客户端项目的类路径中。

Wildfly Developer Guide

如果您收到身份验证失败异常，则需要将 username/password 属性添加到 InitialContext 并运行服务器上的添加-user.sh 脚本

Add User

如何在另一个客户端项目中调用 @Remote EJB

How to call a @Remote EJB in another client project

java

jakarta-ee

jboss

javabeans

wildfly-8