对Storm的DRPC进行权限控制，
并且设计相应的测试验证。

1.集群安装

请参考Storm集群安装Version1.0.1

2.使用DRPC功能

请参考Storm集群使用DRPC功能Version1.0.1
预置如下数据：
在Strom集群上面启动DRPC进程，
并且提交了DRPC的topology，
方法名称为exclamation。

3.开启DRPC的权限控制

在storm.yaml文件中开启DRPC的权限控制：

drpc.authorizer: "org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer"
drpc.authorizer.acl.filename: "drpc-auth-acl.yaml"
drpc.authorizer.acl.strict: true

在conf目录下新建drpc-auth-acl.yaml文件，
配置内容如下：

drpc.authorizer.acl:
  "exclamation":
    "client.users":
      - "alice"
      - "kafka"
    "invocation.user": "stormna"

说明，配置用户kafka和alice可以通过客户端调用drpc的方法exclamation，
client.users指定的用户可以执行的操作为operation:execute，
invocation.user可以执行的操作operation:failRequest,fetchRequest,result，
当drpc.authorizer.acl.strict为false时，
意为permissive宽容，
即没有配置权限控制的方法可以被任意用户执行，
而在配置文件中指定了控制权限的方法还需要匹配才能执行。
当drpc.authorizer.acl.strict为ture时，
只有在配置文件中的用户才能执行，
不在则拒绝，即为严格的白名单。

4.重启Storm集群

配置完成后重新启动storm集群，包括nimbus，drpc，
登陆Storm UI管理台可以看到新的配置项已经生效。

5.客户端验证

使用DRPCClientTest.java类中对于exclamation的客户端调用代码，
具体代码请参考Storm集群使用DRPC功能Version1.0.1的第7章节，
打成名称为drpctest.jar的jar包，
然后上传到Linux的storm用户下面，
执行如下测试命令：
java -jar drpctest.jar hi
未授权用户会抛出异常：

Exception in thread "main" AuthorizationException(msg:DRPC request 'execute' for 'unknown' user is not authorized)
    at org.apache.storm.generated.DistributedRPC$execute_result$execute_resultStandardScheme.read(DistributedRPC.java:1231)
    at org.apache.storm.generated.DistributedRPC$execute_result$execute_resultStandardScheme.read(DistributedRPC.java:1200)
    at org.apache.storm.generated.DistributedRPC$execute_result.read(DistributedRPC.java:1134)
    at org.apache.storm.thrift.TServiceClient.receiveBase(TServiceClient.java:86)
    at org.apache.storm.generated.DistributedRPC$Client.recv_execute(DistributedRPC.java:106)
    at org.apache.storm.generated.DistributedRPC$Client.execute(DistributedRPC.java:92)
    at org.apache.storm.utils.DRPCClient.execute(DRPCClient.java:60)
    at test.zte.storm.drpc.DRPCClientTest.main(DRPCClientTest.java:28)

登陆到kafka用户，
执行同样的测试命令：
java -jar drpctest.jar hi
正常返回结果:

input:hi, result:hi!

用户kafka执行成功，而storm执行失败，
是因为我们在drpc-auth-acl.yaml给kafka配置了权限，
而没有给storm用户权限。