0

我正在尝试实现基于 Californium 的 CoAP 客户端。我让这个客户观察一个资源：

public static class CoapCl{

    double val = 0;
    CoapClient client = new CoapClient("coap://localhost/Ultrasonic");
    CoapObserveRelation relation = client.observe(new CoapHandler() {
    @Override public void onLoad(CoapResponse response)
    {
        val = Double.parseDouble(response.getResponseText());
    }

    @Override
    public void onError() {
        System.out.println("Failed");

    }
});
}

我想从另一个类访问值“val”。我该怎么做 ？我试图像这样从 CoapCl 类调用引用并打印出值：

CoapCl client = new CoapCl();
    while(true)
    {
    System.out.println("Testing: " + client.val);
    }

这将打印我从 CoAP 客户端获得的所有值，包括已更改和未更改的值。如果我只想获取更改后的值该怎么办？

4

1 回答 1

1

好吧，问题本身与 Californium 和 CoAP 无关。除了 CoapHandler 是异步的，但这相当困难。不过，我建议以某种回调结束：

public class CoapCl {
    private final Consumer<Double> valueChangedAction;
    private final CoapClient client = new CoapClient("coap://localhost/Ultrasonic");

    public CoapCl(Consumer<Double> valueChangedAction) {
        this.valueChangedAction = valueChangedAction;
    }

    public void run() {
        client.observe(new CoapHandler() {
            @Override
            public void onLoad(CoapResponse response) {
                valueChangedAction.accept(
                    Double.parseDouble(
                        response.getResponseText()
                    )
                );
            }

            @Override
            public void onError() {
                System.out.println("Failed");
            }
        });
    }
}


new CoapCl(val -> System.out.println("Testing: " + val)).run();

请记住，您必须以某种方式阻止主线程以防止程序立即退出。之前，您已经用无限循环阻止了它。现在，如果您的程序中还没有这样的东西，您将不得不使用 System.in.read() 或 Thread.sleep 或其他东西。

于 2017-08-10T10:40:39.183 回答