Jadual Kandungan
Kandungan soalan
Penyelesaian
Rumah Java Apabila cuba memulakan dua atau lebih kerja Spring Batch pada masa yang sama, ralat dilemparkan: ORA-08177: Tidak dapat mensiri akses untuk transaksi ini

Apabila cuba memulakan dua atau lebih kerja Spring Batch pada masa yang sama, ralat dilemparkan: ORA-08177: Tidak dapat mensiri akses untuk transaksi ini

Feb 09, 2024 pm 05:00 PM
lsp

editor php Xigua mungkin menghadapi masalah apabila menggunakan Spring Batch: apabila cuba memulakan dua atau lebih kerja Spring Batch pada masa yang sama, ralat akan dilemparkan: ORA-08177: Tidak dapat menyerikan akses kepada transaksi ini. Ralat ini mungkin mengelirukan, tetapi ia sebenarnya disebabkan oleh isu penguncian pangkalan data. Sebelum menyelesaikan masalah ini, kita perlu memahami beberapa pengetahuan latar belakang tentang Spring Batch dan transaksi pangkalan data.

Kandungan soalan

Saya mengalami ralat semasa cuba menggunakan completablefuture untuk menjalankan dua kerja kelompok musim bunga secara selari. Mesej ralat adalah seperti berikut:

originalsql = insert into batch_job_instance(job_instance_id, job_name, job_key, version)
    values (?, ?, ?, ?)
, error msg = ora-08177: can't serialize access for this transaction
Salin selepas log masuk

Saya menggunakan spring batch 5.x, spring boot 3.1.6, jdk 17

Sifat Aplikasi

spring.batch.repository.isolationlevelforcreate=isolation_read_committed
spring.batch.isolationlevel=read_committed
spring.batch.jdbc.table-prefix=batch_
spring.batch.job.enabled=false
Salin selepas log masuk

batchconfig.java

@configuration
public class batchconfig {

@bean("simpletaskexecutor")
    public taskexecutor simpletaskexecutor() {
        simpleasynctaskexecutor asynctaskexecutor = new simpleasynctaskexecutor("simpletaskexecutor");
        asynctaskexecutor.setconcurrencylimit(concurrencycount);
        return asynctaskexecutor;
    }


@bean("joblauncherasync")
    @scope("prototype")
    public joblauncher joblauncherasync(datasource datasource, jobrepository jobrepository) throws exception {

        taskexecutorjoblauncher joblauncher = new taskexecutorjoblauncher();
        joblauncher.setjobrepository(jobrepository);
        joblauncher.settaskexecutor(simpletaskexecutor());
        joblauncher.afterpropertiesset();
        return joblauncher;
    }
    
    @bean
    public jpatransactionmanager transactionmanager(entitymanagerfactory entitymanagerfactory) {
        return new jpatransactionmanager(entitymanagerfactory);
    }
    
    @bean
    public batchjobexecutionlistener batchjobexecutionlistener() {
        return new batchjobexecutionlistener();
    } 
    
    @bean
    public batchjobstepexecutionlistner batchjobstepexecutionlistner() {
        return new batchjobstepexecutionlistner();
    }
Salin selepas log masuk

}

employeejobconfig.java

@configuration
@import(batchconfig.class)
public class employeejobconfig{
    
        
    @autowired
    employeestatuswritter employeestatuswritter;
    
    @autowired
    employeependingprocessor employeependingprocessor;
    
    
    
    @bean("employeependingreader")
    public jpapagingitemreader<employee> employeependingreader(datasource ds,entitymanagerfactory entitymanagerfactory) {
        
        jpapagingitemreader<employee> jpareader = new jpapagingitemreader<>();
        jpareader.setentitymanagerfactory(entitymanagerfactory);
        jpareader.setquerystring("select e from employee e");
        jpareader.setpagesize(5000);
        return jpareader;

    }
    
