[UDP] How to send UDP messages on Unity and receive UDP messages on Python? Is there an example? The example of the document does not work

[1101728133]

How to send UDP messages on Unity and receive UDP messages on Python? Is there an example? The example of the document does not work

[alec1o]

You can use Netly on dotnet side. but on python side you must find example about here. but don't angry im creating tests on give you example: Netly UdpClient & Python UdpServer and Netly UdpServer & Python UdpClient. let me remove rust from my python skill!
Example souces: https://wiki.python.org/moin/UdpCommunication

dont forget put: useConnection=false on UDP construtos

[1101728133]

Actually, the main thing is to want Unity examples, or to be able to use C # scripts in Unity

[1101728133]

亲，您的来信可能不能及时看到，看到后必定第一时间回复！

[alec1o]

#25 (comment) It's working?

[alec1o]

😭 😭 😭 I hope this examples help you. because was much hard create it all those examples.

Client

C# UdpClient

using Netly;
using Netly.Core;
using UnityEngine;

class NetlyUdpExample : MonoBehaviour
{
    private UdpClient client = new UdpClient(useConnection: false);
    public string message = "";

    private void Start()
    {
        client.OnOpen(() =>
        {
            Debug.Log("UDP Client, connected.");

            // Send data for python server...
            client.ToData("Hello Python Server.");
        });

        client.OnClose(() =>
        {
            Debug.Log("UDP Client, disconnected.");
        });

        client.OnError((exception) =>
        {
            Debug.Log($"UDP Client, error: {exception}.");
        });

        client.OnData((bytes) =>
        {
            Debug.Log($"UDP Client, data: {NE.GetString(bytes)}.");
        });

        client.Open(new Host("127.0.0.1", 12000));

        Debug.Log("Netly UDP Client started.");
    }

    private void Update()
    {
        if (Input.GetKeyDown(KeyCode.Enter))
        {
            if (client.IsOpened)
            {
                if (string.IsNullOrEmpty(message) == false)
                {
                    client.ToData(message);
                }
            }
        }
    }
}

Python UdpClient

import socket
import threading

ip = "127.0.0.1"
port = 12000
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
running = True

# receive data on background
def ReceiveDataOnBackground(m_socket, m_ip, m_port):

    while running:
        try:
            data, addr = m_socket.recvfrom(2048) # max buffer size per data is 2048 bytes
            print(f"message: {data} from {addr}")
        except:
            pass

print("q -> quit application")
tread = threading.Thread(target=ReceiveDataOnBackground, args=(sock, ip, port))
tread.start()

while running:
    message = input("write message: ")

    if (message == "q"):
        running = False
        print("quit application")
        exit()
    
    if(len(message) > 0):
        sock.sendto(message.encode(), (ip, port))
        print('data sent.')

Server

C# UdpServer

using Netly;
using Netly.Core;

var server = new UdpServer(useConnection: false);

server.OnOpen(() =>
{
    Console.WriteLine("UDP Server, connected.");

    // Send data for python server...
    server.ToData("Hello Python Server.");
});

server.OnClose(() =>
{
    Console.WriteLine("UDP Server, disconnected.");
});

server.OnError((exception) =>
{
    Console.WriteLine($"UDP Server, error: {exception}.");
});

server.OnEnter((c) =>
{
    Console.WriteLine($"client connected: {c}");

    // alternative of: UdpServer.OnData
    c.OnData((bytes) =>
    {
        // echo message;
        // c.ToData(bytes);
    });
});

server.OnExit((c) =>
{
    Console.WriteLine($"client disconnected: {c.Host}");
});

server.OnData((client, bytes) =>
{
    Console.WriteLine($"UDP Server, data: {NE.GetString(bytes)}.");

    // echo the message.
    client.ToData($"I'm netly server and you sent me: {NE.GetString(bytes)}");
});

server.Open(new Host("127.0.0.1", 12000));

Console.WriteLine("Netly UDP Server started.");

Console.ReadLine(); // block thread for app not close;

Python UdpServer

import socket
import threading

