在线程中进行 DAO 注入

Question

我正在使用 java ee 与 wildfly 开发一个 Web 应用程序，我必须开发一个立即响应客户端的 Web 服务，但您必须创建一个任务或线程来执行某些任务，最后更新数据库中的记录

这是一个基本示例，此处创建线程

@GET
@Path("/createReq")
@Produces("application/json")
public void createReq() {
objThread trip = new ObjThread();
trip.setIdTrip("id");
trip.start();
}

这是一个基本示例，此处创建线程

public class ObjThread extends Thread {
volatile boolean ejecutar = true;
public String idTrip;
private int time = 0;
@Inject
Tbl_car_tripDAO tripDAO;
@Override
public void run() {
try {
while (ejecutar) {
if (time == 1) { 
// task 1
} else if (time ==  3) { //30
// task 2
} else if (time >= 5) { //45
// task 3
detener();
changeStatus();
}
Thread.sleep(1000);
time++;
}
} catch (Exception e) {
// TODO: handle exception
}
}
public void detener() {
ejecutar = false;
}
public void changeStatus() {
try {
Tbl_car_trip trip= tripDAO.getTripByIdTrip(idTrip);
trip.setCar_tri_status("data");
tripDAO.update(trip);
} catch (Exception e) {
e.printStackTrace();
// TODO: handle exception
}
}
public void setIdTrip(String idTrip) {
this.idTrip = idTrip;
}
}

但是在执行时，我在 changeStatus 方法中收到持久性错误，但是如果我在另一个类中对@inject注释使用相同的方法，它可以正常工作。您能否通过建议帮助我解决此问题。谢谢

升级

这是我的DAO类

@Singleton
public class Tbl_car_tripDAO {
@Inject
private EntityManager em;
public boolean update(Tbl_car_trip tbl_car_trip) {
try {
em.merge(tbl_car_trip);
return true;
} catch (Exception e) {
return false;
}
}

Answer 1

ObjThread 必须是 Spring bean，这样你才能注入依赖关系 (Tbl_car_tripDAO(。

@Component
@Scope("prototype")
public class ObjThread extends Thread {

您需要从 Sprint 上下文中获取 ObjThread(无法使用新的 ObjThread (( 进行实例化(