    @bean("employeespinvokestep")
    public step employeespinvokestep(@qualifier("employeependingreader") itemreader<employee> reader,
            @qualifier("employeestatuswritter") itemwriter<employee> writer,
            @qualifier("employeependingprocessor") itemprocessor<employee, employee> processor,jobrepository jobrepository,
            platformtransactionmanager transactionmanager,batchjobstepexecutionlistner batchjobstepexecutionlistner,taskexecutor simpletaskexecutor) {

        return new stepbuilder("employeespinvokestep",jobrepository)
                .<employee, employee>chunk(50,transactionmanager).reader(reader)
                .processor(processor).writer(writer)
                .listener(batchjobstepexecutionlistner)
                .taskexecutor(simpletaskexecutor)
                .build();
    }
    
    @bean("employeespjob")
    public job employeespjob(@qualifier("employeespinvokestep") step employeespinvokestep,jobrepository jobrepository,batchjobexecutionlistener batchjobexecutionlistener) {
        return new jobbuilder("employeespjob",jobrepository)
                .incrementer(new runidincrementer())
                .listener(batchjobexecutionlistener)
                .start(employeespinvokestep)
                .build();
    }

}
Salin selepas log masuk

managerconfig.java

@configuration
@import(batchconfig.class)
public class managerconfig {
    
        

    @autowired
    managerstatuswritter managerstatuswritter;
    
    
    @autowired
    managerpendingprocessor managerpendingprocessor;
    
    @bean("managerpendingreader")
    public jpapagingitemreader<manager> managerpendingreader(datasource ds,entitymanagerfactory entitymanagerfactory) {
        
        jpapagingitemreader<manager> jpareader = new jpapagingitemreader<>();
        jpareader.setentitymanagerfactory(entitymanagerfactory);
        jpareader.setquerystring("select m from manager m");
        jpareader.setpagesize(5000);
        return jpareader;

    }
    
    @bean("managerspinvokestep")
    public step indvinvoiceconsctlspinvokestep(@qualifier("managerpendingreader") itemreader<manager> reader,
            @qualifier("managerstatuswritter") itemwriter<manager> writer,
            @qualifier("managerpendingprocessor") itemprocessor<manager, manager> processor,jobrepository jobrepository,
            platformtransactionmanager transactionmanager,batchjobstepexecutionlistner batchjobstepexecutionlistner,taskexecutor simpletaskexecutor) {

        return new stepbuilder("managerspinvokestep",jobrepository)
                .<manager, manager>chunk(5000,transactionmanager).reader(reader)
                .processor(processor).writer(writer)
                .listener(batchjobstepexecutionlistner)
                .taskexecutor(simpletaskexecutor)
                .build();
    }
    
    @bean("managerspjob")
    public job managerspjob(@qualifier("managerspinvokestep") step indvinvoiceconsctlspinvokestep,jobrepository jobrepository,batchjobexecutionlistener batchjobexecutionlistener) {
        return new jobbuilder("managerspjob",jobrepository)
                .incrementer(new runidincrementer())
                .listener(batchjobexecutionlistener)
                .start(indvinvoiceconsctlspinvokestep)
                .build();
    }
    
}
Salin selepas log masuk

batchjobmanager.java

@service
public class batchjobmanager {

    
    
      @autowired applicationcontext context;
     
      @autowired batchexecutorservice batchexecutorservice;
      
      @autowired
      batchjobrunner batchjobrunner;
      
       
    
    public void startjob() {
        
         try {
               system.out.println("batchjobmanager called .. "+new date());
                
               string[] invoicenames={"employeespjob","managerspjob"};
               
               list<string> invoicenameslist = arrays.aslist(invoicenames);
               launchasyn(getbatchjoblist(invoicenameslist));
                
                 
         } catch (exception e) {
             system.out.println("while loading job..");
             e.printstacktrace();
         }
        
    }
      

    public list<batchjob>  getbatchjoblist(list<string> jobnames) throws exception{
        list<batchjob> batchjoblist=new arraylist<batchjob>();
        for(string job:jobnames) {
             batchjob batchjob= batchjob.builder().jobname(invoicejob).build();
             batchjoblist.add(batchjob);
        }
        return batchjoblist;
    }
      
    
       
