netty-plugin

[547426109]

I want develop netty plugin,Can someone give me some advice? thx

[jiaqifeng]

@547426109
the encoder and decoder of the packge to add and extract the trace info from upstream app to downstream app.

[dinesh4747]

Any recent progress/updates on netty plugin being available? I would like to contribute as well @547426109 @jiaqifeng

[jiaqifeng]

@dinesh4747 The key problem is what information do you want to trace. Netty is just a tcp/udp framework, it provides little knowledge to help you understand your application. I suggest you trace the library or framework above the netty.

[ryankiki86]

The netty plugin can not work?neither server nor client

[aalinyu]

@jiaqifeng
the encoder and decoder of the packge to add and extract the trace info from upstream app to downstream app.

When I use react-netty , Why com.navercorp.pinpoint.plugin.netty.interceptor.http.HttpEncoderInterceptor not work

The log shows : AsyncContext not found

Why AsyncContext not found?

[aalinyu]

This is my code:

public void client3() {
        ConnectionProvider connectionProvider = ConnectionProvider.newConnection();
        HttpClient httpClient = HttpClient.create(connectionProvider);

        log.debug("begin");
        HttpClient.RequestSender request = httpClient.request(HttpMethod.GET);
        httpClient.headers(headers -> {
            System.out.println("头: " + headers.toString());
        }).request(HttpMethod.GET)
                .uri("http:https://pinpoint-web.msxfcloud.test/")
                .send(Mono.defer(() -> {
                    log.debug("doSend");
                    return Mono.empty();
                }))
                .responseContent()
                .doOnError(t -> t.printStackTrace())
                .map(buf -> {
                    log.debug("map");
                    return buf;
                }).subscribe(buf -> {
            byte[] data;
            if (buf.hasArray()) {
                data = buf.array();
            } else {
                data = new byte[buf.readableBytes()];
                buf.readBytes(data);
            }
            try {
                String s = new String(data, "utf-8");
                log.debug("RSP CONTENT: " + s);
            } catch (Exception e) {
                log.error("Catch Exception: ", e);
            }
        });

        log.debug("end");

        try {
            Thread.sleep(5 * 1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

[aalinyu]

@jiaqifeng
the encoder and decoder of the packge to add and extract the trace info from upstream app to downstream app.

When I use react-netty , Why com.navercorp.pinpoint.plugin.netty.interceptor.http.HttpEncoderInterceptor not work

The log shows : AsyncContext not found

Why AsyncContext not found?

I use pinpoint agent 2.1.0

[jiaqifeng]

@aalinyu

Currently I have no time working on this plugin. Wish somebody else could help. Also netty is hard to trace since it's so complecate.