首页 文章 精选 留言 我的

Storm的wordCounter计数器详解

2014-03-30 654
原文：http://www.maoxiangyi.cn/index.php/archives/362

拓扑

点击(此处)折叠或打开

  1. package cn.jd.storm;

  3. import backtype.storm.Config;
  4. import backtype.storm.LocalCluster;
  5. import backtype.storm.topology.TopologyBuilder;
  6. import backtype.storm.tuple.Fields;
  7. /**
  8.  * 功能说明：
  9.  * 设计一个topology，来实现对一个句子里面的单词出现的频率进行统计。
  10.  * 整个topology分为三个部分：
  11.  *         WordReader:数据源，负责发送单行文本记录（句子）
  12.  *         WordNormalizer:负责将单行文本记录（句子）切分成单词
  13.  *         WordCounter:负责对单词的频率进行累加
  14.  *
  15.  * @author 毛祥溢
  16.  * Email:frank@maoxiangyi.cn
  17.  * 2013-8-26 下午5:59:06
  18.  */
  19. public class TopologyMain {

  21.     /**
  22.      * @param args 文件路径
  23.      */
  24.     public static void main(String[] args)throws Exception {
  25.         // Storm框架支持多语言，在JAVA环境下创建一个拓扑，需要使用TopologyBuilder进行构建
  26.         TopologyBuilder builder = new TopologyBuilder();
  27.         /* WordReader类，主要是将文本内容读成一行一行的模式
  28.          * 消息源spout是Storm里面一个topology里面的消息生产者。
  29.          * 一般来说消息源会从一个外部源读取数据并且向topology里面发出消息：tuple。
  30.          * Spout可以是可靠的也可以是不可靠的。
  31.          * 如果这个tuple没有被storm成功处理，可靠的消息源spouts可以重新发射一个tuple，但是不可靠的消息源spouts一旦发出一个tuple就不能重发了。
  32.          *
  33.          * 消息源可以发射多条消息流stream。多条消息流可以理解为多中类型的数据。
  34.          * 使用OutputFieldsDeclarer.declareStream来定义多个stream，然后使用SpoutOutputCollector来发射指定的stream。
  35.          *
  36.          * Spout类里面最重要的方法是nextTuple。要么发射一个新的tuple到topology里面或者简单的返回如果已经没有新的tuple。
  37.          * 要注意的是nextTuple方法不能阻塞，因为storm在同一个线程上面调用所有消息源spout的方法。
  38.          *
  39.          * 另外两个比较重要的spout方法是ack和fail。storm在检测到一个tuple被整个topology成功处理的时候调用ack，否则调用fail。storm只对可靠的spout调用ack和fail。
  40.          */
  41.         builder.setSpout("word-reader",new WordReader());
  42.         /* WordNormalizer类，主要是将一行一行的文本内容切割成单词
  43.          *
  44.          * 所有的消息处理逻辑被封装在bolts里面。Bolts可以做很多事情：过滤，聚合，查询数据库等等。
  45.          * Bolts可以简单的做消息流的传递。复杂的消息流处理往往需要很多步骤，从而也就需要经过很多bolts。
  46.          * 比如算出一堆图片里面被转发最多的图片就至少需要两步：
  47.          *     第一步算出每个图片的转发数量。
  48.          *     第二步找出转发最多的前10个图片。（如果要把这个过程做得更具有扩展性那么可能需要更多的步骤）。
  49.          *
  50.          * Bolts可以发射多条消息流， 使用OutputFieldsDeclarer.declareStream定义stream，使用OutputCollector.emit来选择要发射的stream。
  51.          * Bolts的主要方法是execute, 它以一个tuple作为输入，bolts使用OutputCollector来发射tuple。
  52.          * bolts必须要为它处理的每一个tuple调用OutputCollector的ack方法，以通知Storm这个tuple被处理完成了，从而通知这个tuple的发射者spouts。
  53.          * 一般的流程是： bolts处理一个输入tuple, 发射0个或者多个tuple, 然后调用ack通知storm自己已经处理过这个tuple了。storm提供了一个IBasicBolt会自动调用ack。
  54.          *
  55.          *
  56.          */
  57.         builder.setBolt("word-normalizer", new WordNormalizer()).shuffleGrouping("word-reader");
  58.         /*
  59.          * 上面的代码和下面的代码中都设定了数据分配的策略stream grouping
  60.          * 定义一个topology的其中一步是定义每个bolt接收什么样的流作为输入。stream grouping就是用来定义一个stream应该如果分配数据给bolts上面的多个tasks。
  61.          * Storm里面有7种类型的stream grouping
  62.          *         Shuffle Grouping: 随机分组， 随机派发stream里面的tuple，保证每个bolt接收到的tuple数目大致相同。
  63.          *         Fields Grouping：按字段分组， 比如按userid来分组， 具有同样userid的tuple会被分到相同的Bolts里的一个task，
  64.          *             而不同的userid则会被分配到不同的bolts里的task。
  65.          *         All Grouping：广播发送，对于每一个tuple，所有的bolts都会收到。
  66.          *         Global Grouping：全局分组， 这个tuple被分配到storm中的一个bolt的其中一个task。再具体一点就是分配给id值最低的那个task。
  67.          *         Non Grouping：不分组，这stream grouping个分组的意思是说stream不关心到底谁会收到它的tuple。
  68.          *             目前这种分组和Shuffle grouping是一样的效果， 有一点不同的是storm会把这个bolt放到这个bolt的订阅者同一个线程里面去执行。
  69.          *         Direct Grouping： 直接分组， 这是一种比较特别的分组方法，用这种分组意味着消息的发送者指定由消息接收者的哪个task处理这个消息。
  70.          *             只有被声明为Direct Stream的消息流可以声明这种分组方法。而且这种消息tuple必须使用emitDirect方法来发射。
  71.          *             消息处理者可以通过TopologyContext来获取处理它的消息的task的id （OutputCollector.emit方法也会返回task的id）。
  72.          *         Local or shuffle grouping：如果目标bolt有一个或者多个task在同一个工作进程中，tuple将会被随机发生给这些tasks。
  73.          *             否则，和普通的Shuffle Grouping行为一致。
  74.          *
  75.          */
  76.         builder.setBolt("word-counter", new WordCounter(),1).fieldsGrouping("word-normalizer", new Fields("word"));
  77.  
  78.         /*
  79.          * storm的运行有两种模式: 本地模式和分布式模式.
  80.          * 1) 本地模式：
  81.          *         storm用一个进程里面的线程来模拟所有的spout和bolt. 本地模式对开发和测试来说比较有用。
  82.          *         你运行storm-starter里面的topology的时候它们就是以本地模式运行的， 你可以看到topology里面的每一个组件在发射什么消息。
  83.          * 2) 分布式模式：
  84.          *         storm由一堆机器组成。当你提交topology给master的时候， 你同时也把topology的代码提交了。
  85.          *         master负责分发你的代码并且负责给你的topolgoy分配工作进程。如果一个工作进程挂掉了， master节点会把认为重新分配到其它节点。
  86.          * 下面是以本地模式运行的代码:
  87.          *
  88.          * Conf对象可以配置很多东西， 下面两个是最常见的：
  89.          *        TOPOLOGY_WORKERS(setNumWorkers) 定义你希望集群分配多少个工作进程给你来执行这个topology.
  90.          *            topology里面的每个组件会被需要线程来执行。每个组件到底用多少个线程是通过setBolt和setSpout来指定的。
  91.          *            这些线程都运行在工作进程里面. 每一个工作进程包含一些节点的一些工作线程。
  92.          *            比如， 如果你指定300个线程，60个进程， 那么每个工作进程里面要执行6个线程， 而这6个线程可能属于不同的组件(Spout, Bolt)。
  93.          *            你可以通过调整每个组件的并行度以及这些线程所在的进程数量来调整topology的性能。
  94.          *        TOPOLOGY_DEBUG(setDebug), 当它被设置成true的话， storm会记录下每个组件所发射的每条消息。
  95.          *            这在本地环境调试topology很有用， 但是在线上这么做的话会影响性能的。
  96.          */
  97.         Config conf = new Config();
  98.         conf.setDebug(true);
  99.         conf.setNumWorkers(2);
  100.         conf.put("wordsFile","/root/workspace1/com.jd.storm.demo/src/main/resources/words.txt");
  101.         conf.setDebug(true);
  102.         conf.put(Config.TOPOLOGY_MAX_SPOUT_PENDING, 1);
  103.         /*
  104.          * 定义一个LocalCluster对象来定义一个进程内的集群。提交topology给这个虚拟的集群和提交topology给分布式集群是一样的。
  105.          * 通过调用submitTopology方法来提交topology， 它接受三个参数：要运行的topology的名字，一个配置对象以及要运行的topology本身。
  106.          * topology的名字是用来唯一区别一个topology的，这样你然后可以用这个名字来杀死这个topology的。前面已经说过了， 你必须显式的杀掉一个topology， 否则它会一直运行。
  107.          */
  108.         LocalCluster cluster = new LocalCluster();
  109.         cluster.submitTopology("wordCounterTopology", conf, builder.createTopology());
  110.         Thread.sleep(1000);
  111.         cluster.killTopology("wordCounterTopology");
  112.         cluster.shutdown();
  113.     }

  115. }

