0

我正在尝试在 OSGi 中构建一个可以读取给定格式文件的服务。

服务接口如下所示：

public interface FileReaderService {
    /**
     * Reads the given file.
     * @param filePath Path of the file to read
     * @return the data object built from the file
     * @throws IOException if there is an error while reading the file
     */
    Data readFile(Path filePath) throws IOException;

    /**
     * Detects if the format of the provided file is supported.
     * @param filePath the file to check
     * @return true if the format of the file is supported, false otherwise
     * @throws IOException if there is an error while reading the file
     */
    boolean isFormatSupported(Path filePath) throws IOException;
}

Data 对象是一个类，它定义了要读取的文件的数据结构（它们应该包含相同类型的数据）。

这个想法是有不同的服务实现，例如：

public class TxtFileReader implements FileReaderService {

    @Override
    public Data readFile(Path filePath) throws IOException {
            // Do something smart with the file
            return data;
        }
    }

    @Override
    public boolean isFormatSupported(Path filePath) throws IOException {
        PathMatcher matcher = FileSystems.getDefault().getPathMatcher("glob:*.txt");
        return matcher.matches(filePath);
    }
}

还可能有其他实现，例如 XmlFileReader、MdFileReader 等。

最后，我想要一个像这样的 FileReaderFactory：

@Component
public class FileReaderFactory implements FileReaderService {

    private List<FileReaderService> availableServices = new ArrayList<>();

    @Override
    public Data readFile(Path filePath) throws IOException {

        for (FileReaderService reader : availableServices) {
            if (reader.isFormatSupported(filePath)) {
                return reader.readFile(filePath);
            }
        }

        return null;
    }

    @Override
    public boolean isFormatSupported(Path filePath) throws IOException {
        for (FileReaderService reader : availableServices) {
            if (reader.isFormatSupported(filePath)) {
                return true;
            }
        }
        return false;
    }
}

我想要的是 DS 在工厂列表中动态注入 FileReaderServices。根据提供的服务数量，我会支持（或不支持）给定的文件格式。

我的问题是：

1）这对DS可行吗？

2）如果是，如何使用DS注释来做到这一点？

3）如果没有，你会怎么做？

谢谢

编辑：我尝试了 Christian 的解决方案，但它没有工作（还）。完整代码可以在这里下载：https ://github.com/neopium/FileReader

4

2 回答 2

2

使用@Reference 注释列表：

@Reference(service = FileReaderService.class)
private List<FileReaderService> availableServices;

您需要 DS 1.3 才能工作。最新的 felix scr 版本支持这一点。

我不建议将 FileReaderFactory 导出为 FileReaderService，因为它可能会导致递归。

于 2016-01-10T18:25:43.750 回答
0

正如 Christian Schneider 所指出的，解决方案是使用 @Reference 注释。

然而，当我按照他的回答中指定的方式使用它时，Karaf 确实崩溃了：

Cannot register Component
org.osgi.service.component.ComponentException: Component org.test.reader.service.factory.FileReaderFactory validation failed: Field value type must not be set for unary field references.

通过查看 Felix SCR 源代码，我在 org.apache.felix.scr.impl.metadata.ReferenceMetadata 类中发现了导致异常的行：

// field value type
if ( !m_isMultiple )
{
    // value type must not be specified for unary references
    if ( m_field_collection_type != null )
    {
        throw componentMetadata.validationFailure( "Field value type must not be set for unary field references." );
    }
}

似乎 Felix SCR 不高兴，因为属性 m_field_collection_type 在组件 XML 中设置为“服务”（即不为空），而没有指定基数...

因此，我像这样更改了我的注释：

@Reference(cardinality = ReferenceCardinality.AT_LEAST_ONE)
private List<FileReaderService> availableServices;

我还添加了一个工厂服务消费者来测试应用程序并且它可以工作！

对于那些感兴趣的人，可以在此处获得固定的源代码： https ://github.com/neopium/FileReader

于 2016-01-14T14:59:26.110 回答