    public void launchasyn( list<batchjob> batchjoblist) throws exception{
         list<completablefuture<batchjob>> batchjobfuturelist = new arraylist<completablefuture<batchjob>>();
          
          for(batchjob batchjob:batchjoblist) {
          completablefuture<batchjob> jobfuture = batchexecutorservice.execute(batchjob, asynctaskexecutor);
          batchjobfuturelist.add(jobfuture);
          }
          
          completablefuture<void> jobfutureresult = completablefuture
                    .allof(batchjobfuturelist.toarray(new completablefuture[batchjobfuturelist.size()]));
          
          
          completablefuture<list<canbatchjob>> allcompletablefuture = jobfutureresult.thenapply(future -> {
                return batchjobfuturelist.stream().map(completablefuture -> completablefuture.join())
                        .collect(collectors.tolist());
            });
        
          list<batchjob> resultfuturelist=allcompletablefuture.get();
          
          for(batchjob batch:resultfuturelist) {
              system.out.println("status "+batch.getiscompleted());
          }
    }
   
    
}
Salin selepas log masuk

batchexecutorservice.java

@service
public class batchexecutorservice {
    
        
    @autowired 
    batchjobrunner batchjobrunner;
        
    public completablefuture<canbatchjob> execute(canbatchjob canbatchjob,taskexecutor threadpooltaskexecutor){
        return completablefuture.supplyasync(() -> batchjobrunner.execute(canbatchjob),threadpooltaskexecutor);
    }
    
    
}
Salin selepas log masuk

batchjobrunner.java

@service
public class batchjobrunner {

    @autowired applicationcontext context;
      
    
     @autowired 
     @qualifier("joblauncherasync")
     joblauncher joblauncherasync;
    
    
    /*
     * @autowired joblauncher joblauncherasync;
     */
    
    public batchjob execute(batchjob batchjob) {
        try {
            system.out.println(" batchjob"+batchjob.getjobname()+" called ...");
            joblauncherasync.run(getjob(batchjob.getjobname()), getjobparameters(batchjob.getjobname()));
            thread.sleep(15000);
            batchjob.setiscompleted(true);
            system.out.println(" batchjob"+batchjob.getjobname()+" completed ...");
        }
        catch(exception e) {
            system.out.println("exception "+e.getmessage());
            batchjob.seterrordesc(e.getmessage().tostring());
            e.printstacktrace();
        }
        
        return canbatchjob;
    }
    
    public job getjob(string jobname) {
        
         return  (job) context.getbean(jobname); 
    }
    
    public jobparameters getjobparameters(string jobname) {
    
    jobparameters  jobparameters = new jobparametersbuilder() .addstring("unique_id",
              uuid.randomuuid().tostring(), true) .addstring("job_name", jobname,
              true) .adddate("execution_start_date", date.from(instant.now()),
              true).tojobparameters();
    return jobparameters;
    }
    
}
Salin selepas log masuk

batchjob.java

public class BatchJob {

    private String jobName;
    private Boolean isCompleted;
    private String errorDesc;
    
    
}
Salin selepas log masuk

Pekerjaan berjalan dengan jayanya apabila dilaksanakan satu persatu atau mengikut urutan. Walau bagaimanapun, apabila menggunakan completablefuture, saya menghadapi masalah. Adakah memulakan kerja kumpulan musim bunga pada masa yang sama dengan cara yang betul?

Penyelesaian

1. Tambahkan sifat berikut pada aplikasi.properties

spring.main.allow-bean-definition-overriding=true

2. Joblauncher () dikemas kini, seperti yang ditunjukkan dalam batchconfig.java di bawah

@bean("joblauncher")
    public joblauncher joblauncher(datasource datasource, jobrepository jobrepository) throws exception {
        taskexecutorjoblauncher joblauncher = new taskexecutorjoblauncher();
        joblauncher.setjobrepository(jobrepository);
        joblauncher.settaskexecutor(simpletaskexecutor());
        joblauncher.afterpropertiesset();
        return joblauncher;
    }