读句子

点击(此处)折叠或打开

  1. package cn.jd.storm;

  3. import java.io.BufferedReader;
  4. import java.io.FileNotFoundException;
  5. import java.io.FileReader;
  6. import java.util.Map;

  8. import backtype.storm.spout.SpoutOutputCollector;
  9. import backtype.storm.task.TopologyContext;
  10. import backtype.storm.topology.OutputFieldsDeclarer;
  11. import backtype.storm.topology.base.BaseRichSpout;
  12. import backtype.storm.tuple.Fields;
  13. import backtype.storm.tuple.Values;
  14. /**
  15.  *
  16.  * 功能说明：
  17.  *         主要是将文件内容读出来，一行一行
  18.  *
  19.  *     Spout类里面最重要的方法是nextTuple。
  20.  *     要么发射一个新的tuple到topology里面或者简单的返回如果已经没有新的tuple。
  21.  *     要注意的是nextTuple方法不能阻塞，因为storm在同一个线程上面调用所有消息源spout的方法。
  22.  *     另外两个比较重要的spout方法是ack和fail。
  23.  *     storm在检测到一个tuple被整个topology成功处理的时候调用ack，否则调用fail。
  24.  * storm只对可靠的spout调用ack和fail。
  25.  *
  26.  * @author 毛祥溢
  27.  * Email:frank@maoxiangyi.cn
  28.  * 2013-8-26 下午6:05:46
  29.  */
  30. public class WordReader extends BaseRichSpout {

  32.     private SpoutOutputCollector collector;
  33.     private FileReader fileReader;
  34.     private String filePath;
  35.     private boolean completed = false;
  36.     //storm在检测到一个tuple被整个topology成功处理的时候调用ack，否则调用fail。
  37.     public void ack(Object msgId) {
  38.         System.out.println("OK:"+msgId);
  39.     }
  40.     public void close() {}
  41.     //storm在检测到一个tuple被整个topology成功处理的时候调用ack，否则调用fail。
  42.     public void fail(Object msgId) {
  43.         System.out.println("FAIL:"+msgId);
  44.     }
  45.  
  46.   /*
  47.    * 在SpoutTracker类中被调用，每调用一次就可以向storm集群中发射一条数据（一个tuple元组），该方法会被不停的调用
  48.    */
  49.     public void nextTuple() {
  50.         if(completed){
  51.             try {
  52.                 Thread.sleep(1000);
  53.             } catch (InterruptedException e) {
  54.             }
  55.             return;
  56.         }
  57.         String str;
  58.         BufferedReader reader =new BufferedReader(fileReader);
  59.         try{
  60.             while((str = reader.readLine()) != null){
  61.                 System.out.println("WordReader类 读取到一行数据："+ str);
  62.                 this.collector.emit(new Values(str),str);
  63.                 System.out.println("WordReader类 发射了一条数据："+ str);
  64.             }
  65.         }catch(Exception e){
  66.             throw new RuntimeException("Error reading tuple",e);
  67.         }finally{
  68.             completed = true;
  69.         }
  70.     }
  71.  
  72.     public void open(Map conf, TopologyContext context,SpoutOutputCollector collector) {
  73.         try {
  74.             this.fileReader = new FileReader(conf.get("wordsFile").toString());
  75.         } catch (FileNotFoundException e) {
  76.             throw new RuntimeException("Error reading file ["+conf.get("wordFile")+"]");
  77.         }
  78.         this.filePath    = conf.get("wordsFile").toString();
  79.         this.collector = collector;
  80.     }
  81.     /**
  82.      * 定义字段id，该id在简单模式下没有用处，但在按照字段分组的模式下有很大的用处。
  83.      * 该declarer变量有很大作用，我们还可以调用declarer.declareStream();来定义stramId，该id可以用来定义更加复杂的流拓扑结构
  84.      */
  85.     public void declareOutputFields(OutputFieldsDeclarer declarer) {
  86.         declarer.declare(new Fields("line"));
  87.     }
  88. }

