1

Столкнулся с проблемой, не знаю как реализовать.

Есть treeView, данные берутся из базы данных. В узле хранятся данные для tcp подключения. Я хочу, чтобы при загрузке формы опросилось каждое соединение и опрашивались постоянно с каким-то интервалом. И по нажатию на узел тоже открывалось соединение и с ним я уже буду работать.

Я написал функцию для опроса устройства, добавил её в поток, но всё-равно при неверном подключении - очень долго поток обрабатывается.

А как сделать что-бы они все опрашивались - я вообще не понимаю...

Может кто-нибудь сможет помочь. Буду очень благодарен.

Это моё подключение.

public void connect()
    {
        this.Invoke((MethodInvoker)delegate ()
        {
            string[] IpHERE;
            TreeNode currentNode = treeView1.SelectedNode;

            IpHERE = currentNode.Text.Split(' ');

            Modbus mb = new Modbus();
            Regex regIP = new Regex(@"\b(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\b");

            if (regIP.IsMatch(IpHERE[1]) && IpHERE[1].Length != 0 && IpHERE[4].Length != 0 && IpHERE[9].Length != 0 && IpHERE[11].Length != 0 && (mb.OpenTCP(IpHERE[1], IpHERE[4], IpHERE[9], IpHERE[11])))
            {
                currentNode.SelectedImageIndex = 3;

                dataGridView1.Visible = true;

                mb.CloseTCP();
            }
            else
            {
                currentNode.SelectedImageIndex = 4;
            }
        });
        Thread.Sleep(100);
    }

Это действие при нажатии

private void treeView1_AfterSelect(object sender, TreeViewEventArgs e)
    {
        string[] IpHERE;
        TreeNode currentNode1 = treeView1.SelectedNode;

        IpHERE = currentNode1.Text.Split(' ');

        Thread thread = new Thread(new ThreadStart(connect));
        thread.Start();
    }

Я сделал гифки с подключением. Первая с успешным подключением а вторая нет(заснял не до конца, там долго).

Первая

Вторая

7
  • Всё, что внутри this.Invoke выполняется в GUI-потоке. Пока этот код не завершится, форма ни на что другое не реагирует. PS: на кой ляд Thread.Sleep? 13 фев 2019 в 18:19
  • @AlexanderPetrov sleep действительно не нужен. А как сделать без this.Invoke?
    – Crowl
    13 фев 2019 в 18:40
  • Чего-то я логику не уловил. 1) В if() после всех проверок вы открываете соединение ... && (mb.OpenTCP(IpHERE[1], IpHERE[4], IpHERE[9], IpHERE[11]))), а потом внутри сразу его закрываете mb.CloseTCP(); и чё? А зачем тогда нужно устанавливать соединение? Или это такая прозвонка соединения? 2) и зачем нужна проверка данных полученных из ноды IpHERE = currentNode.Text.Split(' '); ежели такую проверку нужно делать в момент создания ноды при получении данных из БД? На кой создавать ноду с кривой инфой, а потом заниматься ее проверкой всякий раз, когда нужно с ней поработать?
    – Bulson
    13 фев 2019 в 21:39
  • при неверном подключении - очень долго поток обрабатывается вероятно, надо настроить таймаут соединения
    – tym32167
    13 фев 2019 в 23:38
  • @Bulson а я вопрос задавал по этому моменту?
    – Crowl
    14 фев 2019 в 9:05

1 ответ 1

1

пример работы

//класс устройства
class Device
{
    public string IpAddress { get; set; }
    public string Port { get; set; }
    public string Name { get; set; }
}

С БД будем работать в отдельном классе. Перед создание объекта устройства будем там же проверять данные.

//класс для работы с БД
class DataContext
{
    public async Task<List<Device>> GetDevicesAsync()
    {
        DataTable table = await GetTableDevicesAsync();

        var result = new List<Device>();
        foreach (DataRow row in table.Rows)
        {
            var address = row["Address"].ToString();
            var port = row["Port"].ToString();
            var name = row["Name"].ToString();

            //если данные верны
            if (IsCorrect(address, port, name))
            {
                result.Add(new Device { IpAddress = address, Port = port, Name = name });
            }
        }

        return result;
    }

    private bool IsCorrect(string address, string port, string name)
    {
        //здесь делаем вашу проверку
        //c помощью вашего
        //Regex regIP = new Regex("...");

        //проверка пройдена
        return true;
    }

    //...
}

Для ноды в TreeView создадим класс

class DeviceTreeNode : TreeNode
{
    public Device Device { get; private set; }

    public DeviceTreeNode(Device device)
    {
        Device = device ?? throw new ArgumentNullException(nameof(device));

        this.Text = $"IP:{Device.IpAddress}-Порт:{Device.Port}-Устройство:{Device.Name}";
    }
}

