Jump to content

[SOLVED] 1.19.2 MySQL Query in parallel Thread and MultiThread in Maincraft


andreybadrey

Recommended Posts

Hi guys, my Java is BAD, and my English is verry BAD... Therefore, what I will write may not be clear, but I really ask you to try to figure it out and help me if someone knows an alternative or has already done something like this.

 

I am having the following problem with my mod:

There is a game store in the mod, how is it? Its alpha version, which will be improved from the current state... And this store is working properly... But, when buying from the store, the entire server stops at the moment the item is received from the store. The reason for this is one thread (Main Thread).

Now the purchase code works like this:

1) By pressing the key, GUI opens, information from the player's balance database is loaded into the GUI;

2) When you click on the purchase button, a packet is sent to the server with information that the player pressed the button

3) The server, having received the packet, makes a request to the database with a balance check. If the balance allows, the server issues the item to the player, makes a database query, writing the new balance.

I noticed that at the time of requests to the database, the server just sleeps. It stops generating ticks until it receives a response from the database. If you spam multiple clicks on the button, then you can observe a complete stop of the world, at the time of loading requests to the database. As far as I realized myself in Java, I understand that the reason for all this is: the sequence of code execution in the main thread, all operations are performed strictly in order ...

So, in order to fix this, based on my knowledge, I assume that you need to move database queries to a separate thread ... What is a thread and how to create it, I know a little, but very little. Of course, I will pump my knowledge in this direction.

 

But I would like to know from you:

1) Where should the new thread be written?

2) Safe syntax for opening a stream, and in which part of the code

3) Methods for transferring information from the second stream to the main one

 

I will be glad if you at least point to actual examples on the github in which this is practiced. 

Due to my limited knowledge of languages, I experience some difficulties in finding information. I will be glad for any help

GitHub

Edited by andreybadrey
Link to comment
Share on other sites

  • andreybadrey changed the title to [SOLVED] 1.19.2 MySQL Query in parallel Thread and MultiThread in Maincraft

In general, as always, I independently found a solution

in fact, the topic of multithreading turned out to be very simple to understand and apply in minecraft

The point is to output each server action to a separate thread, of course, where possible and safe

For those who are interested, I am attaching my first multithread model

GITHUB

On the example of using packages, I brought each server action to a separate thread through a class with inheritance of the Thread class

class MyThread extends Thread { 

 

   @Override
   public void run() {

         any code

    }

}

Having trouble defining NetworkEvent.Context.  To define it and pass it to a new thread, I defined a static object in the package class


public class ByeAppleC2SPacket {
    public static NetworkEvent.Context val;
    public ByeAppleC2SPacket() {}

}

define a variable(object) val in the handler method and Starting the second thread

public boolean handle(Supplier<NetworkEvent.Context> supplier) {
   NetworkEvent.Context context = supplier.get();
   context.enqueueWork(() -> {
   val = context;
   MyThread myThread = new MyThread();
   myThread.start();
   });

  return true;
}

Now in a new thread, we can perform actions on the player through ByeAppleC2SPacket.val.getSender()

Also in the stream method run() we can start new threads

as a result, after performing each action in a new thread, we give a minimum drawdown on the TPS server and speed up the mod tenfold

Before using this model, the code provided in the github gave a huge drawdown of the TPS, and caused the server to crash. Now when spamming at 10 packets per second, and with three operations per packet: Request balance, give an item, update the balance. All operations are parallelized into separate threads, and do not slow down the server

Use this if you are interested ... I will ask experienced developers for feedback ...

Link to comment
Share on other sites

Join the conversation

You can post now and register later. If you have an account, sign in now to post with your account.
Note: Your post will require moderator approval before it will be visible.

Guest
Unfortunately, your content contains terms that we do not allow. Please edit your content to remove the highlighted words below.
Reply to this topic...

×   Pasted as rich text.   Restore formatting

  Only 75 emoji are allowed.

×   Your link has been automatically embedded.   Display as a link instead

×   Your previous content has been restored.   Clear editor

×   You cannot paste images directly. Upload or insert images from URL.

