Блог

Итак, я создаю серверное приложение на Java, и я хочу, чтобы запросы к базе данных управлялись событиями, чтобы они не блокировались.

Способ, которым я это делаю, заключается в создании соединения с MySQL в другом потоке, пока у меня есть это:

 package makeza.server.persistence;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

import java.util.logging.Logger;

import makeza.server.WorldServer;

public final class MySQLNonblock extends Thread {
    public Connection connection = null;
    private Logger log = WorldServer.log;

    private String host, port, user, pass, database;

    @Override
    public void run(){
        init();
    }

    public MySQLNonblock(String hst, String prt, String usr, String pas, String dbase){
        this.setDaemon(true);
        this.setName("DatabaseThread");
        this.host = hst;
        this.port = prt;
        this.user = usr;
        this.pass = pas;
        this.database = dbase;
    }

    public void init(){
        log.info("Connecting to database...");
        try {
            connection = DriverManager.getConnection("jdbc:mysql://"   host   ":"   port   "/"   
                                        database   "?"   "user="   user   "amp;password="   pass);
            log.info("Connected to database");
        } catch (SQLException e) {
            log.severe("Couldn't connect to database at "   host   ":"   port);
            System.out.println("SQLException: "   e.getMessage());
            System.out.println("SQLState: "   e.getSQLState());
            System.out.println("VendorError: "   e.getErrorCode());
            System.exit(1);
            //e.printStackTrace();
        }
    }

}
  

Я запускаю поток в другом классе, и он подключается к серверу mysql, а затем поток завершается.

Как мне сделать так, чтобы поток сохранялся после завершения метода запуска, чтобы я мог использовать соединение с mysql?

Вы хотите использовать пул соединений.

«Закрытие» соединения в этом отношении означает «возврат соединения в пул для повторного использования».

Вам нужно подождать, пока какой-нибудь другой поток не разбудит его, уведомив об этом. Прочитайте учебник о параллелизме: http://download.oracle.com/javase/tutorial/essential/concurrency /

Вам, вероятно, следует использовать более высокоуровневую абстракцию, например ExecutorService .