zoukankan      html  css  js  c++  java

  • OSGi 系列（六）之服务的使用

    OSGi 系列（六）之服务的使用

    1. 为什么使用服务

    • 降低服务提供者和服务使用者直接的耦合，这样更容易重用组件
    • 隐藏了服务的实现细节
    • 支持多个服务的实现、这样你可以互换这实现

    2. 服务的使用

    2.1 服务的注册

    bundle 通过在框架的服务注册中心注册一个服务对象来发布一个服务。安装在 OSGi 环境下的其它 bundle 就可以访问到在框架中注册的服务对象。

    bundle 通过使用 BundleContext.registerService，在框架中注册一个服务对象：

    registerService(String, Object, Dictionary)   //用于一个服务接口的服务注册
registerService(String[], Object, Dictionary) //用于多个服务接口的服务注册
    • String 表示服务的接口
    • Object 表示服务的实现类
    • Dictionary 表示服务属性
    • 调用之后，返回 ServiceRegistration 对象

    2.2 服务的销毁

    ServiceRegistration.unregister()

    2.3 服务的属性

    属性 类型 常量 描述
    objectClass String[] OBJECTCLASS objectClass 属性包含了注册到框架中的服务对象所有实现的接口的集合。这个属性必须由框架自动设置
    service.id Long SERVICE_ID 每一个注册了的服务对象都由框架分配了一个惟一的service.id。将这个标志数字添加到服务对象的属性中。框架给每一个注册的服务对象分配一个惟一的标志值，这个值要比原来分配的任何值要大，也就是说是递增分配的。
    service.pid String SERVICE_PID service.pid属性是可选的，标记了服务对象的持久惟一标记。
    service.ranking Integer SERVICE_RANKING 服务的排行，当有多个服务的时候，会返回service.ranking值最大的那个服务
    service.description String SERVICE_DESCRIPTION service.description属性用于文档性的描述，这个属性是可选的
    service.vendor String SERVICE_VENDOR 这是一个可选属性，描述服务对象的开发商信息

    2.4 服务的查找

    查找服务时要分两步：

    bundleContext.getServiceReference() //1. 获取 ServiceReference 对象
bundleContext.getService()          //2. 获取真实的服务对象

    查找单个服务：

    bundleContext.getServiceReference() 要么返回 null，要么返回一个服务。如果有多个服务匹配，也只会返回一个服务。

    • 找 service.ranking 属性最高的。如果注册时为指定该属性，则默认值为0
    • 找 service ID 属性最小的。也就是最先注册的服务。

    查找多个服务：

    bundleContext.getServiceReferences(Clazz clazz, String filter)
bundleContext.getServiceReferences(String clazz, String filter)

    第二个参数接受标准的LDAP过滤字符串。示例:

    属性匹配：(vendor=Apache)、(count>3)
通配符：(vendor=Apache*)
判断某个属性是否存在：(vendor=)
条件非：(!(vendor=Apache))
条件与：(&(objectClass=com.edu.osgi.user.IUserService)(type=1))
条件或：(|(type=1)(type=2))

    3．实战演示

    3.1 新建 4 个 bundle，目录结构如下：

    图6.1 目录结构

    3.2 email-api 为接口

    package com.github.binarylei.email.api;

public interface EmailService {
    void sendEmail(String to, String title, String content);
}

    注意： email-api 要将接口暴露出去，配制如下：

    <Import-Package>org.osgi.framework</Import-Package>
<Export-Package>com.github.binarylei.email.api</Export-Package>

    3.3 email-service-139 实现

    package com.github.binarylei.email.service;

import com.github.binarylei.email.api.EmailService;

public class EmailService139 implements EmailService {

    public void sendEmail(String dest, String title, String content) {
        System.out.println("139 email send. dest=" + dest + ",title=" + title + ",content=" + content);
    }
}

    BundleActivator 如下：

    package com.github.binarylei.email.internal;

import com.github.binarylei.email.api.EmailService;
import com.github.binarylei.email.service.EmailService139;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceRegistration;

public class Activator implements BundleActivator {
    ServiceRegistration<EmailService> serviceRegistration;

    @Override
    public void start(BundleContext context) throws Exception {
        serviceRegistration = context.registerService(EmailService.class, new EmailService139(), null);
    }

    @Override
    public void stop(BundleContext context) throws Exception {
        serviceRegistration.unregister();
    }
}

    注意： email-service-139 要将引入 email-api 接口，配制如下：

    <Import-Package>org.osgi.framework,com.github.binarylei.email.api</Import-Package>
<Bundle-Activator>com.github.binarylei.email.internal.Activator</Bundle-Activator>

    3.4 email-service-163 实现

    与 email-service-139 类似

    3.5 email-client 服务的使用

    package com.github.binarylei.email.internal;

import com.github.binarylei.email.api.EmailService;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceReference;