class Application:
    def __init__(self):
        self.ip = "127.0.0.1"
        self.port = 12000
        self.running = True
        self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        self.thread = threading.Thread(target=self.server, args=())

    def server(self):
        self.sock.bind((self.ip, self.port))
        print(f"server running at: {self.ip}:{self.port}")

        while self.running:
            # wait for client send some data
            clientAddress = None
            data = None
            
            try:
                data, clientAddress = self.sock.recvfrom(2048) # max buffer size per data is 2048 bytes
            
            except:
                return
                        
            # data received
            print(f"received message from client: {data}, from {clientAddress}")
            
            # send data for client
            # return same data for netly client. (echo)
            self.sock.sendto(data, clientAddress)

    def close(self):
        while self.running:
            print(f'\nHELP:\n\tq -> quit program\n')
            r = input()
            if r == 'q':
                self.running = False
                print('quit...')
                self.sock.close()
                self.thread.join()
                print('exit...')
                exit(code=1)

    def start(self):
        self.thread.start()
        self.close()

# start instance.
app = Application()
app.start()

[1101728133]

That's amazing, thank you

[1101728133]

I tried but couldn't work

[1101728133]

#python client
import socket
UDP_PORT = 12345
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server.bind(("", UDP_PORT))
# server.setblocking(False)
while True:
    try:
        data, addr = server.recvfrom(1024)
        print(data.decode('utf-8'))
    except Exception as e:

        print(e)

[alec1o]

Bro! You can't bind on client.

UDP_PORT = 12345
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server.bind(("", UDP_PORT))

Its is a client or server? It's sounds a server. because is bind and you dont put IPAddress to bind and on Netly server you are put (172.16.5.28)
How will you client connected to 172.16.5.28 port?

#python client
import socket
UDP_PORT = 12345
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server.bind(("", UDP_PORT))
# server.setblocking(False)
while True:
    try:
        data, addr = server.recvfrom(1024)
        print(data.decode('utf-8'))
    except Exception as e:

        print(e)

Just 1 ip can bind a port, and you client can't bind a Port because server is using it.
And use Loopback ip not for simplify testing i mean (127.0.0.1)

Use my code bellow and testing it. If not working tell me what error or another infos

#python client
import socket
UDP_PORT = 12345
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server.bind(("", UDP_PORT))
# server.setblocking(False)
while True:
    try:
        data, addr = server.recvfrom(1024)
        print(data.decode('utf-8'))
    except Exception as e:

        print(e)

Test my example first

import socket
import threading

ip = "127.0.0.1"
port = 12000
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
running = True

# receive data on background
def ReceiveDataOnBackground(m_socket, m_ip, m_port):

    while running:
        try:
            data, addr = m_socket.recvfrom(2048) # max buffer size per data is 2048 bytes
            print(f"message: {data} from {addr}")
        except:
            pass

print("q -> quit application")
tread = threading.Thread(target=ReceiveDataOnBackground, args=(sock, ip, port))
tread.start()

while running:
    message = input("write message: ")

    if (message == "q"):
        running = False
        print("quit application")
        exit()
    
    if(len(message) > 0):
        sock.sendto(message.encode(), (ip, port))
        print('data sent.')

[1101728133]

// unity server
using System;
using Netly;
using Netly.Core;
using UnityEngine;

class NetlyUdp : MonoBehaviour
{
  private readonly UdpServer _server = new UdpServer(useConnection: false);
  public string message = "";
  public String ip="172.16.5.28";
  public int port=12345;
  private void Start()
  {
    _server.OnOpen(() =>
    {
      Debug.Log("UDP Server, connected.");

      // Send data for python server...
      _server.ToData("Hello Python Server.");
    });

    _server.OnClose(() => { Debug.Log("UDP Server, disconnected."); });

    _server.OnError((exception) => { Debug.Log($"UDP Server, error: {exception}."); });

    _server.OnData((UdpClient newUdpClient, byte[] bytes) =>
    {
      Debug.Log($"UDP Server, data: {NE.GetString(bytes)}.");
    });

    _server.Open(new Host(ip, port));

    Debug.Log("Netly UDP Server started.");
  }

  private void Update()
  {
    if (Input.GetKeyDown(KeyCode.Return))
    {
      if (_server.IsOpened)
      {
        if (string.IsNullOrEmpty(message) == false)
        {
          _server.ToData(message);
          print("8888");
        }
      }
    }
  }
}

[alec1o]

Bro!!!!
NOTICE!