Так выглядит код формы

public partial class MainView : Form
{
    //класс работы с БД
    private readonly DataContext _data = new DataContext();
    //флаг загрузки формы
    private bool _isFirsLoading = true;
    //флаг опроса всех нод
    private bool _isChecking = false;

    public MainView()
    {
        InitializeComponent();

        //загрузка данных
        LoadData();

        this.StartPosition = FormStartPosition.CenterScreen;
        this.Text = "Пример";

        //подписка
        _treeViewDevices.AfterSelect += TreeViewIpAddresses_AfterSelect;
        _buttonCheckAll.Click += ButtonCheckAll_Click;
        _buttonCancel.Click += ButtonCancel_Click;
    }

    /// <summary>
    /// Загрузка данных из БД
    /// Создание нод для TreeView
    /// </summary>
    private async void LoadData()
    {
        //получаем коллекцию устройств из БД
        List<Device> devices = await _data.GetDevicesAsync();

        //создаем ноды и наполняем TreeView
        foreach (var device in devices)
        {
            var node = new DeviceTreeNode(device);
            node.ImageIndex = 0;
            node.SelectedImageIndex = 1;
            _treeViewDevices.Nodes.Add(node);
        }
    }

    /// <summary>
    /// Выбор ноды в TreeView
    /// </summary>
    /// <param name="sender"></param>
    /// <param name="e"></param>
    private async void TreeViewIpAddresses_AfterSelect(object sender, TreeViewEventArgs e)
    {
        //надо ли что-то делать
        if (_isFirsLoading || _isChecking)
        {
            _isFirsLoading = false;
            return;
        }

        await ConnectToDevice(_treeViewDevices.SelectedNode);
    }

    /// <summary>
    /// Соединение с выделенным устройством
    /// </summary>
    /// <param name="node"></param>
    /// <returns></returns>
    private async Task ConnectToDevice(TreeNode node)
    {
        //приводим ноду к нашему типу
        var devNode = node as DeviceTreeNode;

        //пытаемся соединиться
        var modbus = new Modbus(devNode.Device.IpAddress, devNode.Device.Port);
        bool connected = await Task.Run(() => modbus.OpenTCP());

        if (connected)
        {
            Debug.WriteLine($"Адрес {devNode.Device.IpAddress} доступен");
            devNode.SelectedImageIndex = 2;
            await Task.Run(() => modbus.CloseTCP());
        }
        else
        {
            Debug.WriteLine($"Адрес {devNode.Device.IpAddress} недоступен");
            devNode.SelectedImageIndex = 3;
        }
    }

    /// <summary>
    /// Опрос всех устройств
    /// </summary>
    /// <param name="sender"></param>
    /// <param name="e"></param>
    private async void ButtonCheckAll_Click(object sender, EventArgs e)
    {
        _isChecking = true;
        _buttonCancel.Enabled = true;
        _buttonCheckAll.Enabled = false;

        foreach (TreeNode node in _treeViewDevices.Nodes)
        {
            if (!_isChecking) break;

            // выделяем ноду
            _treeViewDevices.SelectedNode = node;
            //пытаемся соединится
            await ConnectToDevice(node);
            //пауза чтоб успела отобразиться иконка
            await Task.Delay(500);
        }

        _isChecking = false;
        _buttonCancel.Enabled = false;
        _buttonCheckAll.Enabled = true;
    }

    private void ButtonCancel_Click(object sender, EventArgs e)
    {
        _isChecking = false;
    }
}

Пример целиком можно найти здесь

6
  • Вот это modbus.CloseTCP(); наверное имеет смысл в таску также засунуть, нет необходимости закрывать подкобчение в UI потоке.
    – tym32167
    14 фев 2019 в 10:41
  • @tym32167 да, пожалуй, лучше.
    – Bulson
    14 фев 2019 в 11:57
  • :) Я имел ввиду немного другое. Что то типа bool canConnect= await Task.Run(() => if (modbus.OpenTCP()){ modbus.Close(); return true; } else return false;); `
    – tym32167
    14 фев 2019 в 12:13
  • @tym32167 ну, это уже вкусовщина, да и лень уже что-то править. :)
    – Bulson
    14 фев 2019 в 12:33
  • не, я про то, что вся история с modbus должна быть, по хорошему, инкапсулирована в Task.Run(), так как нет смысла создвать/коннектиться/дисконнектиться к ресурсу из UI потока. А разбитие это на несколько Task.Run нарушит инкапсуляцию и будет чуточку медленнее из за перключений контекста между потоками. Но в просто примере кода в ответе, это я согласен, не имеет особого значения )
    – tym32167
    14 фев 2019 в 14:13

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.