want to read msmq message fast using safe thread in c# .net

Amit Pathak

I want to read the MSMQ where queue data in byte and numbers of queues generated in 1 mins about 1500.

If read continuously queue, cpu goes on 30%, and after some time it stopped.
I need to read queue in high volume upto 4 hrs.

I want safe thread reading in such a manner that shouldn't be blocked.
Actually I am not good about threading so can you please help me out?

Currently I am reading in this manner:

bool ProcessStatus; //process
Thread _UDPthreadConsme;

private void btn_receive_Click(object sender, EventArgs e)
       {

       if (MessageQueue.Exists(@".\private$\myquelocal"))
            {

                ThreadStart _processrcs = new ThreadStart(receivemessages);
                _UDPthreadConsme = new Thread(_processrcs);
                ProcessStatus = true;
                _UDPthreadConsme.Start();
             } 
       }


private void receivemessages()
       {
           MessageBox.Show("Start");
           while (ProcessStatus)
           {
                   try
                        {

                            // Connect to the a queue on the local computer.
                            MessageQueue myQueue = new MessageQueue(@".\private$\myquelocal");


                            System.Messaging.Message[] myMessagecount = myQueue.GetAllMessages();

                            if (myMessagecount.Length <= 0)
                                return;

                       
                            myQueue.Formatter = new BinaryMessageFormatter();
                         
                            // Receive and format the message. 
                            System.Messaging.Message myMessage = myQueue.Receive();
                            byte[] buffer = (byte[])myMessage.Body;
                                    

// here i convert buffer to its related structure and then insert the values in database sqlserver.

           }
       }

7 Replies

Know the answer? Post it — somebody with the same question will find it here.

Guest User15y ago
Try implementing a BackgroundWorker as Sam suggested.
0
Amit Pathak15y ago
thanks for showing interest in my question, i have used sleep of 50 ms still it goes to 5 to 105 cpu if sleep is 200 then it may work good, but the issue will consumaption of queues is less than creation of queue. i found 1500 queue generated in 1 min and consumation of only 150 queue now suggest me what to do???
0
Sam Hobbs15y ago
That's what happens when we learn things ourselves. I have learned a lot without books. The BackgroundWorker class would be covered in any good book about C#. It is good to be familiar with more detailed ways of doing things but the BackgroundWorker is a relatively easy way to do threading in a form.
0
Guest User15y ago
That's interesting, Sam... I hadn't heard of BackgroundWorker, just used to doing things the old fashioned way, I guess. Thanks for posting that, it does seem like a better way to go.
0
Sam Hobbs15y ago
I don't really understand what you are asking but I do know that if you make your thread work the way it should work, you totally do not need to use Thread.Sleep().

I think the important thing is that BackgroundWorker is probably the best solution. Look for articles in this web site about that.

I don't understand why the program reads the messages only when the receive button is clicked. First, though, go ahead and read the articles about BackgroundWorker. Then if you have questions, tell us if the program would work if it started reading messages at the beginning of the program and then continued to read messages or if there is a reason why the messages must be read only when the receive button is clicked.
0
Suthish Nair15y ago
If the query got resolved, then mark the post that helped you as Answer so will be helpful for others. Otherwise if you got the solution please share with us.
0
Guest User15y ago
At the end of the while loop in receivemessages (after you insert the values into the database), add the following line:

Thread.Sleep(10);

This causes that thread to stop processing for 10ms. This allows other processes and threads to continue processing and reduces the CPU utilization of the receivemessages thread.

You can adjust that 10ms to whatever you feel is best for performance.
0

want to read msmq message fast using safe thread in c# .net

Amit Pathak

15y6.8kVisual Basic .NET

bool ProcessStatus; //process
Thread _UDPthreadConsme;

private void btn_receive_Click(object sender, EventArgs e)
       {

       if (MessageQueue.Exists(@".\private$\myquelocal"))
            {

                ThreadStart _processrcs = new ThreadStart(receivemessages);
                _UDPthreadConsme = new Thread(_processrcs);
                ProcessStatus = true;
                _UDPthreadConsme.Start();
             } 
       }


private void receivemessages()
       {
           MessageBox.Show("Start");
           while (ProcessStatus)
           {
                   try
                        {

                            // Connect to the a queue on the local computer.
                            MessageQueue myQueue = new MessageQueue(@".\private$\myquelocal");


                            System.Messaging.Message[] myMessagecount = myQueue.GetAllMessages();

                            if (myMessagecount.Length <= 0)
                                return;

                       
                            myQueue.Formatter = new BinaryMessageFormatter();
                         
                            // Receive and format the message. 
                            System.Messaging.Message myMessage = myQueue.Receive();
                            byte[] buffer = (byte[])myMessage.Body;
                                    

// here i convert buffer to its related structure and then insert the values in database sqlserver.

           }
       }

7 Replies

Know the answer? Post it — somebody with the same question will find it here.

Guest User15y ago
Try implementing a BackgroundWorker as Sam suggested.
0
Amit Pathak15y ago
thanks for showing interest in my question, i have used sleep of 50 ms still it goes to 5 to 105 cpu if sleep is 200 then it may work good, but the issue will consumaption of queues is less than creation of queue. i found 1500 queue generated in 1 min and consumation of only 150 queue now suggest me what to do???
0
Sam Hobbs15y ago
That's what happens when we learn things ourselves. I have learned a lot without books. The BackgroundWorker class would be covered in any good book about C#. It is good to be familiar with more detailed ways of doing things but the BackgroundWorker is a relatively easy way to do threading in a form.
0
Guest User15y ago
That's interesting, Sam... I hadn't heard of BackgroundWorker, just used to doing things the old fashioned way, I guess. Thanks for posting that, it does seem like a better way to go.
0
Sam Hobbs15y ago
I don't really understand what you are asking but I do know that if you make your thread work the way it should work, you totally do not need to use Thread.Sleep().

I think the important thing is that BackgroundWorker is probably the best solution. Look for articles in this web site about that.

I don't understand why the program reads the messages only when the receive button is clicked. First, though, go ahead and read the articles about BackgroundWorker. Then if you have questions, tell us if the program would work if it started reading messages at the beginning of the program and then continued to read messages or if there is a reason why the messages must be read only when the receive button is clicked.
0
Suthish Nair15y ago
If the query got resolved, then mark the post that helped you as Answer so will be helpful for others. Otherwise if you got the solution please share with us.
0
Guest User15y ago
At the end of the while loop in receivemessages (after you insert the values into the database), add the following line:

Thread.Sleep(10);

This causes that thread to stop processing for 10ms. This allows other processes and threads to continue processing and reduces the CPU utilization of the receivemessages thread.

You can adjust that 10ms to whatever you feel is best for performance.
0