将句子切割成单词

点击(此处)折叠或打开

  1. package cn.jd.storm;

  3. import backtype.storm.topology.BasicOutputCollector;
  4. import backtype.storm.topology.OutputFieldsDeclarer;
  5. import backtype.storm.topology.base.BaseBasicBolt;
  6. import backtype.storm.tuple.Fields;
  7. import backtype.storm.tuple.Tuple;
  8. import backtype.storm.tuple.Values;
  9. /**
  10.  *
  11.  * 功能说明：
  12.  *     将一行文本切割成单词，并封装collector中发射出去
  13.  *
  14.  * @author 毛祥溢
  15.  * Email:frank@maoxiangyi.cn
  16.  * 2013-8-26 下午6:05:59
  17.  */
  18. public class WordNormalizer extends BaseBasicBolt {

  20.     public void cleanup() {
  21.         System.out.println("将一行文本切割成单词，并封装collector中发射出去 ---完毕！");
  22.     }
  23.     
  24.     /**
  25.      * 接受的参数是WordReader发出的句子，即input的内容是句子
  26.      * execute方法，将句子切割形成的单词发出
  27.      */
  28.     public void execute(Tuple input, BasicOutputCollector collector) {
  29.         String sentence = input.getString(0);
  30.         String[] words = sentence.split(" ");
  31.         System.out.println("WordNormalizer类 收到一条数据，这条数据是： "+ sentence);
  32.         for(String word : words){
  33.             word = word.trim();
  34.             if(!word.isEmpty()){
  35.                 word = word.toLowerCase();
  36.                 System.out.println("WordNormalizer类 收到一条数据，这条数据是： "+ sentence+"数据正在被切割，切割出来的单词是 "+ word);
  37.                 collector.emit(new Values(word));
  38.             }
  39.         }
  40.     }
  41.  
  42.     /**
  43.     * 定义字段id，该id在简单模式下没有用处，但在按照字段分组的模式下有很大的用处。
  44.     * 该declarer变量有很大作用，我们还可以调用declarer.declareStream();来定义stramId，该id可以用来定义更加复杂的流拓扑结构
  45.     */
  46.     public void declareOutputFields(OutputFieldsDeclarer declarer) {
  47.         declarer.declare(new Fields("word"));
  48.     }
  49. }

