Помогите разработка плагина с Netty, создание АПИ, помогите

Ну тебе этого не достаточно, эт простой экзампл юза listenablefuture

 

ААААА у меня мозг скоро взорвётся, нечего не понятно. просто скажу, можешь свой текст на русский перевести.

 

Стой их с Java 9 идёт?

 

Так да?

PHP:

implements ListenableFuture<Boolean>

Вот методы

Код:

  [php]  public void addListener(Runnable runnable, Executor executor) {

    }

    public boolean cancel(boolean mayInterruptIfRunning) {
        return false;
    }

    public boolean isCancelled() {
        return false;
    }

    public boolean isDone() {
        return false;
    }

    public Boolean get() throws InterruptedException, ExecutionException {
        return null;
    }

    public Boolean get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
        return null;[/php]
    }

И что в методах писать?

 

Я тебе просто посоветовал удобный интерфейс, реализация протокола на твоей совести

 

И что в методах писать?

 

Я че знаю реализацию твоего протокола?

 

За что это методы отвечают?

 

Я тебе привел удобный интерфейс чтою юзать его, читай ява доки. Можешь свой интерфейс сделать

 

Ну вас класс, как можно реализовать, хотя бы на пальцах.

PHP:

public class ClientHandler extends ChannelInboundHandlerAdapter implements ListenableFuture<Economick>{
    private ByteBuf buf;
    private static HashMap<String,Economick> list;



    static void loadMap(){
        list = new HashMap<String, Economick>();
        list.put("ttestf",new Economick("fd","fd",2,2,true, "ADD"));
    }
    static Economick getData(String name){


        if(list.containsKey(name)){
            Economick data = list.get(name);
            list.remove(name);
            return data;
        }else{
            return null;
        }
    }

    public static void putEco(Economick e){
        list.put(e.getName(), e);
    }

    @Override
    public void handlerAdded(ChannelHandlerContext ctx) {
        buf = ctx.alloc().buffer(4); // (1)
    }

    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) {
        buf.release(); // (1)
        buf = null;
    }


    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        ByteBuf m = (ByteBuf) msg;
        String  s= m.toString(Charset.forName("UTF8"));
        for(String q : s.split(" /$/ ")){
            String[] type = q.split(" /%/ ");
           Load.getLoader(type[0]).event(type[1]);
        }

        buf.writeBytes(m); // (2)
        m.release();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }


    public void addListener(Runnable runnable, Executor executor) {

    }

    public boolean cancel(boolean mayInterruptIfRunning) {
        return false;
    }

    public boolean isCancelled() {
        return false;
    }

    public boolean isDone() {
        return false;
    }

    public Economick get() throws InterruptedException, ExecutionException {
        return null;
    }

    public Economick get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
        return null;
    }
}


 

Кто-то ещё может подсказать?

 

Я просто уточнить.
CompletableFuture наследует(или что типо) ListenableFuture?
Можно попробовать использовать CompletableFuture?

 

ListenableFuture интерфейс от гуава, completablefuture от явы самой. По идеи с ListenableFuture тебе было бы легче работать для таких целей, но можешь и комплитэбл юзать

 

До меня не доходит как это сделать, что-бы главный поток не останавливался , Всё что я могу придумать это цикл пока результат не появится.

 

А в чем суть то? Может тебе подойдет майновский упрощенный протокол из моего core?

 

А на чём он?

 

netty

 

Просто спрошу, не хочу в коде копаться, что твой плагин может, или это API, то что api может?

 

Гуишка с серверами готовая есть, в качестве примера. Сервера разделяются через мотд.
В целом это готовый сокет сервер-клиент.

 

Добавить еще логику будет просто, основа есть.