

Apabila cuba memulakan dua atau lebih kerja Spring Batch pada masa yang sama, ralat dilemparkan: ORA-08177: Tidak dapat mensiri akses untuk transaksi ini
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
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
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(); }
}
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(); } }
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(); } }
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()); } } }
batchexecutorservice.java
@service public class batchexecutorservice { @autowired batchjobrunner batchjobrunner; public completablefuture<canbatchjob> execute(canbatchjob canbatchjob,taskexecutor threadpooltaskexecutor){ return completablefuture.supplyasync(() -> batchjobrunner.execute(canbatchjob),threadpooltaskexecutor); } }
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; } }
batchjob.java
public class BatchJob { private String jobName; private Boolean isCompleted; private String errorDesc; }
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; }
Dialih keluar completablefuture.
Batchexecutorservice.java
dipadamkanMenambah 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 masukAtas 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!

Alat AI Hot

Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Undress AI Tool
Gambar buka pakaian secara percuma

Clothoff.io
Penyingkiran pakaian AI

AI Hentai Generator
Menjana ai hentai secara percuma.

Artikel Panas

Alat panas

Notepad++7.3.1
Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1
Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6
Alat pembangunan web visual

SublimeText3 versi Mac
Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Topik panas

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

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

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 "

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,

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

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

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

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.