Simple C# NATS example

Readme.md

Simple C# NATS example

1. Run NATS

docker run -p 4444:4444 nats -p 4444

2. Create Web Server

dotnet new webapi -n web

3. Create Worker

dotnet new console -n worker

4. Add NATS to both projects

dotnet add package NATS.Client --version 0.8.1

5. Add ValuesController.cs to web project
6. Add Program.cs to worker project
7. Run Projects
8. Run CURL command

curl --header "Content-Type: application/json" \
--request POST \
--data 'my value' \
http://localhost:5000/api/values

9. Worker logs

worker listening...
worker listening...
worker received {Subject=worker;Reply=null;Payload=<hello, world: >}
worker listening...
worker listening...

10. Server logs

Hosting environment: Production
Content root path: /yourpathto/web
Now listening on: http://localhost:5000
Application started. Press Ctrl+C to shut down.
api/values my value

Program.cs

using System;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using NATS.Client;

namespace worker
{
    class Program
    {
        static void Main()
        {
            Console.WriteLine("Worker:");
            ConnectionFactory cf = new ConnectionFactory();
            Options opts = ConnectionFactory.GetDefaultOptions();
            opts.Url = "nats://localhost:4444";

            IConnection c = cf.CreateConnection(opts);

            EventHandler<MsgHandlerEventArgs> h = (sender, args) =>
            {
                Console.WriteLine($"worker received {args.Message}");
            };

            IAsyncSubscription s = c.SubscribeAsync("worker", h);

            while (true)
            {
                Console.WriteLine("worker listening...");
                Thread.Sleep(TimeSpan.FromSeconds(5));
            }
        }
    }
}

ValuesController.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using NATS.Client;

namespace web.Controllers
{
    [Route("api/[controller]")]
    public class ValuesController : Controller
    {
        // POST api/values
        [HttpPost]
        public IActionResult Post([FromBody]string value)
        {
            Console.WriteLine($"api/snaphost {value}");
            ConnectionFactory cf = new ConnectionFactory();
            Options opts = ConnectionFactory.GetDefaultOptions();

            opts.Url = "nats://localhost:4444";

            IConnection c = cf.CreateConnection(opts);

            c.Publish("worker", Encoding.UTF8.GetBytes($"hello, world: {value}"));
            c.Close();
            return Ok();
        }
    }
}

Is there any example to use publish and request? Thank you