private void Update()
{
  if (Input.GetKeyDown(KeyCode.Return))
  {
    if (_server.IsOpened)
    {
      if (string.IsNullOrEmpty(message) == false)
      {
        _server.ToData(message);
        print("8888");
      }
    }
  }
}

bro first mesage come from Client UdpServer.ToData or UdpServer.ToEvent just send event to all connected IP, this is called Broadcast.
UdpClient.ToData or UpdClient send message for server.

You adapted my client example, but its fine.

[alec1o]

Well i think you wish use Unity as UdpServer and Pyhton as UdpClient.

using now:
NOTICE: First test my code without any modifications, after that: you can modify ip or whatever

// unity server
using System;
using Netly;
using Netly.Core;
using UnityEngine;

class NetlyUdp : MonoBehaviour
{
    private readonly UdpServer server = new UdpServer(useConnection: false);
    public string message = "";
    public String ip = "127.0.0.1";
    public int port = 12000;

    private void Start()
    {
        server.OnOpen(() => Debug.Log("UDP Server, started."));

        server.OnClose(() => Debug.Log("UDP Server, disconnected."));

        server.OnError((exception) => Debug.Log($"UDP Server, error: {exception}."));

        server.OnData((UdpClient newUdpClient, byte[] bytes) =>
        {
            Debug.Log($"UDP Server, data: {NE.GetString(bytes)}. from {newUdpClient.Host}");

            // echo effect
            newUdpClient.ToData(bytes)
        });

        server.Open(new Host(ip, port));

        Debug.Log("Netly UDP Server starting...");
    }

    private void Update()
    {
        if (Input.GetKeyDown(KeyCode.Return))
        {
            if (server.IsOpened)
            {
                if (string.IsNullOrEmpty(message) == false)
                {
                    // (send) this data for all connected address
                    server.ToData(message);
                    print("data sent.");
                }
            }
        }
    }
}

# client python
import socket
import threading

ip = "127.0.0.1"
port = 12000
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# receive data on background
def ReceiveDataOnBackground(m_socket, m_ip, m_port):

    while True:
        try:
            data, addr = m_socket.recvfrom(2048) # max buffer size per data is 2048 bytes
            print(f"message: {data} from {addr}")
        except:
            pass

# start background task for receive data from client.
tread = threading.Thread(target=ReceiveDataOnBackground, args=(sock, ip, port))
tread.start()

print("q -> quit application")
while True:
    message = input("write message: ")

    if (message == "q"):
        exit()
    
    # send data to the server.
    if(len(message) > 0):
        sock.sendto(message.encode(), (ip, port))
        print('data sent.')

It's working?

[1101728133]

I know the reason now. Your code is fine, and I should be using FixedUpdate when handling data updates. There's no problem now

[1101728133]

It would be great if Netly could be used more easily, such as establishing a connection with just two or three lines of code, or being able to switch network protocols at any time

[alec1o]

Ohh 🤣

[alec1o]

Open Connection with 3 lines.

var udp = new UdpServer(false);

udp.OnEnter((client) => print($"client connected from {client.Host}"));

udp.Open(new Host("127.0.0.1", 8080));

[alec1o]

Can you give me syntax ideia? maybe you have good ideia to be netly easy to new users.

Current Netly Syntax.

var server = new UdpServer(false);

// init server
server.OnOpen(() => { });

// close server
server.OnClose(() => { });

// server error
server.OnError((e) => { });

// client connection
server.OnEnter((client) => { });

// client disconnection
server.OnExit((client) => { });
server.OnEnter((client) => client.OnClose(() => { }));

// client data
server.OnData((client, buffer) => { });
server.OnEnter((client) => client.OnData((buffer) => { }));

// open connection
server.Open(new Host("127.0.0.1", 8080));

// close connection
server.Close();

[1101728133]

Not yet. If I become proficient in this library, I can provide practical suggestions

[alec1o]

Wow 😭😭😭. I will be happy with your suggestions.!
Don't forget use documentation for know the details

[1101728133]

May I ask how Netly can change the UDP receiver in real-time in Unity？I use server.Open changing IP does not work

[alec1o]

Plz open new discussion. 🥺 (This discussion was closed)

And may explain what you mean on change receptor? Bc I'm not sure about what you mean 🤔