计数器WordCounter

点击(此处)折叠或打开

  1. package cn.jd.storm;

  3. import java.util.HashMap;
  4. import java.util.Map;

  6. import backtype.storm.task.TopologyContext;
  7. import backtype.storm.topology.BasicOutputCollector;
  8. import backtype.storm.topology.OutputFieldsDeclarer;
  9. import backtype.storm.topology.base.BaseBasicBolt;
  10. import backtype.storm.tuple.Tuple;
  11. /**
  12.  *
  13.  * 功能说明：
  14.  *     实现计数器的功能，第一次将collector中的元素存放在成员变量counters（Map）中.
  15.  *     如果counters（Map）中已经存在该元素，getValule并对Value进行累加操作。
  16.  *
  17.  * @author 毛祥溢
  18.  * Email:frank@maoxiangyi.cn
  19.  * 2013-8-26 下午6:06:07
  20.  */
  21. public class WordCounter extends BaseBasicBolt {

  23.     private static final long serialVersionUID = 5678586644899822142L;
  24.     Integer id;
  25.     String name;
  26.      //定义Map封装最后的结果
  27.     MapString, Integer> counters;
  28.  
  29.     /**
  30.      * 在spout结束时被调用，将最后的结果显示出来
  31.      *
  32.      * 結果:
  33.      * -- Word Counter [word-counter-2] --
  34.      * really: 1
  35.      * but: 1
  36.      * application: 1
  37.      * is: 2
  38.      * great: 2
  39.      */
  40.     @Override
  41.     public void cleanup() {
  42.         System.out.println("-- Word Counter ["+name+"-"+id+"] --");
  43.         for(Map.EntryString, Integer> entry : counters.entrySet()){
  44.             System.out.println(entry.getKey()+": "+entry.getValue());
  45.         }
  46.         System.out.println("实现计数器的功能 --完畢！");
  47.     }
  48.  
  49.     /**
  50.      * 初始化操作
  51.      */
  52.     @Override
  53.     public void prepare(Map stormConf, TopologyContext context) {
  54.         this.counters = new HashMapString, Integer>();
  55.         this.name = context.getThisComponentId();
  56.         this.id = context.getThisTaskId();
  57.     }
  58.  
  59.     public void declareOutputFields(OutputFieldsDeclarer declarer) {}
  60.  
  61.     /**
  62.      * 实现计数器的功能，第一次将collector中的元素存放在成员变量counters（Map）中.
  63.      * 如果counters（Map）中已经存在该元素，getValule并对Value进行累加操作。
  64.      */
  65.     public void execute(Tuple input, BasicOutputCollector collector) {
  66.         String str = input.getString(0);
  67.         System.out.println("WordCounter 计数器收到单词 "+ str);
  68.         if(!counters.containsKey(str)){
  69.             counters.put(str, 1);
  70.         }else{
  71.             Integer c = counters.get(str) + 1;
  72.             counters.put(str, c);
  73.         }
  74.     }
  75. }

