小编Sou*_*nta的帖子

我正在寻找在无线网络(802.11)上保护UDP流量(主要是实时视频)的选项.除数据报传输层安全性(DTLS)之外的任何建议？

谢谢.

关于Scala列表中的模式匹配,我有点困惑.

例如.

    val simplelist: List[Char] = List('a', 'b', 'c', 'd')

    //> simplelist  : List[Char] = List(a, b, c, d)

    def simple_fun(list: List[Char]) = list match {
           case (x:Char) :: (y:List[Char]) => println(x)
           case _ => Nil
     }                                                 
   //> simple_fun: (list: List[Char])Any

   simple_fun(simplelist)                            

   //> a
   //| res0: Any = ()

目前只打印一行输出.它是否应该在列表的每个元素上运行/模式匹配？

编辑:我修复了编译错误并复制了REPL的输出.

我正在尝试编写执行以下操作的拓扑:

1. 订阅Twitter订阅源的订阅源(基于关键字)
2. 聚合螺栓,聚合集合中的许多推文(比如N)并将它们发送给打印机螺栓
3. 一个简单的螺栓,可以立即将集合打印到控制台.

实际上我想对集合进行更多处理.

我在本地测试它,看起来它正在工作.但是,我不确定我是否正确设置了螺栓上的分组,以及在部署在实际风暴群上时这是否可以正常工作.如果有人可以帮助审查此拓扑并建议任何错误,更改或改进,我将不胜感激.

谢谢.

这就是我的拓扑结构.

builder.setSpout("spout", new TwitterFilterSpout("pittsburgh"));
   builder.setBolt("sampleaggregate", new SampleAggregatorBolt())
                .shuffleGrouping("spout");
   builder.setBolt("printaggreator",new PrinterBolt()).shuffleGrouping("sampleaggregate");

聚合螺栓

public class SampleAggregatorBolt implements IRichBolt {

    protected OutputCollector collector;
    protected Tuple currentTuple;
    protected Logger log;
    /**
     * Holds the messages in the bolt till you are ready to send them out
     */
    protected List<Status> statusCache;

    @Override
    public void prepare(Map stormConf, TopologyContext context,
                        OutputCollector collector) {
        this.collector = collector;

        log = Logger.getLogger(getClass().getName());
        statusCache = new ArrayList<Status>();
    }

    @Override
    public void execute(Tuple tuple) { …

我正在对数据流执行一些分析并在Redis频道上发布结果.消费者订阅这些频道并获得实时数据馈送.所有历史数据分析结果都将丢失.

现在我想添加在Redis中存储历史数据的功能,以便消费者可以查询这些历史数据(主要是按时间).由于分析结果按时间划分,将结果存储在Redis中的好设计是什么？

我正在尝试重构/重新设计Android应用.目前,我有一个UI活动(Activity 1)创建一个DataThread.该线程负责网络I/O,并通过a与UI活动交互(提供数据)handler.

现在,我想添加另一个活动(带有视频的新UI屏幕) - Activity 2.Activity 1仍然是主要的活动.Activity 2将在用户单击按钮时调用Activity 1.Activity 2的数据也来自于 DataThread.

我的想法是把我的逻辑DataThread放在Android Service(DataService)中.我的问题是 - 可以在活动上同时绑定我的活动DataService吗？有没有办法告诉服务只为特定活动提供数据？

欢迎任何其他想法？

提前致谢.

由于某种原因,以下代码在Windows XP上不起作用.

new URL("file://" + tempfile.getAbsolutePath());

我正在使用Java 1.6.

Java(TM) SE Runtime Environment (build 1.6.0_31-b05)
Java HotSpot(TM) Client VM (build 20.6-b01, mixed mode, sharing)

但是,相同的代码在OS X(Lion)和Java 1.6中运行良好

java version "1.6.0_29"
Java(TM) SE Runtime Environment (build 1.6.0_29-b11-402-11M3527)
Java HotSpot(TM) 64-Bit Server VM (build 20.4-b02-402, mixed mode)

使用Java 1.6的Linux(Linux 2.6.32-38-generic#83-Ubuntu x86_64 GNU/Linux)

java version "1.6.0_26"
Java(TM) SE Runtime Environment (build 1.6.0_26-b03)
Java HotSpot(TM) 64-Bit Server VM (build 20.1-b02, mixed mode)

基于此,上面的代码应该可行.

寻找将语音转换为文本的库(使用Java或Python API).100%的准确性不是绝对的要求,因为我只需要为原型进行一些实验.理想情况下,它应该接受输入文件(例如,.wav)并将输出作为文本返回.

谢谢.

如果我想获得List中的唯一元素,我可以做一个distinct或调用toSet.toList.哪个更有效,为什么？还有其他有效的方法吗？我的理解是,distinct这也将维持秩序,而toSet.toList不会.

scala> val mylist = List(1,2,3,3,4,4,4,5,6,6,6,6,7)
mylist: List[Int] = List(1, 2, 3, 3, 4, 4, 4, 5, 6, 6, 6, 6, 7)

scala> mylist.distinct
res11: List[Int] = List(1, 2, 3, 4, 5, 6, 7)

scala> mylist.toSet.toList
res12: List[Int] = List(5, 1, 6, 2, 7, 3, 4)

在pub-sub的情况下,Redis使用什么机制将消息保存在内存中？如果没有客户订阅消息会发生什么？Redis会缓冲它们吗？有没有办法配置分钟.最多 每个频道分配的内存？

我有一堆现有的REST服务(下面的#1和#2),它们运行在仅在内部使用的不同端点上.现在我想使用Spray在外部公开一些REST API(API-1和API-2),因为这个外部端点还将提供一些额外的API(API-3,API-4).

是否有一种简单/推荐的方法将外部REST请求转发到我的新端点到现有REST端点？