Announcements



  • Recently Browsing

    • No registered users viewing this page.
  • Posts

    • >>>KLIK LOGIN DISINI SAYANG<<< >>>KLIK DAFTAR DISINI SAYANG<<< Pendahuluan Dalam dunia perjudian online, slot menjadi salah satu permainan yang paling diminati. Dengan munculnya berbagai platform, Togel2Win hadir sebagai salah satu pilihan menarik, terutama dengan fitur anti rungkad yang dijanjikan. Artikel ini akan membahas tentang Togel2Win, keunggulan slot terbaru, dan bagaimana server Thailand berperan dalam meningkatkan pengalaman bermain. Apa Itu Togel2Win? Togel2Win adalah platform permainan yang menawarkan berbagai jenis permainan, termasuk slot dan togel. Dengan antarmuka yang ramah pengguna dan beragam pilihan permainan, situs ini bertujuan untuk memberikan pengalaman bermain yang menyenangkan dan menguntungkan bagi para pemain. Keunggulan Slot Togel2Win Fitur Anti Rungkad: Salah satu keunggulan utama dari Togel2Win adalah fitur anti rungkad yang dirancang untuk mengurangi kemungkinan gangguan saat bermain. Ini memastikan bahwa pemain dapat menikmati permainan tanpa gangguan teknis, meningkatkan kenyamanan dan fokus. Beragam Pilihan Slot: Togel2Win menawarkan berbagai jenis slot, dari yang klasik hingga yang modern dengan grafis menawan dan tema yang menarik. Ini memberikan variasi yang cukup bagi pemain untuk menemukan permainan yang sesuai dengan preferensi mereka. Server Thailand yang Stabil: Server yang berlokasi di Thailand memberikan koneksi yang cepat dan stabil. Ini sangat penting untuk pengalaman bermain yang lancar, terutama saat bermain slot yang memerlukan respons cepat. Bonus dan Promosi Menarik: Togel2Win sering menawarkan bonus dan promosi yang menarik untuk menarik pemain baru dan mempertahankan loyalitas pemain yang sudah ada. Ini bisa berupa bonus deposit, putaran gratis, atau program loyalitas. Tips untuk Pemain Slot di Togel2Win Pilih Slot dengan RTP Tinggi: Sebelum memulai permainan, pastikan untuk memilih slot dengan tingkat pengembalian pemain (RTP) yang tinggi untuk meningkatkan peluang menang. Kelola Anggaran: Tentukan batasan anggaran sebelum bermain dan patuhi itu. Ini membantu mencegah kerugian besar dan menjaga pengalaman bermain tetap menyenangkan. Manfaatkan Bonus: Jangan ragu untuk memanfaatkan bonus dan promosi yang ditawarkan. Ini bisa memberikan tambahan modal untuk bermain lebih lama. Kesimpulan Togel2Win merupakan pilihan menarik bagi para penggemar slot, terutama dengan fitur anti rungkad dan server yang stabil. Dengan berbagai pilihan permainan dan bonus yang menggiurkan, Togel2Win siap memberikan pengalaman bermain yang tak terlupakan. Jika Anda mencari platform slot yang andal dan menyenangkan, Togel2Win bisa menjadi solusi yang tepat.
    • I'm trying to make my own modpack, but sometimes, in certain areas of the world, the game just says "server closed". Minecraft doesn't close, it just returns to the menu. When I tried to figure it out on my own and understand the logs, I didn't understand anything (English is not my native language, so it's difficult for me). I've been trying to solve the problem for the third month. So I ask if anyone is good at this and it's not difficult for you, to help me with this. If you need details, ask. I'll describe everything. What it looks like Logs
    • Hi i installed modpack to my server, it starts but when i join it crashes everytime, im running 1.20.1 forge version, all client mods are deleted from the server.   java.lang.NoClassDefFoundError: Could not initialize class sun.security.ssl.SSLContextImpl$DefaultSSLContext at java.lang.Class.forName0(Native Method) ~[?:?] {re:mixin} at java.lang.Class.forName(Class.java:390) ~[?:?] {re:mixin} at java.lang.Class.forName(Class.java:381) ~[?:?] {re:mixin} at java.security.Provider$Service.getImplClass(Provider.java:1967) ~[?:?] {} at java.security.Provider$Service.getDefaultConstructor(Provider.java:1998) ~[?:?] {} at java.security.Provider$Service.newInstanceOf(Provider.java:1912) ~[?:?] {} at java.security.Provider$Service.newInstanceUtil(Provider.java:1920) ~[?:?] {} at java.security.Provider$Service.newInstance(Provider.java:1895) ~[?:?] {} at sun.security.jca.GetInstance.getInstance(GetInstance.java:236) ~[?:?] {} at sun.security.jca.GetInstance.getInstance(GetInstance.java:164) ~[?:?] {} at javax.net.ssl.SSLContext.getInstance(SSLContext.java:185) ~[?:?] {} at javax.net.ssl.SSLContext.getDefault(SSLContext.java:110) ~[?:?] {} at javax.net.ssl.SSLSocketFactory.getDefault(SSLSocketFactory.java:83) ~[?:?] {} at javax.net.ssl.HttpsURLConnection.getDefaultSSLSocketFactory(HttpsURLConnection.java:336) ~[?:?] {} at javax.net.ssl.HttpsURLConnection.<init>(HttpsURLConnection.java:292) ~[?:?] {} at sun.net.www.protocol.https.HttpsURLConnectionImpl.&lt;init&gt;(HttpsURLConnectionImpl.java:81) ~[?:?] {} at sun.net.www.protocol.https.Handler.openConnection(Handler.java:62) ~[?:?] {} at sun.net.www.protocol.https.Handler.openConnection(Handler.java:57) ~[?:?] {} at java.net.URL.openConnection(URL.java:1095) ~[?:?] {re:mixin} at java.net.URL.openStream(URL.java:1162) ~[?:?] {re:mixin} at xxrexraptorxx.additionalstructures.utils.Events.SupporterCheck(Events.java:129) ~[AdditionalStructures-1.20.x-(v.4.2.2).jar%23401!/:4.2.2] {re:classloading} at xxrexraptorxx.additionalstructures.utils.Events.SupporterRewards(Events.java:86) ~[AdditionalStructures-1.20.x-(v.4.2.2).jar%23401!/:4.2.2] {re:classloading} at xxrexraptorxx.additionalstructures.utils.__Events_SupporterRewards_PlayerLoggedInEvent.invoke(.dynamic) ~[AdditionalStructures-1.20.x-(v.4.2.2).jar%23401!/:4.2.2] {re:classloading,pl:eventbus:B} at net.minecraftforge.eventbus.ASMEventHandler.invoke(ASMEventHandler.java:73) ~[eventbus-6.0.5.jar%2352!/:?] {} at net.minecraftforge.eventbus.EventBus.post(EventBus.java:315) ~[eventbus-6.0.5.jar%2352!/:?] {} at net.minecraftforge.eventbus.EventBus.post(EventBus.java:296) ~[eventbus-6.0.5.jar%2352!/:?] {} at net.minecraftforge.event.ForgeEventFactory.firePlayerLoggedIn(ForgeEventFactory.java:875) ~[forge-1.20.1-47.3.0-universal.jar%23694!/:?] {re:mixin,re:classloading,pl:mixin:A} at net.minecraft.server.players.PlayerList.m_11261_(PlayerList.java:261) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,pl:accesstransformer:B,re:classloading,pl:accesstransformer:B,pl:mixin:A} at net.minecraft.server.network.ServerLoginPacketListenerImpl.m_143699_(ServerLoginPacketListenerImpl.java:139) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,pl:accesstransformer:B,re:classloading,pl:accesstransformer:B,pl:mixin:APP:krypton.mixins.json:shared.network.pipeline.encryption.ServerLoginNetworkHandlerMixin,pl:mixin:APP:connectivity.mixins.json:ServerLoginNetHandlerMixin,pl:mixin:A} at net.minecraft.server.network.ServerLoginPacketListenerImpl.m_10055_(ServerLoginPacketListenerImpl.java:126) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,pl:accesstransformer:B,re:classloading,pl:accesstransformer:B,pl:mixin:APP:krypton.mixins.json:shared.network.pipeline.encryption.ServerLoginNetworkHandlerMixin,pl:mixin:APP:connectivity.mixins.json:ServerLoginNetHandlerMixin,pl:mixin:A} at net.minecraft.server.network.ServerLoginPacketListenerImpl.m_9933_(ServerLoginPacketListenerImpl.java:70) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,pl:accesstransformer:B,re:classloading,pl:accesstransformer:B,pl:mixin:APP:krypton.mixins.json:shared.network.pipeline.encryption.ServerLoginNetworkHandlerMixin,pl:mixin:APP:connectivity.mixins.json:ServerLoginNetHandlerMixin,pl:mixin:A} at net.minecraft.network.Connection.m_129483_(Connection.java:263) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,re:classloading,pl:mixin:APP:connectivity.mixins.json:AdvancedPacketErrorLogging,pl:mixin:APP:krypton.mixins.json:shared.network.flushconsolidation.ClientConnectionMixin,pl:mixin:APP:krypton.mixins.json:shared.network.pipeline.compression.ClientConnectionMixin,pl:mixin:APP:krypton.mixins.json:shared.network.pipeline.encryption.ClientConnectionMixin,pl:mixin:APP:connectivity.mixins.json:ConnectionErrorMixin,pl:mixin:APP:connectivity.mixins.json:NetworkManagerMixin,pl:mixin:A} at net.minecraft.server.network.ServerConnectionListener.m_9721_(ServerConnectionListener.java:142) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,re:classloading} at net.minecraft.server.MinecraftServer.m_5703_(MinecraftServer.java:907) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,pl:accesstransformer:B,re:computing_frames,pl:accesstransformer:B,re:classloading,pl:accesstransformer:B,pl:mixin:APP:modernfix-common.mixins.json:core.MinecraftServerMixin,pl:mixin:APP:modernfix-common.mixins.json:perf.dedicated_reload_executor.MinecraftServerMixin,pl:mixin:APP:balm.mixins.json:MinecraftServerMixin,pl:mixin:APP:neruina.mixins.json:MinecraftServerMixin,pl:mixin:A} at net.minecraft.server.dedicated.DedicatedServer.m_5703_(DedicatedServer.java:283) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,pl:accesstransformer:B,re:computing_frames,pl:accesstransformer:B,re:classloading,pl:accesstransformer:B,pl:mixin:APP:lithostitched.mixins.json:server.DedicatedServerMixin,pl:mixin:APP:mixins/common/nochatreports.mixins.json:server.MixinDedicatedServer,pl:mixin:APP:tombstone.mixins.json:DedicatedServerMixin,pl:mixin:A} at net.minecraft.server.MinecraftServer.m_5705_(MinecraftServer.java:814) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,pl:accesstransformer:B,re:computing_frames,pl:accesstransformer:B,re:classloading,pl:accesstransformer:B,pl:mixin:APP:modernfix-common.mixins.json:core.MinecraftServerMixin,pl:mixin:APP:modernfix-common.mixins.json:perf.dedicated_reload_executor.MinecraftServerMixin,pl:mixin:APP:balm.mixins.json:MinecraftServerMixin,pl:mixin:APP:neruina.mixins.json:MinecraftServerMixin,pl:mixin:A} at net.minecraft.server.MinecraftServer.m_130011_(MinecraftServer.java:661) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,pl:accesstransformer:B,re:computing_frames,pl:accesstransformer:B,re:classloading,pl:accesstransformer:B,pl:mixin:APP:modernfix-common.mixins.json:core.MinecraftServerMixin,pl:mixin:APP:modernfix-common.mixins.json:perf.dedicated_reload_executor.MinecraftServerMixin,pl:mixin:APP:balm.mixins.json:MinecraftServerMixin,pl:mixin:APP:neruina.mixins.json:MinecraftServerMixin,pl:mixin:A} at net.minecraft.server.MinecraftServer.m_206580_(MinecraftServer.java:251) ~[server-1.20.1-20230612.114412-srg.jar%23689!/:?] {re:mixin,pl:accesstransformer:B,re:computing_frames,pl:accesstransformer:B,re:classloading,pl:accesstransformer:B,pl:mixin:APP:modernfix-common.mixins.json:core.MinecraftServerMixin,pl:mixin:APP:modernfix-common.mixins.json:perf.dedicated_reload_executor.MinecraftServerMixin,pl:mixin:APP:balm.mixins.json:MinecraftServerMixin,pl:mixin:APP:neruina.mixins.json:MinecraftServerMixin,pl:mixin:A} at java.lang.Thread.run(Thread.java:1589) ~[?:?] {re:mixin} Caused by: java.lang.ExceptionInInitializerError: Exception java.lang.ExceptionInInitializerError [in thread " Iron Furnaces Update Checker"] at javax.crypto.Cipher.getInstance(Cipher.java:548) ~[?:?] {re:mixin} at sun.security.ssl.SSLCipher.isTransformationAvailable(SSLCipher.java:523) ~[?:?] {} at sun.security.ssl.SSLCipher.<init>(SSLCipher.java:512) ~[?:?] {} at sun.security.ssl.SSLCipher.<clinit>(SSLCipher.java:93) ~[?:?] {} at sun.security.ssl.CipherSuite.<clinit>(CipherSuite.java:65) ~[?:?] {} at sun.security.ssl.SSLContextImpl.getApplicableSupportedCipherSuites(SSLContextImpl.java:343) ~[?:?] {} at sun.security.ssl.SSLContextImpl$AbstractTLSContext.<clinit>(SSLContextImpl.java:556) ~[?:?] {} at java.lang.Class.forName0(Native Method) ~[?:?] {re:mixin} at java.lang.Class.forName(Class.java:390) ~[?:?] {re:mixin} at java.lang.Class.forName(Class.java:381) ~[?:?] {re:mixin} at java.security.Provider$Service.getImplClass(Provider.java:1967) ~[?:?] {} at java.security.Provider$Service.getDefaultConstructor(Provider.java:1998) ~[?:?] {} at java.security.Provider$Service.newInstanceOf(Provider.java:1912) ~[?:?] {} at java.security.Provider$Service.newInstanceUtil(Provider.java:1920) ~[?:?] {} at java.security.Provider$Service.newInstance(Provider.java:1895) ~[?:?] {} at sun.security.jca.GetInstance.getInstance(GetInstance.java:236) ~[?:?] {} at sun.security.jca.GetInstance.getInstance(GetInstance.java:164) ~[?:?] {} at javax.net.ssl.SSLContext.getInstance(SSLContext.java:185) ~[?:?] {} at javax.net.ssl.SSLContext.getDefault(SSLContext.java:110) ~[?:?] {} at javax.net.ssl.SSLSocketFactory.getDefault(SSLSocketFactory.java:83) ~[?:?] {} at javax.net.ssl.HttpsURLConnection.getDefaultSSLSocketFactory(HttpsURLConnection.java:336) ~[?:?] {} at javax.net.ssl.HttpsURLConnection.<init>(HttpsURLConnection.java:292) ~[?:?] {} at sun.net.www.protocol.https.HttpsURLConnectionImpl.&lt;init&gt;(HttpsURLConnectionImpl.java:81) ~[?:?] {} at sun.net.www.protocol.https.Handler.openConnection(Handler.java:62) ~[?:?] {} at sun.net.www.protocol.https.Handler.openConnection(Handler.java:57) ~[?:?] {} at java.net.URL.openConnection(URL.java:1095) ~[?:?] {re:mixin} at java.net.URL.openStream(URL.java:1162) ~[?:?] {re:mixin} at ironfurnaces.update.ThreadUpdateChecker.run(ThreadUpdateChecker.java:30) ~[ironfurnaces-1.20.1-4.1.6.jar%23534!/:4.1.6] {re:classloading}
  • Topics

×
×
  • Create New...

Important Information

By using this site, you agree to our Terms of Use.