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

    Video Face Swap

    Video Face Swap

    Tukar muka dalam mana-mana video dengan mudah menggunakan alat tukar muka AI percuma kami!

    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 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 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

    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

    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.

    Bagaimana untuk menetapkan paparan trafik pada Redmi Note13RPro? Bagaimana untuk menetapkan paparan trafik pada Redmi Note13RPro? May 02, 2024 pm 03:34 PM

    RedmiNote13RPro ialah telefon bimbit yang digemari oleh ramai pengguna. Telefon ini menyediakan kaedah khas untuk memaparkan trafik pada telefon Jika anda masih tidak tahu cara menyediakan RedmiNote13RPro untuk memaparkan trafik, kemudian ikuti editor untuk mengetahui. Bagaimana untuk menetapkan paparan trafik pada Redmi Note13RPro? 1. Masukkan "Tetapan" dan klik "Rangkaian Mudah Alih Dwi SIM". 2. Tatal ke bawah untuk memilih pilihan "Tetapan Pakej Data". 3. Hidupkan suis fungsi di sebelah kanan "Paparkan maklumat trafik dalam bar pemberitahuan" dan "Paparkan kelajuan rangkaian semasa dalam bar status". 4. Selepas tetapan berjaya, tarik ke bawah bar status untuk melihat paparan kelajuan rangkaian masa nyata dan maklumat trafik. FAQ Sambung Bluetooth Tukar tema kaedah input Tukar tetapan kilang Sembunyikan penghantaran aplikasi

    Kecantikan 'Whole Life' Journey to the West membantu watak wanita Journey to the West kembali ke tempat mereka dan membersihkan tahap Kecantikan 'Whole Life' Journey to the West membantu watak wanita Journey to the West kembali ke tempat mereka dan membersihkan tahap May 07, 2024 pm 03:46 PM

    Keseluruhan Huoba ialah permainan pecah tahap yang sangat popular di Douyin Terdapat banyak tahap dalam permainan yang menunggu semua orang untuk mencabar! Dalam tahap permainan "Journey to the West Beauty", semua orang perlu membantu watak wanita "Journey to the West" kembali ke kedudukannya Bagaimana untuk melepasi tahap? Di bawah ialah panduan untuk melengkapkan permainan "Whole Life" yang dibawakan oleh editor The Beauty of Journey to the West membantu watak wanita Journey to the West kembali ke tempat mereka permainan, mari lihat saya harap ia dapat membantu anda. Kecantikan "Whole Life" Journey to the West membantu watak wanita Journey to the West untuk kembali ke tempatnya tempat Live" mempunyai panduan lengkap untuk semua peringkat, membantunya menjadi pemerhati tahun ini, membantu adik perempuan itu mengenal pasti bajingan dan serigala, dan nenek untuk membantu gadis kecil itu melarikan diri daripada bahaya dan melakukan pengembaraan luar.