数据格式
storm ni great he he xi wang
test haha heihei very
are mao xiang yi jd

运行日志

WordReader类 发射了一条数据：storm ni great he he xi wang
WordReader类 发射了一条数据：test haha heihei very

WordNormalizer类 收到一条数据，这条数据是：    storm ni great he he xi wang
WordNormalizer类 收到一条数据，这条数据是：    storm ni great he he xi wang数据正在被切割，切割出来的单词是 storm
WordNormalizer类 收到一条数据，这条数据是：    storm ni great he he xi wang数据正在被切割，切割出来的单词是 ni
WordNormalizer类 收到一条数据，这条数据是：    storm ni great he he xi wang数据正在被切割，切割出来的单词是 great
WordNormalizer类 收到一条数据，这条数据是：    storm ni great he he xi wang数据正在被切割，切割出来的单词是 he
WordNormalizer类 收到一条数据，这条数据是：    storm ni great he he xi wang数据正在被切割，切割出来的单词是 he
WordNormalizer类 收到一条数据，这条数据是：    storm ni great he he xi wang数据正在被切割，切割出来的单词是 xi
WordNormalizer类 收到一条数据，这条数据是：    storm ni great he he xi wang数据正在被切割，切割出来的单词是 wang
WordCounter 计数器收到单词 storm
WordCounter 计数器收到单词 ni
WordCounter 计数器收到单词 great
WordCounter 计数器收到单词 he
WordCounter 计数器收到单词 he
WordCounter 计数器收到单词 xi
WordCounter 计数器收到单词 wang


WordNormalizer类 收到一条数据，这条数据是：    test haha heihei very
WordNormalizer类 收到一条数据，这条数据是：    test haha heihei very 数据正在被切割，切割出来的单词是 test
WordNormalizer类 收到一条数据，这条数据是：    test haha heihei very 数据正在被切割，切割出来的单词是 haha
WordNormalizer类 收到一条数据，这条数据是：    test haha heihei very 数据正在被切割，切割出来的单词是 heihei
WordNormalizer类 收到一条数据，这条数据是：    test haha heihei very 数据正在被切割，切割出来的单词是 very
WordCounter 计数器收到单词 test
WordCounter 计数器收到单词 haha
WordCounter 计数器收到单词 heihei
WordCounter 计数器收到单词 very