Salin selepas log masuk
  • Dialih keluar completablefuture.

  • Batchexecutorservice.java

    dipadamkan
  • Menambah kaedah berikut dalam batchjobmanager.java untuk memanggil kerja.

    public void launchSync(List<BatchJob> batchJobList) throws Exception {
             for(BatchJob batchJob:batchJobList) {
                  batchJobRunner.execute(batchJob);
                  }  
         }
    Salin selepas log masuk

    Atas ialah kandungan terperinci Apabila cuba memulakan dua atau lebih kerja Spring Batch pada masa yang sama, ralat dilemparkan: ORA-08177: Tidak dapat mensiri akses untuk transaksi ini. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

  • Kenyataan Laman Web ini
    Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn

    Alat AI Hot

    Undresser.AI Undress

    Undresser.AI Undress

    Apl berkuasa AI untuk mencipta foto bogel yang realistik

    AI Clothes Remover

    AI Clothes Remover

    Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

    Undress AI Tool

    Undress AI Tool

    Gambar buka pakaian secara percuma

    Clothoff.io

    Clothoff.io

    Penyingkiran pakaian AI

    AI Hentai Generator

    AI Hentai Generator

    Menjana ai hentai secara percuma.

    Artikel Panas

    R.E.P.O. Kristal tenaga dijelaskan dan apa yang mereka lakukan (kristal kuning)
    2 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌
    Repo: Cara menghidupkan semula rakan sepasukan
    4 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌
    Hello Kitty Island Adventure: Cara mendapatkan biji gergasi
    4 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌

    Alat panas

    Notepad++7.3.1

    Notepad++7.3.1

    Editor kod yang mudah digunakan dan percuma

    SublimeText3 versi Cina

    SublimeText3 versi Cina

    Versi Cina, sangat mudah digunakan

    Hantar Studio 13.0.1

    Hantar Studio 13.0.1

    Persekitaran pembangunan bersepadu PHP yang berkuasa

    Dreamweaver CS6

    Dreamweaver CS6

    Alat pembangunan web visual

    SublimeText3 versi Mac

    SublimeText3 versi Mac

    Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

    Bagaimana untuk menyembunyikan album foto pada Redmi Note13RPro? Bagaimana untuk menyembunyikan album foto pada Redmi Note13RPro? May 01, 2024 pm 12:50 PM

    RedmiNote13RPro ialah model baharu dengan prestasi dan konfigurasi yang sangat baik Telefon ini mempunyai fungsi album foto tersembunyi yang sangat berguna Ia boleh membantu pengguna menyembunyikan album foto mereka supaya orang lain tidak dapat melihat album foto anda. Seterusnya, editor akan memberitahu anda cara menyembunyikan album foto pada Redmi Note13R Pro untuk membantu anda melindungi privasi anda. Bagaimana untuk menyembunyikan album foto pada Redmi Note13RPro? 1. Masukkan tetapan telefon Xiaomi anda. 2. Kemudian klik Privasi dan Perlindungan. 3. Klik Lindungi Privasi di sini sekali lagi. 4. Klik peti besi. 5. Akhir sekali, anda boleh menyediakan album foto peribadi di sini. Soalan Lazim Menyambung ke Bluetooth Menukar Kaedah Input Tema Menukar Tetapan Kilang Sembunyikan Aplikasi Mencerminkan TV NFC Dayakan Masa Pengaktifan Pemasangan Dwi SIM

    Bagaimana untuk melaraskan saiz fon pada Redmi Note13RPro? Bagaimana untuk melaraskan saiz fon pada Redmi Note13RPro? May 07, 2024 pm 06:34 PM

    Jangan ubah maksud kandungan asal, perhalusi kandungan, tulis semula kandungan, jangan teruskan Redmi Note13RPro bukan sahaja mempunyai prestasi yang sangat baik, tetapi juga mempunyai pengalaman pengguna yang lebih baik , Redmi Note13RPro dilengkapi dengan fungsi pelarasan fon untuk membolehkan pengguna Keupayaan untuk melaraskan fon untuk telefon anda. Jika anda ingin tahu cara melaraskan saiz fon Redmi Note13R Pro, sila lihat. Bagaimana untuk melaraskan saiz fon pada Redmi Note13RPro? 1. Buka apl Tetapan. 2. Tatal ke bahagian bawah dan pilih "Paparan." 3. Klik "Saiz Teks". 4. Pada skrin ini, anda boleh melaraskan saiz fon dengan menyeret peluncur atau memilih saiz fon pratetap. 5. Selepas pelarasan selesai, tekan "OK" untuk menyimpan

    Bagaimana untuk menetapkan kertas dinding dinamik pada Redmi Note13RPro? Bagaimana untuk menetapkan kertas dinding dinamik pada Redmi Note13RPro? Apr 28, 2024 pm 06:49 PM

    Jumlah jualan Redmi Note13R Pro kekal pada tahap tinggi sejak dilancarkan Sebagai model baharu Redmi, ia mempunyai banyak fungsi berguna terbina dalam, seperti fungsi tetapan kertas dinding dinamik. Di sini hari ini, editor membawakan anda tutorial terperinci tentang cara menetapkan kertas dinding dinamik pada Redmi Note13R Pro Jika anda ingin tahu, lihat. Bagaimana untuk menetapkan kertas dinding dinamik pada Redmi Note13RPro? Cari dan buka apl "Tema Diperibadikan" atau "Tema" pada desktop telefon anda. Dalam apl, cari pilihan "Kertas Dinding" atau "Kertas Dinding Langsung" dan klik untuk masuk. Dalam halaman Kertas Dinding Langsung, semak imbas dan pilih kertas dinding langsung yang anda suka. Klik pada kertas dinding langsung yang dipilih untuk pratonton dan kemudian pilih pilihan "Muat turun" untuk memuat turunnya. Selepas muat turun selesai, cari "

    Bagaimana untuk menyambungkan Redmi Note13RPro ke komputer? Bagaimana untuk menyambungkan Redmi Note13RPro ke komputer? May 09, 2024 pm 06:52 PM

    Redmi Note13RPro adalah telefon bimbit yang sangat popular baru-baru ini, ramai pengguna telah membeli telefon ini untuk kali pertama, jadi mereka tidak tahu bagaimana untuk menyambungkan Redmi Note13RPro ke komputer editor di sini untuk menerangkan kepada anda Pengenalan tutorial terperinci disediakan. Bagaimana untuk menyambungkan Redmi Note13RPro ke komputer? 1. Gunakan kabel data USB untuk menyambungkan telefon Redmi ke antara muka USB komputer. 2. Buka tetapan telefon, klik Pilihan dan hidupkan penyahpepijatan USB. 3. Buka pengurus peranti pada komputer anda dan cari pilihan peranti mudah alih. 4. Klik kanan peranti mudah alih, pilih Kemas Kini Pemacu, dan kemudian pilih Cari pemacu yang dikemas kini secara automatik. 5. Jika komputer tidak mencari pemandu secara automatik,

    Bagaimana untuk mengekstrak teks daripada gambar pada Redmi Note13RPro? Bagaimana untuk mengekstrak teks daripada gambar pada Redmi Note13RPro? May 08, 2024 pm 10:00 PM

    Telefon bimbit Redmi Note13RPro menyepadukan beberapa alat pintar dari segi fungsi perisian Antaranya, dengan cepat dan tepat mengekstrak kandungan teks daripada gambar adalah salah satu daripadanya Editor berikut akan memperkenalkan kepada anda cara Redmi Note13RPro mengekstrak teks daripada gambar. Bagaimana untuk mengekstrak teks daripada gambar pada Redmi Note13RPro? Gunakan fungsi pengimbasan kod QR Xiaomi, buka aplikasi pengimbasan kod QR pada telefon anda, klik ikon gambar, pilih gambar, dan kemudian klik pilihan "Kecam teks" di sebelah kanan untuk berjaya mengekstrak teks dalam gambar. Beroperasi melalui album telefon mudah alih. Cari gambar yang teksnya perlu diekstrak dalam album telefon mudah alih, klik "Lagi" di bawah gambar, dan pilih "Ekstrak Teks". Selepas pengecaman berjaya, anda boleh menyalin atau menyimpan teks seperti yang diperlukan. Gunakan program mini WeChat. Mikro terbuka

    Bagaimana untuk melaraskan saiz fon pada Redmi Note13RPro? Bagaimana untuk melaraskan saiz fon pada Redmi Note13RPro? Apr 29, 2024 pm 07:22 PM

    Bagi memberikan pengguna pengalaman pengguna yang lebih baik, Redmi Note13R Pro membawakan anda fungsi melaraskan saiz fon Fungsi ini boleh melaraskan saiz fon telefon bimbit mengikut keperluan anda. Seterusnya, editor akan memperkenalkan secara terperinci cara melaraskan fon pada Redmi Note13R Pro Mari belajar bersama. Bagaimana untuk melaraskan saiz fon pada Redmi Note13RPro? 1. Buka tetapan telefon dan klik Paparan 2. Klik Tetapan Fon 3. Pilih saiz fon yang anda ingin tetapkan Soalan Lazim Sambung Bluetooth Tukar kaedah input Tema Tukar tetapan kilang Sembunyikan aplikasi Mirror TV NFC Dayakan pemasangan dwi-SIM Masa pengaktifan Bagaimana pula Redmi Note13RPro Laraskan saiz fon? Tutorial ini sebenarnya agak mudah, kecuali untuk RedmiN yang disebutkan dalam artikel

    Bagaimana untuk mematikan bunyi kamera pada Redmi Note13RPro? Bagaimana untuk mematikan bunyi kamera pada Redmi Note13RPro? May 02, 2024 pm 06:31 PM

    Fungsi kamera Redmi Note13RPro sangat mudah digunakan, terutamanya apabila mengambil gambar, ia akan mensimulasikan bunyi pengatup kamera, bagaimanapun, fungsi ini mungkin mengganggu orang lain dalam keadaan sunyi seperti perpustakaan, sehingga ramai pengguna ingin tahu cara membelok off bunyi kamera Redmi Note13RPro , biarkan editor memberitahu anda di bawah. Bagaimana untuk mematikan bunyi kamera pada Redmi Note13RPro? 1. Untuk kaedah pertama, anda perlu membuka tetapan telefon anda terlebih dahulu. 2. Kemudian cari aplikasi sistem di bawah menu tetapan. 3. Kemudian kami mencari pilihan kamera di bawah antara muka aplikasi sistem. 4. Akhir sekali, kita boleh menetapkan sama ada untuk mematikan bunyi kamera dalam antara muka kamera Kita hanya perlu mematikan suis di sebelah kanan bunyi kamera. 5. Kaedah kedua, langkah pertama, buka

    Panduan lengkap untuk semua peringkat 'Seluruh Kehidupan' Panduan lengkap untuk semua peringkat 'Seluruh Kehidupan' May 07, 2024 pm 06:31 PM

    Seluruh Huoba ialah permainan teka-teki kasual yang sangat menyeronokkan yang semua orang boleh alami pada berbilang platform! Permainan ini menyediakan pelbagai tahap menarik yang menunggu untuk dibuka kunci Setiap tahap penuh dengan kebaharuan dan cabaran, membolehkan anda mengalami pengembaraan yang menarik untuk menjawab soalan dan membuka kunci kandungan permainan baharu. Jadi bagaimana untuk membersihkan keseluruhan tahap Huoba? Hari ini saya membawakan anda panduan lengkap untuk semua peringkat "Whole Life". Jika anda menghadapi sebarang masalah untuk melepasi tahap, anda boleh merujuknya! Panduan lengkap "The Whole Life" untuk semua peringkat "The Whole Life" Panduan lengkap untuk semua peringkat "The Whole Life" Bantu dia menonton Malam Tahun Baru, bantu adik perempuan untuk mengenal pasti serigala bajingan, dan nenek membantu gadis kecil itu melarikan diri dari bahaya untuk pengembaraan luar, berpura-pura tidak melihat Ah Piao dan berubah kembali Manusia itu membantu orang utan itu menjadi seorang manusia yang berada di tempat duduk belakang terus tenang dan berurusan dengan hantu perempuan itu tenang dan berurusan dengan hantu perempuan.