UTGARD opc client: многократное чтение нескольких элементов

Я написал следующий код с использованием библиотеки Utgard OPC.

Мне нужно читать данные с OPC-сервера один раз каждые 15 секунд. Однако я не уверен, является ли это наиболее оптимальным способом его реализации. В моем сценарии мне требуется прочитать более 300 тегов с сервера.

Какие-либо предложения?

package opcClientSalem;
import java.util.concurrent.Executors;

import org.jinterop.dcom.common.JIException;
//import org.jinterop.dcom.core.JIVariant;
import org.openscada.opc.lib.common.ConnectionInformation;
import org.openscada.opc.lib.common.NotConnectedException;
import org.openscada.opc.lib.da.AccessBase;
import org.openscada.opc.lib.da.AddFailedException;
import org.openscada.opc.lib.da.AutoReconnectController;
import org.openscada.opc.lib.da.DataCallback;
import org.openscada.opc.lib.da.DuplicateGroupException;
import org.openscada.opc.lib.da.Item;
import org.openscada.opc.lib.da.ItemState;
import org.openscada.opc.lib.da.Server;
import org.openscada.opc.lib.da.SyncAccess;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;

import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;


public class opcClientSalem {
    public static void main(String[] args) throws Exception {
        // create connection information
        System.out.println("**********Initializing OPC Client**********");
        java.util.logging.Logger.getLogger("org.jinterop").setLevel(java.util.logging.Level.OFF);
        final ConnectionInformation ci = new ConnectionInformation("myusername","mypassword");
        ci.setHost("myhost");
        ci.setDomain("");
        ci.setProgId("Matrikon.OPC.Simulation.1");
        ci.setClsid("F8582CF2-88FB-11D0-B850-00C0F0104305");
        String itemIdArr[] = {"Random.Real8","Random.Int2"}; // This is where I would have an array of all items
        // create a new server
        final Server server = new Server(ci, Executors.newSingleThreadScheduledExecutor());
        AutoReconnectController controller = new AutoReconnectController(server);

        try {
            // connect to server
            System.out.println("**********Attempting to connect to OPC**********");
            controller.connect();
            System.out.println("**********Successfully connected to OPC**********");
            // add sync access, poll every 15000 ms
            final AccessBase access = new SyncAccess(server, 15000);

            while(true){
                for(final String str : itemIdArr){
                    access.addItem(str, new DataCallback() {
                        @Override
                        public void changed(Item item, ItemState state) {
                            // Building a JSON string with value recieved
                            String record = "[ {" +"\""+"name"+"\" :\""+str + "\",\""+"timestamp"+"\" :"+ state.getTimestamp().getTime().getTime()+ ",\""+"value"+"\" : "+value.replace("[", "").replace("]", "")  +",\"tags\":{\"test\":\"test1\"}} ]";

                            try {
                                // Post JSON string to my API which ingests this data
                                new opcClientSalem().restpost(record);
                            } catch (ClientProtocolException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                            } catch (IOException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                            }
                        }
                    });
                }
                // start reading
                access.bind();
                Thread.sleep(5000);
            }
            // wait a little bit

            // stop reading
            //access.unbind();
        } catch (final JIException e) {
            //System.out.println(String.format("%08X: %s", e.getErrorCode(), server.getErrorMessage(e.getErrorCode())));
        }
    }

    private void restpost(String record) throws ClientProtocolException, IOException{

        HttpClient client = new DefaultHttpClient();
        HttpPost post = new HttpPost("http://localhost/myapi/datapoints");
        StringEntity input = new StringEntity(record);
        post.setEntity(input);
        HttpResponse response = client.execute(post);
        System.out.println("Post success::"+record);
    }

}
Источник

2 ответа

Решение

Я не уверен, что вам нужно добавлять элементы снова и снова в вашей группе.

В других библиотеках (.net или native C++) обычно вам нужно добавлять элементы только один раз, и обратный вызов вызывается всякий раз, когда значение элемента изменяется.

В.net или C++ мы получаем глобальный обратный вызов для каждой группы, который кажется более эффективным, чем отдельные обратные вызовы для элементов. Может быть, SyncAccess имеет глобальный обратный вызов, поищите его.

Итак, возможные оптимизации:

  • удалите часть while, добавьте элементы только один раз и спите поток бесконечно.
  • искать глобальный обратный вызов для всех предметов
Источник

Вы должны создать подписку в этом случае.

Источник
Другие вопросы по тегам