UdpSender.cs 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Net;
  5. using System.Net.Sockets;
  6. using System.Text;
  7. using System.Threading.Tasks;
  8. namespace MeterVision.Helper
  9. {
  10. public class UdpSender
  11. {
  12. private static UdpSender _instance;
  13. private static readonly object _lock = new object();
  14. private UdpClient udpClient;
  15. private IPEndPoint remoteEndPoint;
  16. // 私有构造函数,防止外部实例化
  17. private UdpSender(string receiverIp, int receiverPort)
  18. {
  19. udpClient = new UdpClient();
  20. remoteEndPoint = new IPEndPoint(IPAddress.Parse(receiverIp), receiverPort);
  21. }
  22. // 获取单例实例
  23. public static UdpSender GetInstance(string receiverIp = "127.0.0.1", int receiverPort = 5000)
  24. {
  25. if (_instance == null)
  26. {
  27. lock (_lock)
  28. {
  29. if (_instance == null)
  30. {
  31. _instance = new UdpSender(receiverIp, receiverPort);
  32. }
  33. }
  34. }
  35. return _instance;
  36. }
  37. // 发送日志
  38. public void SendLog(string message)
  39. {
  40. try
  41. {
  42. byte[] data = Encoding.UTF8.GetBytes(message);
  43. udpClient.Send(data, data.Length, remoteEndPoint);
  44. }
  45. catch (Exception ex)
  46. {
  47. Console.WriteLine($"日志发送失败: {ex.Message}");
  48. }
  49. }
  50. // 关闭 UDP 连接
  51. public void Close()
  52. {
  53. udpClient?.Close();
  54. }
  55. }
  56. }