WordReader类 发射了一条数据：are mao xiang yi jd
WordNormalizer类 收到一条数据，这条数据是：    are mao xiang yi jd
WordNormalizer类 收到一条数据，这条数据是：    are mao xiang yi jd 数据正在被切割，切割出来的单词是 are
WordNormalizer类 收到一条数据，这条数据是：    are mao xiang yi jd 数据正在被切割，切割出来的单词是 mao
WordNormalizer类 收到一条数据，这条数据是：    are mao xiang yi jd 数据正在被切割，切割出来的单词是 xiang
WordNormalizer类 收到一条数据，这条数据是：    are mao xiang yi jd 数据正在被切割，切割出来的单词是 yi
WordNormalizer类 收到一条数据，这条数据是：    are mao xiang yi jd 数据正在被切割，切割出来的单词是 jd
WordCounter 计数器收到单词 are
WordCounter 计数器收到单词 mao
WordCounter 计数器收到单词 xiang
WordCounter 计数器收到单词 yi
WordCounter 计数器收到单词 jd

-- Word Counter [word-counter-2] --
xi: 1
test: 1
heihei: 1
haha: 1
he: 2
storm: 1
wang: 1
jd: 1
xiang: 1
great: 1
are: 1
ni: 1
yi: 1
very: 1
mao: 1
实现计数器的功能 --完畢！
将一行文本切割成单词，并封装collector中发射出去 ---完毕！
上一篇 下一篇
优秀的个人博客,低调大师

微信关注我们

原文链接：https://yq.aliyun.com/articles/497462

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

hive导入nginx日志

将nginx日志导入到hive中的方法 1 在hive中建表 CREATETABLEapachelog(ipaddressSTRING,identdSTRING,userSTRING,finishtimeSTRING,requestlinestring,returncodeINT,sizeINT,refererstring,agentstring)ROWFORMATSERDE'org.apache.hadoop.hive.serde2.dynamic_type.DynamicSerDe'WITHSERDEPROPERTIES('serialization.format'='org.apache.hadoop.hive.serde2.thrift.TCTLSeparatedProtocol','quote.delim'='("|\\[|\\])','field.delim'='','serialization.null.format'='-')STOREDASTEXTFILE; 导入后日志格式为 203.208.60.91--05/May/2011:01:18:47+0800GET...
2014-03-28
702
上一篇

Hadoop专业解决方案-第5章 开发可靠的MapReduce应用

本章主要内容： 1、利用MRUnit创建MapReduce的单元测试。 2、MapReduce应用的本地实例。 3、理解MapReduce的调试。 4、利用MapReduce防御式程序设计。 在WOX.COM下载本章源代码 本章在wox.com网站的源码可以在www.wiley.com/go/prohadoopsolutions的源码下载标签找到。第五章的源码根据本章的内容各自分别命名放在了第五章下载目录中。 到目前为止，你应该对MapReduce体系结构，应用程序设计，和定制MapReduce扩展程序很熟悉了。本章讨论如何对测试程序通过有影响力（leveraging）的单元测试和基于Hadoop的设备创建可靠的MapReduce代码。你也可以从中学到不同的防御式编程技术来处理部分被破坏的（corrupted）数据的方法。 MapReduce应用的单元测试 缺陷（Bugs）总在代码中存在，这是一个不争的事实——你写的代码越多，你也会遇到越多的缺陷（Bugs）。即使是最伟大的程序员也极少写没有缺陷(bug)的代码。这就是为什么测试成为了代码开发中完整中的（integral）一部分，因此许...
2014-04-01
661
下一篇

相关文章

发表评论

资源下载

更多资源
Mario

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

时间: 2025-12-12 大小: 211.28KB 下载: 54次
腾讯云软件源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

时间: 2025-12-28 大小: 1MB 下载: 4次
Nacos

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

时间: 2025-12-21 大小: 189MB 下载: 2次
Sublime Text

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。

时间: 2025-12-03 大小: 9.84MB 下载: 39次
手机查看

扫码在手机上查看文章

扫描二维码，手机阅读更方便

热门标签
HarmonyOS6 Gemini3 Docker Rocky Nacos3 Redis SpringCloud Service Mesh SpringBoot4 Kubernetes OpenAi Jdk25 DeepSeek

欢迎您来访！

登录后，您将获得更多功能！
热门文章
联系我们

有任何问题或合作意向欢迎联系我们

Email: 99873273@qq.com

QQ: 99873273

用户登录
用户注册