public class Activator implements BundleActivator {
    @Override
    public void start(BundleContext context) throws Exception {
        //1. 获取所有的服务
        ServiceReference<?>[] refs = context.getAllServiceReferences(EmailService.class.getName(), null);
        if (refs != null) {
            for (ServiceReference ref : refs) {
                EmailService emailService = (EmailService) context.getService(ref);
                emailService.sendEmail("binarylei@qq.com", "OSGi", "OSGi Service");
            }
        }
        //2. 获取单个服务
        ServiceReference<?> ref = context.getServiceReference(EmailService.class.getName());
        if (ref != null) {
            EmailService emailService = (EmailService) context.getService(ref);
            emailService.sendEmail("binarylei@qq.com", "OSGi", "OSGi Service");
        }
    }

    @Override
    public void stop(BundleContext context) throws Exception {

    }
}

    注意： email-client 要将引入 email-api 接口，配制如下：

    <Import-Package>org.osgi.framework,com.github.binarylei.email.api</Import-Package>
<Bundle-Activator>com.github.binarylei.email.internal.Activator</Bundle-Activator>

    3.6 felix 测试

    将这 4 个 bundle 拷贝到 felix-framework-5.6.10/bundle 下，启动 felix

    图6.2 服务的测试

    4. 服务的属性使用

    4.1 服务添加属性

    分别给 email-service-163 和 email-service-139 添加属性 vendor

    @Override
public void start(BundleContext context) throws Exception {
    Dictionary properties = new Hashtable<>();
    properties.put("vendor", "163"); // 139
    serviceRegistration = context.registerService(EmailService.class, new EmailService163(), properties);
}

    4.2 根据服务属性获取对应的服务

    email-client 获取属性

    @Override
public void start(BundleContext context) throws Exception {
    // 根据属性获取163的服务
    ServiceReference<?>[] refs = context.getServiceReferences(EmailService.class.getName(), "(vendor=163)");
    if (refs != null) {
        for (ServiceReference ref : refs) {
            EmailService emailService = (EmailService) context.getService(ref);
            emailService.sendEmail("binarylei@qq.com", "OSGi", "OSGi Service");
        }
    }
}

    5. 服务工厂

    使用传统的方式获取的服务都是单例的，同一个服务，不管是在同一个 bundle, 还是在不同 bundle 中间获取。

    5.1 测试单例

    将 email-client-1.0.0.jar 复制一份 email-client-2.0.0.jar，修改 META-INF/MANIFEST.MF 的 Bundle-Version 为 2.0.0

    图6.3 测试单例

    5.2 ServiceFactory

    org.osgi.framework.ServiceFactory，使用服务工厂好处：

    1. 有时 service 需要知道是哪个 bundle 在使用它。例如 logger 服务，它需要在日志中记录是哪个 bundle 调用它的。
    2. 延迟初始化 Service
    3. 这对消费者是透明的，它不能知道提供服务的是普通 Service 还是 ServiceFactory
    4. 可以创建多种服务，根据参数 ServiceRegistration 来判断

    5.3 实例

    (1) email-service-163 添加 EmailServiceFactory 类：

    package com.github.binarylei.email.service;

import com.github.binarylei.email.api.EmailService;
import org.osgi.framework.Bundle;
import org.osgi.framework.ServiceFactory;
import org.osgi.framework.ServiceRegistration;

public class EmailServiceFactory implements ServiceFactory<EmailService> {

    @Override
    public EmailService getService(Bundle bundle, ServiceRegistration<EmailService> registration) {
        return new EmailService163();
    }

    @Override
    public void ungetService(Bundle bundle, ServiceRegistration<EmailService> registration, EmailService service) {
    }
}

    (2) 修改 Activator 类：

    @Override
public void start(BundleContext context) throws Exception {
    Dictionary properties = new Hashtable<>();
    properties.put("vendor", "163");
    serviceRegistration = context.registerService(EmailService.class.getName(), new EmailServiceFactory(), properties);
}

    (3) 更新 email-service-163，重启 email-client-1.0.0.jar 和 email-client-2.0.0.jar ，结果如下：

    图6.4 测试多例

    6. OSGi 服务

    核心服务：包管理、启动级别、权限管理、URL处理

    compendium 服务：

    • LOG Service(日志服务)
    • HTTP Service(注册servlet和资源)
    • Configuration Admin(配置管理)
    • Event Admin(事件通知)
    • Declarative Services(定义轻量级的面向服务的组件模型)
    • Blueprint(一个类似 IOC 容器的实现)
  • 相关阅读:
    入侵特斯拉——智能汽车安全性分析
    D-Link系列路由器漏洞挖掘入门
    工控安全入门之 Ethernet/IP
    浅谈JS数据类型存储问题
    【备忘】12306购票必杀技
    制作炫酷的专题页面
    杂记（下）
    杂记（上）
    跨域请求解决方案
    好用的表单验证插件
  • 原文地址：https://www.cnblogs.com/binarylei/p/8538831.html
Copyright © 2011-2022 走看看