JAVA一个接口多个实现逐个调用

JQ实验室

发布于 2022-02-10 14:13:37

1.6K00

代码可运行

文章被收录于专栏：实用技术实用技术

运行总次数：0

代码可运行

经测试确认，当一个接口有多个实现时，调用时只会执行一个

有时候需要多个实现调用，方法示例如下：

public interface TransCallbackInterface {
    
    public void callback(String taskId, int code, String fixed);
    
}

@Component
public class TransCallbackDy implements  InitializingBean,TransCallbackInterface{

    @Override
    public void callback(String taskId, int code, String fixed) {
        System.out.println("TransCallback");
    }

@Component
public class TransCallbackDy implements  InitializingBean, TransCallbackInterface{

    @Override
    public void callback(String taskId, int code, String fixedInfo) {
        System.out.println("TransCallback");
    }

调用方式：

@Component
public class FileTransferShedule implements InitializingBean, DisposableBean {

@Override
    public void afterPropertiesSet() throws Exception {
        
    }

@Override
    public void destroy() throws Exception {
        logger.debug("service closed");

    }


    private static List<TransCallbackInterface> processors = new ArrayList<TransCallbackInterface>();
    
    public static void registerCallbackProcessor(
            TransCallbackInterface processor) {
        synchronized (processors) {
            processors.add(processor);
        }
    }

    public static void unregisterCallbackProcessor(
            TransCallbackInterface processor) {
        synchronized (processors) {
            processors.remove(processor);
        }
    }

public void callback(HttpServletRequest request)  {
    
        logger.debug("回调接口测试");
        try {
            Throwable t = null;
            synchronized (processors) {
                for (TestCallbackInterface processor : processors) {
                    try {
                        processor.callback();
                    } catch (Throwable e) {
                        t = e;
                    }
                }
            }
            if (t != null) {
                throw new IOException(t);
            }
            System.out.println("test");

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2020-05-15 ，如有侵权请联系 cloudcommunity@tencent.com 删除

测试