RabbitMQ in .NET Core (Part 1, Single producer and consumer with Queue)
Переглядів 114,860
3 роки томуThis is the first video of the video series on RabbitMQ. RabbitMQ is vast, and it is not possible to cover every single aspect of RabbitMQ in a single video. Hence, I will create a series of RabbitMQ.
Before we get into RabbitMQ it is important to understand why we need a queueing system. And I discussed this in my video on Microservices here:
Microservices introduction: • What are Microservices...
Hands-on microservices: • Converting a Monolithi...
A queue or a message broker provides the much-needed decoupling between microservices. And it prevents get into the anti-pattern of the distributed monolith.
You can think of a message broker like a post office. Its main responsibility is to broker messages between publishers and subscribers.
Once a message is received by a message broker from a producer, it routes the message to a subscriber. The message broker pattern is one of the most useful patterns when it comes to decoupling microservices.
The source code for this video is available in my GitHub repo here: github.com/choudhurynirjhar/r...
@theghumketu2367 Рік тому
Wohoo it just took 20 minutes to learn something valuable today. Thank you
@charlesmcnicoll9060 3 роки тому
Great stuff and great teaching! Everything worked as is on my computer. I especially enjoyed the painless installation of RabbitMQ using Docker, so easy! You have a new subscriber, thanks a lot!
@DotNetCoreCentral 3 роки тому
@Charles McNicoll, thanks for watching! Yes, using docker to install makes life so much easier. Though in a production environment if you are using docker and want to keep durable messages, then it might become a little complex. In production, I use AWS Managed RabbitMQ and it's super simple as well.
@pasdilhan Рік тому
Short and sweet but covered necessary basics.. Thanks
@antarikshverma8999 3 роки тому
Perfactly demonstration of exchange concepts , Thank you. Your channel is now my favorite channel for dotnet core learning.
@DotNetCoreCentral 3 роки тому
@Antariksh verma, thanks for watching!
@tzadiko 3 роки тому
Actually this video did NOT discuss exchanges at all. That is another video. This video is queues only.
@peymanGhaderkurehpaz 3 роки тому
Thanks bro , this series is going to be awesome. Micorservices are really in trend and it's great to make a series about how to design microservices. ❤👌
@DotNetCoreCentral 3 роки тому
@peyman Ghkp, thanks!
2 роки тому
Thank you for your short, concise and clear explanation
@DotNetCoreCentral 2 роки тому
Thanks!
@mrohailiqbal 9 місяців тому
Really great stuff. Nicely explained. Keep it up bro
@ericngo2228 2 роки тому
Simple and straightforward. Excellent tutorial for beginners, who want to use RabbitMQ for inter process communication. It saves a lot of money in compare with using Azure Service Bus.
@DotNetCoreCentral 2 роки тому
@Eric Ngo, thanks for watching!
@vittoriomorellini1939 Рік тому
Perfect explanation BASIC to understand rabbitmq and its use in microservices
@DotNetCoreCentral Рік тому
Thanks!
@krishnakishore2889 2 роки тому
so simple and the best video so far I have seen in you tube on c# communicating with Rabbit MQ
@DotNetCoreCentral 2 роки тому
@Krishna Kishore, thanks for watching!
@RAM-ff8dy 3 роки тому
Super informative, looking forward for next RabbitMq series, try to post them ASAp..
@DotNetCoreCentral 3 роки тому
@RAM, thanks for watching!
@thethomasproject 2 роки тому
Agreed with other comments. Not too little or not too much as an intro. And I got to build a quick project (though I didn't get it all), to see it working. Great intro!!
@DotNetCoreCentral 2 роки тому
@Frank Thomas, thanks for watching!
@ankitjindal6050 2 роки тому
Very well explained and demoed. Thanks!
@DotNetCoreCentral 2 роки тому
@Ankit Jindal, thanks for watching!
@varunsharma10286 3 роки тому
Great video, It was Valuable and Informative.
@DotNetCoreCentral 3 роки тому
@varun sharma, thanks for watching!
@vincent4624 3 роки тому
Very nice tutorial. Starting out with the very basics of RabbitMQ. Just what I needed! I'll definatly be following this series :)
@DotNetCoreCentral 3 роки тому
@Vincent, thanks for watching!
@salarkazazi7584 Рік тому
Thank to so much, great start !
@ncdave789 3 роки тому
Wow. I was working for several years on a complex WinForms project that had to talk with other running processes. Sort of an app suite, that complement each-other. Most of them were written in C++, but some were C# too. And man was inter process communication a headache. And now we have this :)
@DotNetCoreCentral 3 роки тому
@NC Dave, thanks for watching!
@mattizzle81 Рік тому
I implemented something in HTTP in C#, and it works, but I haven’t tried this yet
@aparnadevi7040 2 роки тому
Awesome explanation. Very easy to understand.
@DotNetCoreCentral 2 роки тому
@aparna devi, thanks!
@idog63 2 роки тому
excellent video. very clear and easy to follow. 👍
@DotNetCoreCentral 2 роки тому
@idog63, thanks for watching!
@hazlotumismo1419 3 роки тому
Very cool video, thank you for sharing Sir!
@DotNetCoreCentral 3 роки тому
@Hazlo tu mismo!, thanks for watching!
@MarioStaats 3 роки тому
Great tutorial, directly subscribed :-)
@DotNetCoreCentral 3 роки тому
@Mario Staats, thanks for watching!
@bashirmanafikhi Рік тому
great, I watched a lot of lessons, but you are the best
@DotNetCoreCentral Рік тому
Thanks!
@bnks2011 2 роки тому
Excellent explanation.. Thanks
@DotNetCoreCentral 2 роки тому
Thanks for watching!
@Moosa_Says Рік тому
Perfect! Thanks :)
@DotNetCoreCentral Рік тому
Thanks for watching!
@olufemioyedepo2791 3 роки тому
nice video on rabbitmq, keep them coming...
@DotNetCoreCentral 3 роки тому
@Olufemi Oyedepo, thanks for watching!
@olufemioyedepo2791 3 роки тому
@@DotNetCoreCentral you're welcome. Your video on background jobs using Hangfire was 👌🏾. I became a subscriber since then.
@DotNetCoreCentral 3 роки тому
@@olufemioyedepo2791 thank you!
@elyeskacem4784 9 місяців тому
the command of rabbitMQ : docker run -d --hostname my-rabbit --name ecomm-rabbit -p 15672:15672 -p 5672:5672 rabbitmq:3-management
@subashreekrishnan7382 Рік тому
Great tutorial. 👍👍
@DotNetCoreCentral Рік тому
Thanks for watching!
@zakiit9594 3 роки тому
Thx again, would love it if you cover more on the admin screen!
@DotNetCoreCentral 3 роки тому
@zaki it, I will try to do a video in the future. Thanks!
@rahulmathew8713 3 роки тому
Awesome job
@DotNetCoreCentral 3 роки тому
@Rahul Mathew, thanks for watching!
@sivakumarr28 2 роки тому
Great demo. Keep it up..
@DotNetCoreCentral 2 роки тому
@Sivakumar R, thanks!
@zakiit9594 3 роки тому
Thanks a bunch
@DotNetCoreCentral 3 роки тому
@zaki it, thanks for watching!
@santoshkumaryadav4436 Рік тому
Thanks for this great video, Can you please make some videos on Azure
@tehseenakhtar3209 Рік тому
good basics of producer and consumer. kindly add the chapters ( instead of key moments) in the video that helps a lot in segmentaion of video. like 14:02 Create a Consumer. Add the chapters in description
@DotNetCoreCentral Рік тому
Thanks for the suggestion! And thanks for watching!
@odinsrensen7460 2 роки тому
That worked, thanks.
@DotNetCoreCentral 2 роки тому
@Odin Sørensen, thanks for watching!
@maneeshdeepankar2984 Місяць тому
great
@mukeshtrivedi1896 3 роки тому
very informative vedio,can you make for multiple consumer along with circuitbreaker and poly
@DotNetCoreCentral 3 роки тому
@Mukesh Trivedi, thanks for watching. I can surely try that.
@RohitSingh-go4ng День тому
Rabbit MQ it is always send byte format it is possible to consume in the json format
@eliassal1 3 роки тому
Nice, useful and easy to understnad. A couple of questions, what "Durable false or true" flag means for RabbitMQ, 2nd, when messages are consumed they disappear from queue, how for example if during the day Rabbit receives 1000 messages and I, from admin perspective can see what happened and details of each message in the dashboard? I activated Recent-history plugin but still can't see the history of messages, thanks again
@DotNetCoreCentral 3 роки тому
@Salam Elias, the "Durable" flag is used to indicating the RabbitMQ to persist the metadata of the Queue and its in-flight messages to the disk so that it can recover a restart. Regarding tracing messages coming to RabbitMQ, I used a combination of out of box RabbitMQ logs and Application logs, for all debugging/tracing purposes. These logs are shipped to AWS Cloudwatch and we do our analysis there. I have not used the Admin site for detailed log analysis. I have used the Admin site mainly to monitor the general health of the exchanges, connections, queues, and nodes.
@eliassal1 3 роки тому
@@DotNetCoreCentral Thanks for your reply. I used Biztalk server heavily in different Publish-Subscribe scenarios, inside of it, you can see all what happened according to a time period you configure. I think it is a little bit heavy nad needs a lot of efforts to use different tools to do admin stuff. I beleive that RabbitMQ is a good tool but it needs to improve its admin features
@DotNetCoreCentral 3 роки тому
@@eliassal1 got it.
@saisivakrishnagarimella8534 2 роки тому
Hi, any minimum publish time for message? I am getting timeout, if publishing time more than 20sec. please let me know, Thank you in Advance
@primavera919 2 роки тому
How did you launch the command line @ 4:41?
@semen083 Рік тому
Hi, it is any way to make a receiver without blocking thread (Console.Readline at 17:28)? For example I need to create multiple subscribers in one application without console?
@videolounge6885 4 місяці тому
can you please write the command here which you used to install the rabbitmq? Also docker image command is not working on my system help me to rectify it.
@giorgiocipriano3334 2 роки тому
I have an error with the consumer, can I see the message in the rabitmq console only with th producer?
@aminejadid2702 3 роки тому
Thank you. Can you please do a video about Redis Cache and .Net core ?
@DotNetCoreCentral 3 роки тому
@amine jadid, thanks for watching. I have a video on Redis and .Net Core. Here is the link: ukposts.info/have/v-deo/qYlzlYN9f5ugzmw.html
@aminejadid2702 3 роки тому
@@DotNetCoreCentral thanks
@DotNetCoreCentral 3 роки тому
@@aminejadid2702 Welcome!
@zeeshanasghar3751 3 роки тому
just a suggestion your video "Microservice resilience - Circuit Breaker using polly in .Net Core " should be part of this series ?
@DotNetCoreCentral 3 роки тому
@Zeeshan Asghar, yes, it is part of Microservices. I might have not put it in the playlist, I will do that. Thanks for pointing it out.
@user-bz9qt2tt6k 7 місяців тому
Hi, I am having errors CS8370 Feature "using declaration" is not available in C# 7.3. what's the solution for this?
@TightyWhities94 2 роки тому
beginner here. what's the benefit of the "using" keywords behind connection and challenge?
@DotNetCoreCentral 2 роки тому
@TightyWhities94, the 'using' keyword is used for disposing the connection object, and whichever object it is used with
@mallianumula 2 роки тому
I am new to this, I have a clarification. what is the best approach for client implementation for continues reading, if we do console app, by mistake if someone close the window then, message pulling stop working. so is windows service is better approach or is there any other tools can use as client. make sure client read the message as long as it push into the queue. please advise, thanks
@DotNetCoreCentral 2 роки тому
@Malli Anumula, I use Linux for all my application need, so I have never faced this issue recently. And .NET Core does not support Windows Service, for the very reason that it runs both in Linux and windows. You can either run it as a Web application, so you host it in a web server in Windows, or you can run it as a task using Windows task manager.
@mallianumula 2 роки тому
@@DotNetCoreCentral noted, windows task is not an option for me bcz there could be some delay for windows task min is 1min delay to trigger. I will check web option with SignalR .. thanks for update..
@DotNetCoreCentral 2 роки тому
@@mallianumula thanks!
@amnesia3490 2 роки тому
What I don't understand is, in the consumer, it's an console app, that means when you run it once, it compile and process up to the Console.Readline(), and it stops... So how is that happening when you run producer again and can see the result in consumer ? Consumer is an console app already compiled and executed to the Console.Readline()... Is it using something like websockert ? How it will behave on web api on production ?
@DotNetCoreCentral 2 роки тому
@AmnesiA, in this example, Console.ReadLine is a blocking call and it makes the application wait for a user input, which means until unless a character is entered from the keyboard. But in a production application, you will probably use something like an IHostedService interface implementation to manage this, so that the consumer never shuts down.
@naufilshaikh09 2 роки тому
Perfect start in RabbitMQ but i have frontend application in javascript and backend in dotnet core. how can i setup between them.
@naufilshaikh09 2 роки тому
I mean do i need to setup rabbitmq both side or communicate frontend app and backend app using signalr ?
@DotNetCoreCentral 2 роки тому
@@naufilshaikh09 yes, from backend if you need to send messages real-time to frontend, you will need SignalR for that.
@milos5247 2 роки тому
Is it a better practice to create queues and exchanges through code or through the management client?
@DotNetCoreCentral 2 роки тому
@Milos Miric, if you want to control access, then it's better to create everything through the management console. But if it's a single app and managed by a single team it's an overhead to manage through the console. In a nutshell, if you need more security, it's better to create everything using the management console and provide specific security access, otherwise, just have single-user access to everything and make queue/exchange from code, you can move much faster and without the management overhead.
@milos5247 2 роки тому
@@DotNetCoreCentral Thanks for explaining.
@DotNetCoreCentral 2 роки тому
@@milos5247 you are welcome!
@meganj7155 Рік тому
If I host this consumer in EKS It is getting exited . Console.readline() is not consider after hosting
@DotNetCoreCentral Рік тому
you cannot use Readline in Linux, its a windows thing. You need to use IHostedService instead. I have a video on the same in my channel, check it out
@meganj7155 Рік тому
@@DotNetCoreCentral 🙏
@triptisharma4731 3 роки тому
I want to be able to consume from multiple queues within this single consumer without any of the queues blocking each other. How can we achieve that?
@DotNetCoreCentral 3 роки тому
@Tripti Sharma, you can use this Nuget package I created: www.nuget.org/packages/Plain.RabbitMQ/, and source code for this is here: github.com/choudhurynirjhar/plain-rabbitmq. After you use the Nuget, you can create a singleton instance of IConnectionProvider. And multiple instances per consumer for ISubscriber. And each ISubscriber can be used by background tasks: ukposts.info/have/v-deo/aXaWa4d7boWnymw.html, that way they are running in separate threads. That's all is needed. Thanks
@amitmistry0101 3 роки тому
Hi sir, Other then docker, what we used to install RabbitMQ
@DotNetCoreCentral 3 роки тому
@amit mistry, you can install in Windows or Linux box, but that's very complex and time-consuming. This is the URL you can follow: www.rabbitmq.com/install-windows.html
@goforshahriar 3 роки тому
nice intro, can you go deeper and show it plays important role in developing microservice app?
@DotNetCoreCentral 3 роки тому
@Shahriar Hossain, thanks for watching! And yes, that's the goal, first cover all the basics, and then get into a real-life example with microservices.
@kartheeknandini3767 3 роки тому
please so more videos on rabbitMQ
@DotNetCoreCentral 3 роки тому
@kartheek nandini, I have other videos for RabbitMQ in this series, have you watched all of them?
@subashreekrishnan7382 Рік тому
From where do we get the 3 digit of the image? e67?
@DotNetCoreCentral Рік тому
You can do docket list, its the first 3 digit of the docker container
@subashreekrishnan7382 Рік тому
@@DotNetCoreCentral ok 👍
@subashreekrishnan7382 Рік тому
@@DotNetCoreCentral when trying to run from the browser getting bad_header and localhost:15672 site can't providebsecure connection error . Why is that happening ?
@DotNetCoreCentral Рік тому
@@subashreekrishnan7382 I am not sure, I have never seen this error. Its hard to say without seeing exactly what you are doing.
@dev4g276 Рік тому
Can you please make one video on rabbit mq with mqtt plugin with wrb api please
@DotNetCoreCentral Рік тому
I will check it
@dev4g276 Рік тому
@@DotNetCoreCentral sir i will be great full to you thank you
@antarikshverma8999 3 роки тому
Please try to cover more on management console part.
@DotNetCoreCentral 2 роки тому
@Antariksh verma, thanks sure I will.
@poojanaik5052 2 роки тому
How to check msgs stored on docker? Someone help me out pls
@DotNetCoreCentral 2 роки тому
@Pooja Naik, when you say message stored on docker, do you mean message sent to RabbitMQ running inside a docker container? If that is the case you can just use the RabbitMQ management studio to do that.
@DotNetCoreCentral 2 роки тому
@Pooja Naik, for accessing the management studio, you will need to open localhost:15672 in your browser
@nagarazzarazza8405 2 роки тому
How do we setup in azure?
@DotNetCoreCentral 2 роки тому
@nagarazza razza, I will do a separate video on that.
@rfidhari 3 роки тому
Could you please share the URL for next video
@DotNetCoreCentral 3 роки тому
@Hari Subbu, thanks for watching this video. Here is the URL for next video: ukposts.info/have/v-deo/e51jpKmMZLB_mmQ.html
@narendra_ingle 3 роки тому
Weblogic jms queue how i can read from there
@DotNetCoreCentral 3 роки тому
@Narendra Ingle, you will need to create a bridge, which will read a message from here and post it to WebLogic. There might be some plugins available, but I have never used any.
@rabbanishaik2363 Рік тому
Is it possible to schedule messages?
@DotNetCoreCentral Рік тому
Not that straight forward, but can be done through some plugins.
@rabbanishaik2363 Рік тому
@@DotNetCoreCentral can you please make a simple demo?
@DotNetCoreCentral Рік тому
@@rabbanishaik2363 Sure, will do
@rabbanishaik2363 Рік тому
@@DotNetCoreCentral thank you. Looking forward
@CoderBB 11 місяців тому
Please add all Rabbitmq videos in playlist
@anishachavan8710 3 роки тому
I had an error in the Uri
@DotNetCoreCentral 3 роки тому
@Anisha Chavan, can you provide a little bit more details on the error?
@anishachavan8710 3 роки тому
@@DotNetCoreCentral yes sure
@anishachavan8710 3 роки тому
@@DotNetCoreCentral system.argumentexception hresult=0x80070057 message=wrong scheme in amqp uri: ampq source=rabbitmq.client stacktrace: at rabbitmq.client.connectionfactory.seturi(uri uri) at rabbitmq.client.connectionfactory.set_uri(uri value) at rabbitmq.consumer.program.main(string[] args) in c:\users\anisha\source epos abbitmq.consumer abbitmq.consumer\program.cs:line 16 I changed the Uri to :amqp://guest:guest@host:5672/vhost
@DotNetCoreCentral 3 роки тому
@@anishachavan8710 are you creating a new virtual host or you are using the default virtual host? if you are using the default virtual host then your URL should be just "amqp://guest:guest@localhost:5672"
@anishachavan8710 3 роки тому
@@DotNetCoreCentral I am using a default virtual host I'll try and let you know
@dharmeshsharma 3 роки тому
This could not help to actual use of micro services. As apis the best way to give examples and understand others to best way. The console is just help the code not best way to use in real world. All the best
@DotNetCoreCentral 3 роки тому
@dharmesh art channel, I did mention in this video that this is a series, where I will first go through the basic concepts of RabbitMQ, and after that, I will create a real-life example of how to use RabbitMQ to create Microservice. And here is the video where I did it: ukposts.info/have/v-deo/qoV8pZeGb3-CpHk.html I guess the title caused the confusion, I will change the title of this series.
@june3878 9 місяців тому
tired of these "Hello World" examples.
@antarikshverma8999 3 роки тому
Please try to cover more on management console part.
@DotNetCoreCentral 3 роки тому
@Antariksh verma, sure, I will schedule it.
DotNet Core Central
Переглядів 42 тис.
Мелодрама твоей души
Переглядів 2,9 млн
DotNet Core Central
Переглядів 45 тис.
Priyanshu Gupta
Переглядів 13 тис.
Tech way
Переглядів 3,1 млн
Inter Link
Переглядів 214 тис.