前端技术
HTML
CSS
Javascript
前端框架和UI库
VUE
ReactJS
AngularJS
JQuery
NodeJS
JSON
Element-UI
Bootstrap
Material UI
服务端和客户端
Java
Python
PHP
Golang
Scala
Kotlin
Groovy
Ruby
Lua
.net
c#
c++
后端WEB和工程框架
SpringBoot
SpringCloud
Struts2
MyBatis
Hibernate
Tornado
Beego
Go-Spring
Go Gin
Go Iris
Dubbo
HessianRPC
Maven
Gradle
数据库
MySQL
Oracle
Mongo
中间件与web容器
Redis
MemCache
Etcd
Cassandra
Kafka
RabbitMQ
RocketMQ
ActiveMQ
Nacos
Consul
Tomcat
Nginx
Netty
大数据技术
Hive
Impala
ClickHouse
DorisDB
Greenplum
PostgreSQL
HBase
Kylin
Hadoop
Apache Pig
ZooKeeper
SeaTunnel
Sqoop
Datax
Flink
Spark
Mahout
数据搜索与日志
ElasticSearch
Apache Lucene
Apache Solr
Kibana
Logstash
数据可视化与OLAP
Apache Atlas
Superset
Saiku
Tesseract
系统与容器
Linux
Shell
Docker
Kubernetes
[企业信息化]的搜索结果
这里是文章列表。热门标签的颜色随机变换,标签颜色没有特殊含义。
点击某个标签可搜索标签相关的文章。
点击某个标签可搜索标签相关的文章。
Flink
...正有价值的、有意义的信息,这种方式可以说是一种高级的数据处理技术。 二、应用场景 1. 实时监控系统 在实时监控系统中,我们需要从大量的实时数据流中获取有价值的信息,例如设备故障、异常行为等。Flink CEP可以帮助我们实时地发现这些事件,并及时采取措施。 java StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); DataStream> stream = env.addSource(new DataStreamSource<>(new FileInputFormat<>("file:///path/to/input/file"))).map(new MapFunction, Tuple2>() { @Override public Tuple2 map(Tuple2 value) throws Exception { // 将字符串转为整数 return new Tuple2<>(value.f0, Integer.parseInt(value.f1)); } }); Pattern, Tuple2> pattern = Pattern., Tuple2>begin("start") .where(new FilterFunction>() { @Override public boolean filter(Tuple2 value) throws Exception { // 判断是否满足条件 return value.f1 > 10; } }) .next("middle") .where(new FilterFunction>() { @Override public boolean filter(Tuple2 value) throws Exception { // 判断是否满足条件 return value.f1 > 20; } }) .followedByAny("end"); DataStream>> results = pattern.grep(stream); results.print(); env.execute("Flink CEP Example"); 这段代码中,我们首先定义了一个事件模式,该模式包含三个事件,分别名为“start”、“middle”和“end”。然后,我们就在这串输入数据流里头“抓”这个模式,一旦逮到匹配的,就把它全都给打印出来。拿这个例子来说吧,我们想象一下,“start”就像是你按下开关启动一台机器的那一刻;“middle”呢,就好比这台机器正在呼呼运转,忙得不可开交的时候;而“end”呢,就是指你再次关掉开关,让设备安静地停止工作的那个时刻。设备一旦启动运转起来,要是过了10秒这家伙还在持续运行没停下来的话,那咱们就可以把它判定为“不正常行为”啦。 2. 实时推荐系统 在实时推荐系统中,我们需要根据用户的实时行为数据生成个性化的推荐结果。Flink CEP可以帮助我们实现实时的推荐计算。 python from pyflink.datastream import StreamExecutionEnvironment, DataStream, ValueStateDescriptor from pyflink.table import DataTypes, TableConfig, StreamTableEnvironment, Schema, \ BatchTableEnvironment, TableSchema, Field, StreamTableApi env = StreamExecutionEnvironment.get_execution_environment() t_config = TableConfig() t_env = StreamTableEnvironment.create(env, t_config) source = ... t_env.connect JDBC("url", "username", "password") \ .with_schema(Schema.new_builder() \ .field("user_id", DataTypes.STRING()) \ .field("product_id", DataTypes.STRING()) \ .field("timestamp", DataTypes.TIMESTAMP(3)) \ .build()) \ .with_name("stream_table") \ .create_temporary_view() pattern = Pattern( from_elements("order", DataTypes.STRING()), OneOrMore( PatternUnion( Pattern.of_type(DataTypes.STRING()).equalTo("purchase"), Pattern.of_type(DataTypes.STRING()).equalTo("click"))), to_elements("session")) result = pattern.apply(t_env.scan("stream_table")) result.select("order_user_id").print_to_file("/tmp/output") env.execute("CEP example") 在这段代码中,我们首先创建了一个表环境,并从JDBC连接读取了一张表。然后,我们定义了一个事件模式,该模式包含了两个事件:“order”和“session”。最后,我们使用这个模式来筛选表中的数据,并将结果保存到文件中。这个例子呢,我们把“order”想象成一次买买买的行动,而“session”呢,就相当于一个会话的开启或者结束,就像你走进商店开始挑选商品到结账离开的整个过程。当用户连续两次剁手买东西,或者接连点啊点的,我们就会觉得这位朋友可真是活跃得不得了,然后我们就把他的用户ID美滋滋地记到文件里去。 3. 实时告警系统 在实时告警系统中,我们需要在接收到实时数据后立即发送告警。Flink CEP可以帮助我们实现实时的告
2023-06-17 10:48:34
453
凌波微步-t
MemCache
...术的发展,越来越多的企业开始探索将Memcached与Kubernetes等容器编排平台结合,通过StatefulSet实现自动化的集群部署与扩展,进一步提升了运维效率。 此外,对于寻求更高一致性保证的用户,可以关注新兴的开源项目如Redis或Cassandra,它们在提供内存级速度的同时,还具备更强的数据持久化能力和多数据中心同步功能。例如,Redis 6.2版本引入了客户端缓存、Stream数据结构改进等特性,为开发者提供了更多元化的缓存解决方案。 而在实际应用层面,有文章深入剖析了大型互联网公司在处理海量数据时如何借助分布式缓存系统进行架构优化,如淘宝、京东等电商平台利用Memcached集群有效缓解数据库压力,保障了业务高峰期的服务稳定性和用户体验。 综上所述,在掌握Memcached集群搭建的基础上,持续关注相关领域的技术创新和行业实践,能够帮助我们更好地应对复杂应用场景,提升系统性能和可用性。
2024-02-28 11:08:19
90
彩虹之上-t
转载文章
...表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 使用angular版本:1.7 html <div class="abouts"><div class="commentbox" ><ul><li><div class="number">{$good_percent}%</div><p>好评度</p></li><li><p>好评({$good_percent}%)</p></li><li><p>中评({$medium_percent}%)</p></li><li><p>差评({$pool_percent}%)</p></li></ul><div class="allbar"><p><span class="act"><a href="" ng-click="reSearch(0)">全部评价({$total})</a></span> <span><a href="" ng-click="reSearch(1)">好评({$good})</a></span> <span><a href="" ng-click="reSearch(2)">中评({$medium})</a></span> <span><a href="" ng-click="reSearch(3)">差评({$pool})</a></span> </p></div></div><ul class="_comments" ><li ng-repeat="item in commentlist"><div class="fl"><img src="{ {item.image} }" alt="" /><p class="tel">{ { item.cellphone } }</p></div><div class="fr"><div class="desc"><p>{ { item.content } }</p><div class="tips"><div class="tip">实用高效</div><div class="tip">服务态度好</div></div><p class="doservice"><span> 办理业务:香港公司注册</span> <span class="datetime">{ {item.add_time} }</span></p></div></div></li> </ul><div class="pagination" ng-if="totalNum!=1"><a ng-if="hasPrev()" ng-click="paging($event,0)">上一页</a><a ng-click="paging($event,1)">1</a><a ng-click="paging($event,2)">2</a><a ng-if="totalNum>2" ng-click="paging($event,3)">3</a><a ng-if="hasNext()" ng-click="paging($event,-1)">下一页</a><a ng-click="paging($event,-2)">末页</a><a>总共{ {totalNum} }页</a></div></div> js代码 var app=angular.module('myApp',[]);app.controller('commCtrl', function($scope, $http) {var reSearch=function(postPoints){var postData={'id':goods_id, //产品id'post_points':postPoints||$scope.paginationConf.postPoints, //全部0,好评1,中评2,差评3'limit':$scope.paginationConf.itemsPerPage, //行数'page':$scope.paginationConf.currentPage //页数};$http({method: 'POST',url: '/comment',data:postData,}).then(function successCallback(response) {// 请求成功执行代码// console.log(response.data)$scope.totalNum=Math.ceil(response.data.total/$scope.paginationConf.itemsPerPage);$scope.commentlist=response.data.list;}, function errorCallback(response) {// 请求失败执行代码console.log('请求失败')});}$scope.reSearch=reSearch;$scope.paginationConf={firstPage:1, //起始页 currentPage:1, //当前页itemsPerPage:5, //每页展示的数据条数postPoints:0 // 全部0,好评1,中评2,差评3}; $scope.paging=function(evt,nType){$(evt.target).addClass("active").siblings().removeClass("active");switch(nType){case -2:$scope.paginationConf.currentPage=$scope.totalNum;break;case -1:$scope.paginationConf.currentPage++;break;case 1:$scope.paginationConf.currentPage=1;break;case 2:$scope.paginationConf.currentPage=2;break;case 3:$scope.paginationConf.currentPage=3;break;default:$scope.paginationConf.currentPage--;} $scope.reSearch(0);}$scope.hasNext=function(){if($scope.paginationConf.currentPage<$scope.totalNum){return true;}else{return false;} }$scope.hasPrev=function(){if($scope.paginationConf.currentPage>1){return true;}else{return false;} }$scope.reSearch(0);// $scope.$watch('paginationConf.currentPage + paginationConf.postPoints', reSearch(0));}) 第一次用angular分页,处理的有些简陋,还有一些疑问留着下次解答: 1.ng-controller放在排序的外层包裹内容显示不出来,也不报错,放在最外层或者body下面包裹的第一层上才显示数据 在angular的函数里面获取元素de属性值,可通过click方法传参($event.target),相当于jquery的this 更多参考:https://www.cnblogs.com/sxz2008/p/6379427.html 本篇文章为转载内容。原文链接:https://blog.csdn.net/samscat/article/details/103328461。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-10-12 14:36:16
73
转载
Redis
...优化Redis性能的企业来说,《Redis源码分析:连接池与内存管理策略》一文提供了从底层原理出发,解读Redis如何高效利用文件描述符、内存等系统资源,并给出了针对特定业务场景定制化调整连接池大小和内存分配策略的实战建议。 综上所述,随着技术的不断演进,理解和掌握Redis连接管理的最新趋势和技术细节,结合实际业务需求进行精细化调优,将有助于我们在保障Redis服务稳定性和高性能的同时,充分挖掘其潜能,助力企业应用高效运行。
2024-02-01 11:01:33
301
彩虹之上_t
SpringCloud
...请求的路径、方法、头信息这些细节,然后对上号了才会执行精确的路由指引。就像是个聪明的小管家,检查每个进门客人的“邀请函”,确保他们能准确到达预定的目的地。 java @Bean public RouteLocator customRouteLocator(RouteLocatorBuilder builder) { return builder.routes() .route("path_route", r -> r.path("/service-a/") .uri("lb://SERVICE-A")) .build(); } 上述代码定义了一个名为"path_route"的路由规则,当请求路径匹配"/service-a/"时,将会被路由至名为"SERVICE-A"的服务实例上。 2. 遇到的服务路由配置错误或失效场景 2.1 路由规则配置错误 假设我们在配置路由规则时,不慎将服务名写错,如下: java .route("wrong_route", r -> r.path("/service-b/") .uri("lb://WRONG-SERVICE-A")) 此处错误地将服务名称配置为了"WRONG-SERVICE-A",而实际上应指向"SERVICE-B"。在这种情况下,任何一个打算去找"/service-b/"的请求,都会因为摸不着目标服务而在路由的路上迷路,没法顺利完成它的任务。 2.2 服务实例未注册或下线 即使路由规则配置无误,如果目标服务实例没有成功注册到Eureka或者Consul等服务注册中心,或者服务实例已经下线,路由也会失效。 2.3 负载均衡失效 另外一种常见情况是,虽然服务实例存在且已注册,但由于负载均衡策略设置不当,导致路由无法有效分配请求到各个服务实例上。 3. 解决方案及排查步骤 对于上述问题,我们可以采取以下策略来解决和排查: - 检查路由规则配置:确保每个路由规则的URI部分指向正确的服务名。 - 查看服务注册状态:登录服务注册中心,确认目标服务是否已成功注册并在线。若未注册或下线,则需要检查服务启动过程以及与注册中心的通信状况。 - 验证负载均衡策略:检查SpringCloud Gateway或Zuul中的负载均衡策略配置,确保其能够正常工作。例如,使用轮询、随机或权重等方式合理分配流量。 - 日志分析:深入阅读网关组件的日志输出,通常会记录详细的路由决策过程和结果,这对于定位问题非常有帮助。 4. 总结与思考 面对服务路由配置错误或失效的问题,关键在于理解和掌握SpringCloud的核心路由机制,并具备一定的故障排查能力。同时呢,咱得时刻盯着服务的注册情况,一旦有变动就得立马响应。还有啊,及时调整和优化那个负载均衡策略,这可是保证服务路由始终保持高效稳定运行的关键招数。在实际动手操作中不断尝试、摸爬滚打,积累经验,才能让我们更溜地玩转SpringCloud这个超级给力的微服务工具箱,让服务路由那些小插曲不再阻碍咱们分布式系统的平稳运行。
2023-03-01 18:11:39
92
灵动之光
ZooKeeper
...; // 序列化任务信息 String taskPath = taskQueuePath + "/" + taskId; zk.create(taskPath, taskData, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL); 3.3 监听任务节点变化 任务调度器在启动时,会在任务队列节点上设置一个Watcher监听器,当有新任务加入或者已有任务完成(节点被删除)时,都能收到通知: java zk.exists(taskQueuePath, new Watcher() { @Override public void process(WatchedEvent event) { if (event.getType() == EventType.NodeChildrenChanged) { List tasks = zk.getChildren(taskQueuePath, true); // 获取当前待处理的任务列表 // 根据任务优先级、顺序等策略,从tasks中选取一个任务进行调度 } } }); 3.4 分配与执行任务 根据监听到的任务列表,任务调度器会选择合适的任务分配给空闲的工作节点。工作节点接收到任务后,开始执行任务,并在完成后删除对应的ZooKeeper节点。 这样,通过ZooKeeper的协助,我们成功实现了分布式任务调度系统的构建。每个步骤都超级灵活、充满活力,能像变形金刚那样,随着集群的大小变化或者任务需求的起起伏伏,始终保持超高的适应能力和稳定性,妥妥地hold住全场。 4. 总结与探讨 ZooKeeper以其强大的协调能力,让我们得以轻松应对复杂的分布式任务调度场景。不过在实际动手操作的时候,咱们还得多琢磨琢磨怎么对付错误、咋整并发控制这些事儿,这样才能让调度的效率和效果噌噌往上涨,达到更理想的优化状态。另外,面对不同的业务应用场景,我们可能需要量身定制任务分配的策略。这就意味着,首先咱们得把ZooKeeper摸透、吃熟,然后结合实际业务的具体逻辑,进行一番深度的琢磨和探究,这样才能玩转起来!就像冒险家在一片神秘莫测的丛林里找寻出路,我们也是手握ZooKeeper这个强大的指南针,在分布式任务调度这片“丛林”中不断尝试、摸爬滚打,努力让我们的解决方案更加完善、无懈可击。
2023-04-06 14:06:25
54
星辰大海
Tomcat
...开源框架,简化了现代企业级Java应用的初始搭建和开发过程。它通过自动配置和依赖注入,减少了开发者编写配置代码的工作量,同时支持模块化和快速部署。文章中提到的Spring Boot项目,通常涉及到Spring MVC的使用,其中类加载器在启动时负责加载Spring的组件和配置。 Parent First ClassLoader , Spring Boot中的一个类加载器策略,它首先从父类路径(通常是应用的类路径)中查找类,如果找不到,则会继续在子类路径(即Spring Boot自身的类路径)中查找。这种策略有助于防止类加载冲突,确保应用可以正常运行。 Application ClassLoader , Spring Boot中的另一个类加载器,它是独立于父类加载器的,允许开发者自定义应用的类加载行为。在Spring Boot项目中,它负责加载应用代码、Spring配置和模块化的依赖。 ComponentScan , Spring Boot中的一个功能,允许开发者指定哪些包或组件需要被自动扫描和注册。通过@ComponentScan注解,Spring Boot能够自动发现并管理应用中的各种Spring组件,如@Controller、@Service等。 Classpath , Java应用程序执行时搜索类文件的目录路径,包括JDK安装目录、用户自定义目录以及项目中的类库目录。类路径的设置直接影响类加载器能否找到所需的类。 Maven , 一个流行的Java项目构建工具,它负责管理和协调项目依赖,包括下载、构建和部署JAR文件。Maven的pom.xml文件是配置项目依赖和类路径的关键部分,确保类加载器能找到所有必要的类。 Java EE , Enterprise Edition(企业版)Java,一套全面的企业级Java技术标准,包括Servlet、JSP、EJB、JMS等。Tomcat作为Java EE的轻量级实现,支持这些技术的部署。 ModulePath , 在Spring Boot 3.0及更高版本中,引入的模块化系统中的概念,它定义了模块间的依赖关系和类加载顺序,有助于更好地管理大型项目中的类加载。
2024-04-09 11:00:45
270
心灵驿站
CSS
...。这一举措不仅体现了企业社会责任,也为其他互联网公司提供了可借鉴的经验。 此外,W3C(万维网联盟)最近发布了一份关于无障碍标准的新指南,强调了“包容性设计”的必要性。这份指南指出,现代网页设计不仅要注重美观,更要考虑到不同人群的需求,包括老年人、残障人士以及文化背景不同的用户。例如,对于老年用户,设计师应减少复杂的交互步骤,并提供更大的字体和更明显的对比度;而对于多语言环境下的用户,则需要确保内容的翻译准确且符合当地习惯。 这些趋势表明,互联网设计正在从单纯的美学追求向更加人性化、社会化的方向演进。未来,随着人工智能和大数据技术的发展,我们有理由相信,更多基于用户行为分析的设计创新将涌现出来,从而推动整个行业的进步。
2025-04-27 15:35:12
47
风轻云淡_
Superset
...就可能会带出些错误的信息,或者干脆没法准确表达我们的观点啦。 三、数据列映射异常的原因 在实际操作中,我们会发现数据列映射异常的情况比我们想象的要常见。最常见的原因,就是我们在捣鼓查询的时候,不小心选错了要分析的字段,或者没把我们想要汇总的方式给整明白、搞清楚。另外,要是我们的数据集里头混进了些缺失的数据或者不按常理出牌的异常值,那很可能会影响到咱们把数据列对应映射的结果。 举个例子,假设我们有一个销售数据表,其中包含销售额和产品类型两列数据。如果咱只挑了销售额这一项来做图表,那这张图就只能展示销售额上下波动的走势,却没法告诉我们不同产品类型的销售额具体是个啥情况。这就意味着我们的数据列映射存在问题。 四、如何处理数据列映射异常? 处理数据列映射异常的方法有很多。首先,咱们得瞧一瞧,是不是选对了查询的列,还有啊,聚合的方式给整准确了没。接着呢,咱们得保证咱的数据集是个实实在在的“完璧之身”,里头甭管是丢三落四的空缺值还是调皮捣蛋的异常值,一个都不能有哈。最后一步,咱们得根据自身的需求,来量身定制可视化设计,确保它能准确无误地传递出咱们想要表达的信息内容。 下面是一些具体的步骤: 步骤一:检查查询 我们首先需要检查我们的查询。在Superset里头,想看我们正在捣鼓的查询超级简单,就跟你平时点开视频网站的小播放键一样,你只需要轻轻一点查询编辑器右下角那个醒目的“预览”按钮,一切就尽在眼前啦!瞧瞧这个预览窗口,这里展示了咱们正在使用的所有列,还附带了我们对这些列的处理手法,也就是聚合方式,一目了然! 例如,如果我们只想看到某一类产品的销售额,我们应该选择"product_type"和"sales_amount"这两列,并设置聚合方式为"SUM(sales_amount)"。 步骤二:处理缺失值和异常值 如果我们发现我们的数据集中存在缺失值或者异常值,我们需要先处理这些问题。在 Python 中,我们可以使用 Pandas 库来处理这些问题。例如,我们可以使用 dropna() 方法来删除含有缺失值的行,或者使用 fillna() 方法来填充缺失值。对于异常值,我们可以使用箱线图来识别并处理。 步骤三:设计可视化 最后,我们需要根据我们的需求来设计我们的可视化。在 Superset 中,我们可以很容易地改变我们可视化的类型、颜色、标签等属性。同时呢,咱们也得留心一下咱的标题和图例这些小细节,确保它们能明明白白地把我们的意思传达出去,让人一看就懂。 例如,如果我们想比较两种产品的销售额,我们应该选择柱状图作为我们的可视化类型,并给每种产品分配不同的颜色。同时,我们也应该在标题和图例中明确指出我们正在比较的是哪两种产品。 五、结论 总的来说,处理数据列映射异常是一项非常重要的任务。瞧,如果我们认真检查咱们的查询,把那些躲猫猫的缺失值和捣乱的异常值都妥妥地处理好,再巧妙地设计我们的可视化图表,那就能确保咱们的数据列映射绝对精准无误。这样一来,生成的可视化效果自然就棒棒哒,既有效又直观!希望这篇文章能帮助你解决你在 Superset 中遇到的问题。
2023-09-13 11:26:54
100
清风徐来-t
ClickHouse
...或希望预防此类问题的企业用户,ClickHouse社区活跃的技术论坛和文档资料提供了丰富的实践案例和解决方案,如采用ON CLUSTER语法确保集群内所有节点顺序执行DDL操作,以及通过监控报警系统实时跟踪表锁定状态等方法,均值得广大用户参考和借鉴。 综上所述,无论是紧跟ClickHouse官方的最新特性更新,还是深入学习行业内的研究成果,或是借鉴同行的成功实践经验,都能为解决和规避“TableAlreadyLockedException”这类问题提供有力支持。对于致力于提升数据分析效率和系统稳定性的团队而言,这无疑是一条不可或缺的学习和探索之路。
2024-02-21 10:37:14
351
秋水共长天一色
RabbitMQ
...传递的重要场合,堪称信息流通的桥梁。 本篇文章将重点介绍如何利用RabbitMQ实现发布/订阅模式。 二、什么是发布/订阅模式? 发布/订阅模式是一种软件设计模式,主要用于处理事件驱动的应用程序。在这种模式下,咱们可以这么理解:生产者,也可以叫它“发布君”,它的工作就是往一个特定的“消息中心”——也就是主题或者交换机那儿发送消息。而消费者呢,换个接地气的名字就是“订阅达人”,它们会先关注这个“消息中心”。这样一来,只要“发布君”有新消息发出,“订阅达人”就能第一时间接收到所有这些消息啦! 三、如何在RabbitMQ中实现发布/订阅模式? 在RabbitMQ中,我们可以通过以下几个步骤来实现发布/订阅模式: 1. 创建并配置RabbitMQ环境 首先,我们需要在本地安装RabbitMQ,并启动服务。启动后,我们可以使用管理控制台查看RabbitMQ的状态和信息。 2. 创建交换机和队列 在RabbitMQ中,交换机和队列是两个基本的概念。交换机负责路由消息,而队列则用于存储消息。在接下来这一步,咱要做的是构建一个直通交换机和两个队列。其中一个队列呢,是专门用来接住生产者发过来的消息;另一个队列呢,则是用来给消费者传递他们的回复消息滴。 3. 编写生产者代码 在生产者代码中,我们将通过RabbitMQ的客户端API发送消息。首先,咱们得先捯饬出一个连接和通道,就像是搭起一座桥,然后像变魔术一样整出一个交换机,再配上两个队列,这两个队列就想象成是咱的消息暂存站。最后一步,就是把消息往这个交换机上一放,就像把信投进邮筒那样,完成发布啦! python import pika 创建连接和通道 connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() 创建交换机和队列 channel.exchange_declare(exchange='direct_logs', exchange_type='direct') 发布消息到交换机上 routing_key = 'INFO' message = "This is an info message" channel.basic_publish(exchange='direct_logs', routing_key=routing_key, body=message) print(" [x] Sent %r" % message) 关闭连接和通道 connection.close() 4. 编写消费者代码 在消费者代码中,我们将通过RabbitMQ的客户端API接收消息。首先,咱们得先搭起一座桥梁,建立起一条通道。然后,把队列和交换机牢牢地绑在一起。最后,从队列里取出消息,好好地“享用”一番。 python import pika 创建连接和通道 connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() 绑定队列到交换机上 queue_name = 'log_queue' channel.queue_bind(queue=queue_name, exchange='direct_logs', routing_key='INFO') 消费消息 def callback(ch, method, properties, body): print(" [x] Received %r" % body) channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True) 启动消费者 print(' [] Waiting for logs. To exit press CTRL+C') channel.start_consuming() 5. 运行代码并观察结果 现在,我们已经编写好了生产者和消费者的代码,接下来只需要运行这两个脚本就可以观察到发布/订阅模式的效果了。当生产者发送一条消息时,消费者会立即接收到这条消息,并打印出来。 四、总结 通过以上步骤,我们成功地在RabbitMQ中实现了发布/订阅模式。这简直就是个超级实用的编程模型,特别是在那些复杂的分布式系统里头,它能神奇地让不同应用程序之间的交流变得松耦合,这样一来,整个系统的稳定性和可靠性嗖嗖往上涨,就像给系统吃了颗定心丸一样。
2023-09-07 10:09:49
95
诗和远方-t
Consul
...允许服务实例注册自身信息并维护心跳以表明其存活状态,其他服务可通过查询Consul来发现和连接所需的服务实例。 服务发现 , 服务发现是分布式系统中的核心概念,它允许系统中的服务能够自动寻找到彼此并建立连接,无需手动配置网络地址或端口等信息。在本文的上下文中,Consul通过提供服务注册表实现服务发现,使得服务实例可以动态地加入或离开集群,并确保其他服务能实时得知这些变化。 健康检查 , 在Consul中,健康检查是指一种机制,用于验证服务实例是否正常运行和响应请求。它可以设置为TCP检查、HTTP检查等多种形式,定期对服务进行探测,如检测特定端口是否开放、HTTP接口返回的状态码是否成功等。如果服务实例连续多次未通过健康检查,Consul会将其标记为不健康,并可能根据配置注销该实例,从而避免将流量导向存在问题的服务节点,维持整个系统的稳定性。 微服务架构 , 微服务架构是一种软件开发方法论,其中应用被设计为一组小型、独立部署且拥有明确业务功能的服务集合。每个服务都可以独立开发、测试、部署和扩展,而服务之间通过API调用相互协作,共同完成复杂的业务逻辑。在本文中,Consul在微服务架构中扮演了关键角色,负责管理和协调各个服务实例,保证它们之间的通信和服务发现过程高效可靠。
2024-01-22 22:56:45
520
星辰大海
Ruby
...,并打印出相应的错误信息。 2. 确保资源释放 确保finally(ensure)执行 Ruby中的ensure关键字为我们提供了一种机制,保证无论在begin块内是否发生异常,其后的代码都会被执行,从而确保了资源的释放: ruby file = File.open('important_file.txt', 'w') begin 对文件进行操作,这里可能出现异常 file.write('Critical data...') rescue Exception => e puts "Error occurred while writing to the file: {e.message}" ensure 不管是否发生异常,这段代码总会被执行 file.close unless file.nil? end 在这段代码中,无论写入文件的操作是否成功,我们都能够确保file.close会被调用,这样就可以避免因未正常关闭文件而造成的数据丢失或系统资源泄露的问题。 3. 定制化异常处理 rescue多个类型 Ruby允许你根据不同的异常类型进行定制化的处理,这样可以更加精确地控制程序的行为: ruby begin 可能产生多种类型的异常 divide_by_zero = 1 / 0 non_existent_file = File.read('non_existent_file.txt') rescue ZeroDivisionError => e puts "Whoops! You can't divide by zero: {e.message}" rescue Errno::ENOENT => e puts "File not found error: {e.message}" ensure 同样确保这里的资源清理逻辑总能得到执行 puts 'Cleaning up resources...' end 通过这种方式,我们可以针对不同类型的异常采取不同的恢复策略,同时也能确保所有必要的清理工作得以完成。 4. 思考与总结 处理异常和管理资源并不是一门精确科学,而是需要结合具体场景和需求的艺术。在Ruby的天地里,咱们得摸透并灵活玩转begin-rescue-end-ensure这套关键字组合拳,好让咱编写的代码既结实耐摔又运行飞快。这不仅仅说的是程序的稳定牢靠程度,更深层次地反映出咱们开发者对每个小细节的极致关注,以及对产品品质那份永不停歇的执着追求。 每一次与异常的“交锋”,都是我们磨砺技术、提升思维的过程。只有当你真正掌握了在Ruby中妥善处理异常,确保资源被及时释放的窍门时,你才能编写出那种既能经得起风吹雨打,又能始终保持稳定运行的应用程序。就像是建造一座坚固的房子,只有把地基打得牢靠,把每一处细节都照顾到,房子才能既抵御恶劣天气,又能在日常生活中安全可靠地居住。同样道理,编程也是如此,特别是在Ruby的世界里,唯有妥善处理异常和资源管理,你的应用程序才能健壮如牛,无惧任何挑战。这就是Ruby编程的魅力所在,它挑战着我们,也塑造着我们。
2023-09-10 17:04:10
90
笑傲江湖
JSON
...清晰地展现了用户列表信息,每个用户都有自己的ID、姓名和邮箱地址。这正是JSON让人着迷的地方,它能用咱们人类看得懂的方式去表达数据,而且机器也能轻松解析理解,真可谓“人机对话”的小能手。 2. JSON与网站数据导入 在实际的网站开发场景中,我们经常需要从外部源导入数据,如API接口、文件或数据库。JSON格式因其通用性,成为理想的数据传输媒介。以下是一个典型的网站导入JSON数据的例子: javascript // 假设我们从某个API获取到了上述JSON数据 fetch('https://example.com/api/users') .then(response => response.json()) .then(data => { // 解析并处理JSON数据 const users = data.users; users.forEach(user => { console.log(User ID: ${user.id}, Name: ${user.name}); // 这里可以将用户数据插入到网站DOM或其他存储中 }); }) .catch(error => console.error('Error fetching data:', error)); 在这段代码中,我们通过fetch函数请求一个返回JSON数据的API,然后利用.json()方法将其转化为JavaScript对象,进而进行数据处理和展示。这便是JSON在网站数据导入中的核心应用。 3. JSON的应用深度探讨 - 数据交互:JSON不仅适用于前后端数据交换,也常用于客户端和服务端之间、甚至不同系统之间的数据传递。它减少了数据转换的成本,简化了开发流程。 - 兼容性:由于JSON是基于JavaScript的对象字面量,因此在浏览器环境中可以直接转化为JavaScript对象,无需额外的库或工具支持。 - 灵活性:JSON结构灵活多变,可以表示复杂的嵌套数据结构,适应各种业务场景的需求。 - 性能优化:相对于XML等其他数据格式,JSON的体积更小,解析速度更快,有利于提升网站性能。 4. 结语 拥抱JSON,让数据流动更自由 随着Web技术的发展,JSON已经深入到我们日常开发的方方面面。它如同一条无形的信息高速公路,承载着网站间、系统间的数据流通。作为开发者,咱们得把JSON的使用窍门玩得贼溜,可别浪费了它的那些个优点。把它用得风生水起,让它在咱们的项目里发光发热,发挥出最大的价值,这才是正经事!当我们面对网站数据导入这样的需求时,不妨试着借助JSON的力量,你会发现,数据的搬运原来可以如此轻松自如,充满了无限可能!
2023-10-11 22:09:42
755
林中小径
ZooKeeper
...群里每个小节点的状态信息,确保这些数据都是鲜活、热乎的。客户端能够通过ZooKeeper这个小帮手,实时掌握各个节点的最新负载状况。这样一来,它就能像一个聪明的调度员,火眼金睛地做出最佳的服务请求转发方案,确保不同节点之间的活儿分配得均匀,实现工作负载的完美均衡。 2. ZooKeeper节点负载均衡策略详解 (1)数据节点(ZNode)管理 在ZooKeeper中,每个服务节点可以注册为一个ZNode,同时附带该节点的负载信息。例如,我们可以创建一个持久化的ZNode /services/serviceName/nodes/nodeId,并在其数据部分存储节点负载量。 java // 创建ZNode并设置节点负载数据 String path = "/services/serviceName/nodes/nodeId"; byte[] data = String.valueOf(nodeLoad).getBytes(StandardCharsets.UTF_8); zk.create(path, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); (2.)监听器(Watcher) 客户端可以通过在特定ZNode上设置Watcher,实时感知到节点负载信息的变化。一旦某个服务节点的负载发生变化,ZooKeeper会通知所有关注此节点的客户端。 java // 设置监听器,监控节点负载变化 Stat stat = new Stat(); byte[] data = zk.getData("/services/serviceName/nodes/nodeId", new Watcher() { @Override public void process(WatchedEvent event) { // 在这里处理节点负载变化事件 } }, stat); (3)选择最佳服务节点 基于ZooKeeper提供的最新节点负载数据,客户端可以根据预设的负载均衡算法(如轮询、最小连接数、权重分配等)来选择当前最合适的服务节点进行请求转发。 java List children = zk.getChildren("/services/serviceName/nodes", false); children.sort((node1, node2) -> { // 这里根据节点负载数据进行排序,选择最优节点 }); String bestNode = children.get(0); 3. 探讨与思考 运用ZooKeeper实现节点负载均衡的过程中,我们能够感受到它的灵活性与强大性。不过,到了实际用起来的时候,有几个挑战咱们也得留心一下。比如,怎么捣鼓出一个既聪明又给力的负载均衡算法,可不是件轻松事儿;再者,网络延迟这个磨人的小妖精怎么驯服,也够头疼的;还有啊,在大规模集群里头保持稳定运行,这更是个大大的考验。这就意味着我们得不断动手尝试、灵活应变,对策略进行微调和升级,确保把ZooKeeper这个分布式协调服务的大能耐,彻彻底底地发挥出来。 总结来说,ZooKeeper在节点负载均衡策略上的应用,既体现了其作为一个通用分布式协调框架的价值,又展示了其实现复杂分布式任务的能力。利用ZooKeeper那个相当聪明的数据模型和监听功能,咱们完全可以捣鼓出一个既能让业务跑得溜溜的,又能稳如磐石、始终保持高可用性的分布式系统架构。就像是用乐高积木搭建一座既美观又结实的大厦一样,我们借助ZooKeeper这块宝,来创建咱所需要的高性能系统。所以,在我们实实在在做开发的时候,要是能摸透并熟练运用ZooKeeper这家伙的节点负载均衡策略,那可是对提升我们系统的整体表现力有着大大的好处,这一点儿毋庸置疑。
2024-01-21 23:46:49
123
秋水共长天一色
Redis
...的小弟们赶紧更新配置信息。这个过程是自动完成的,无需人工干预。 3.2 代码示例 要启用哨兵模式,需要先配置哨兵实例。假设你已经安装了Redis,并且主节点运行在localhost:6379上。接下来,你需要创建一个哨兵配置文件sentinels.conf,内容如下: conf sentinel monitor mymaster 127.0.0.1 6379 2 sentinel down-after-milliseconds mymaster 5000 sentinel failover-timeout mymaster 60000 sentinel parallel-syncs mymaster 1 然后启动哨兵实例: bash redis-sentinel sentinels.conf 现在,当你故意关闭主节点时,哨兵会自动选举出一个新的主节点,并通知从节点进行切换。 4. 集群模式 最后,我们来看看Redis集群模式(Cluster Mode),这是一种更加复杂但也更强大的数据同步机制。集群模式允许Redis实例分布在多个节点上,每个节点都可以同时处理读写请求。 4.1 集群架构 在集群模式下,Redis实例被划分为多个槽(slots),每个槽可以归属于不同的节点。当你用客户端连到某个节点时,它会通过键名算出应该去哪个槽,然后就把请求直接发到对的节点上。这样做的好处是,即使某个节点宕机,也不会影响整个系统的可用性。 4.2 实现步骤 为了建立一个Redis集群,你需要准备至少六个Redis实例,每个实例监听不同的端口。然后,使用redis-trib.rb工具来创建集群: bash redis-trib.rb create --replicas 1 127.0.0.1:7000 127.0.0.1:7001 127.0.0.1:7002 127.0.0.1:7003 127.0.0.1:7004 127.0.0.1:7005 创建完成后,你可以通过任何节点来访问集群。例如: bash redis-cli -c -h 127.0.0.1 -p 7000 5. 总结 通过以上介绍,我们可以看到Redis提供了多种数据同步机制,每种机制都有其独特的应用场景。不管是基本的主从复制,还是复杂的集群模式,Redis都能搞定数据同步,让人放心。当然啦,每种方法都有它的长处和短处,到底选哪个还得看你自己的具体情况和所处的环境。希望今天的分享能对你有所帮助,也欢迎大家在评论区讨论更多关于Redis的话题!
2025-03-05 15:47:59
28
草原牧歌
Flink
..., 大数据领域是指在信息技术行业中,专门研究和应用大数据技术进行数据采集、存储、分析以及可视化的整个产业链集合。在这个领域中,实时处理是指对源源不断产生的大量数据进行即时、连续的计算和分析,以提取有价值的信息并支持实时决策。 Flink的异步I/O操作 , 在Apache Flink框架中,异步I/O操作是一种提升系统性能和效率的关键技术手段。它允许Flink在执行流数据处理任务时,与外部系统(如数据库、消息队列等)进行非阻塞的数据交换。具体来说,当Flink需要从外部系统读取或写入数据时,不会等待该操作完成,而是继续执行其他任务,直到外部系统准备好数据后通过回调机制通知Flink进行后续处理,从而避免了CPU空闲等待,提高了系统的吞吐量和响应速度。 AsyncFunction接口 , AsyncFunction是Apache Flink提供的一种用于实现异步数据处理的接口。在Flink流处理作业中,用户可以通过自定义实现AsyncFunction来创建异步算子。当DataStream上的元素被传递给AsyncFunction时,它会启动一个异步任务,并在任务完成后将结果收集或传递到下一个处理阶段。这样可以确保即使在等待外部系统响应期间,Flink也能高效地利用资源处理其他数据,提升了整体系统的并发能力和实时性。
2024-01-09 14:13:25
493
幽谷听泉-t
Nacos
...管理和服务之间的配置信息,我们引入了Nacos。然而,在实际操作的时候,有些开发者会碰上个让人头疼的问题。这问题是什么呢?就是Nacos在访问过程中引起的内存泄漏,真是让人挺挠头的。 二、内存泄漏的概念及影响 1. 内存泄漏概念 内存泄漏是指程序在申请内存后,无法释放已经不再使用的内存空间,从而造成内存空间越来越少,直到耗尽系统所有可用内存资源的现象。 2. 内存泄漏的影响 (1) 当程序的内存消耗过大时,会导致系统整体性能下降。 (2) 如果程序的内存消耗达到系统最大限制,则可能导致系统崩溃。 三、Nacos导致内存泄漏的原因分析 1. 数据结构设计不合理 Nacos作为配置中心,其中包含了大量的配置数据。如果这些数据的存储方式不恰当,可能会导致大量的内存被占用。 2. 线程池问题 Nacos内部使用了线程池来处理请求,如果线程池中的线程数量过多或者线程生命周期过长,都可能导致内存泄漏。 3. 对象引用未被正确释放 当某个对象被创建后,如果没有正确地释放对它的引用,那么这个对象就会一直存在于内存中,形成内存泄漏。 四、如何避免Nacos引起的内存泄漏? 1. 优化数据结构 对于Nacos中存储的数据,我们可以采用更合理的数据结构来减少内存的占用。比如,咱们可以考虑用哈希表来替代链表,为啥呢?因为哈希表在找东西的时候更快捷呀,就像你用字典查单词一样唰一下就找到了。而且,它也不会像链表那样产生一堆乱七八糟的指针,让事情变得更复杂。 java Map configMap = new HashMap<>(); configMap.put("key", "value"); 2. 合理使用线程池 为了避免线程池中的线程过多,我们需要根据系统的实际情况来设置线程池的最大大小,并且定期清理无用的线程。同时呢,咱最好让线程的生命期短小精悍些,别让那些跑起来没完没了的线程霸占太多的内存,这样就不至于拖慢整个系统的速度啦。 java ExecutorService executor = Executors.newFixedThreadPool(5); executor.shutdown(); 3. 正确释放对象引用 对于Nacos中的对象,我们需要确保它们在不需要的时候能够被正确地释放。比如,假设我们已经用上了try-with-resources这个神奇的语句,那么在finally部分执行完毕之后,JVM这位勤快的小助手会自动帮我们把不再需要的对象引用给清理掉。 java try (NacosClient client = NacosFactory.createNacosClient("localhost:8848")) { // 使用client } 五、总结 总的来说,Nacos作为配置中心,给我们带来了极大的便利。不过呢,在我们日常使用的过程中,千万不能对内存泄漏这个问题掉以轻心。咱得通过一些接地气的做法,比如精心设计数据结构,妥善管理线程池,还有及时释放对象引用这些招数,才能把内存泄漏这个捣蛋鬼给有效挡在门外,不让它出来惹麻烦。 以上就是我对“在客户端的微服务中访问Nacos时出现内存泄漏问题”的理解和解决方法,希望能给大家带来一些帮助。
2023-03-16 22:48:15
116
青山绿水_t
转载文章
...表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 Vue选项 什么是选项? 使用选项式 API,我们可以用包含多个选项的对象来描述组件的逻辑,例如 data、methods 和 mounted。选项所定义的属性都会暴露在函数内部的 this 上,它会指向当前的组件实例。 以上是官网对于选项的概念,简单的说,选项是一组由Vue定义好的对象,你可以将你的代码写在指定的选项中,从而获得一些 “特异功能” 。 注:由于选项是Vue规定好的,因此在使用中我们不能更改其名称,也不可以重复定义 常用选项 1. data选项 必须是一个函数,将组件需要使用的变量定义在此函数的返回值对象中,定义的变量将会获得一个“特异功能” ---- 响应式 <template><div><!-- 在这里使用插值表达式将name渲染到页面 -->{ { name } }</div></template><script>export default {// data选项data(){return{// name是响应式的name:"Jay",} },}</script> 上面例子中的name就是一个响应式数据,在值发生改变时,视图(页面)上的name也会发生变化,那我们便可以通过操作name的变化去使视图发生变化,而不用进行繁琐的DOM操作,这也体现着Vue框架的 数据驱动 这一核心思想。 为什么数据要定义在data函数的返回值中,而不是定义在一个对象中? 将数据定义在函数返回值中,可以确保每产生一个组件实例,都会调用一次函数,并返回一个新的对象,开辟一块新的空间。 如果将数据定义在对象中,可能会出现类似于浅拷贝中出现的问题,即多个组件实例指向同一块空间,一个组件实例修改数据,则全部数据发生变化。 2. methods选项 此选项是一个对象,其中存放着该组件要使用的函数,比如事件的回调函数… <template><div><!-- 添加点击事件,事件回调函数在methods中定义 --><button @click="add">点击加一</button> <p>{ { count } }</p></div></template><script>export default {data(){return{count:0,} },// 在methods中定义函数(方法)methods:{add(){// 在函数中要使用data中的变量,需加thisthis.count++},} }</script> 通过点击事件改变count的值,从而使页面上的值随之变化,再次体现 数据驱动 的核心思想 3. computed 计算属性 计算属性,对象形式,顾名思义,在计算属性中保存着一系列需要经过运算得出的属性 <template><p>路程:{ { distance } } km</p><p>速度:{ { speed } } km/h</p><!-- 使用计算属性,与变量的使用相同 --><p>花费的时间:{ { time } } h</p></template><script>export default {data() {return {distance: 1000,speed: 50,} },computed: {// 定义计算属性,类似于函数的定义,返回值就是该计算属性的值time() {return this.distance / this.speed} }}</script> 计算属性内部所依赖的数据发生变化时, 计算属性本身就会自动重新计算返回一个新的计算值并缓存起来。 计算属性内部所依赖的数据没有发生变化, 计算属性会直接返回上一次缓存的值。 因此上面例子中的distance(路程)与speed(速度)无论如何变化,time都会计算出正确的值。 4. directives 选项, 定义自定义指令( 局部指令 ) 在上节,我们学习了一些Vue内置指令,功能十分强大,那么我们可以自己定义一些指令吗? 当然可以!我们可以在directives选项中创建自定义指令。 <template><!-- 使用自定义指令 --><div v-myshow="1"></div><div v-myshow="0"></div></template><script>export default {// 在directives中定义一个自定义指令,来模仿v-show的功能directives: {//el:添加自定义指令的元素;binding:指令携带的参数myshow(el, binding) {if (binding.value) {el.style.display = "block";} else {el.style.display = "none";} }} }</script><style scoped>div {width: 100px;height: 100px;background-color: red;margin: 10px;}</style> 像以上这种,在组件中定义的指令是局部指令,只能在本组件中使用,全局指令需要在main.js文件中定义,全局指令在任何.vue文件中都可使用。 注意: 当局部指令和全局指令冲突时, 局部指令优先生效. var app = createApp(App)//定义全局指令 app.directive("myshow", (el, binding) => {if (binding.value) {el.style.display = "block";} else {el.style.display = "none";} })// 全局指令可在任何组件使用 5. components组件选项(注册局部组件) 在一个组件中我们可能会使用到其他组件,在将组件引入后,需要在components中进行注册,才能使用。 <template><!-- 使用组件 --><Test /></template><script>// 引入组件import Test from './Test.vue'export default {// 注册组件components: {Test},}</script> 局部组件只能在当前组件内部使用,需要在任何组件中使用,需要在main.js文件中注册为全局组件 // 引入组件import Test from './Test.vue'// 注册全局组件,可在所有.vue文件中使用app.component('Test',Test); 6. 其他 filters 选项, 定义过滤器,vue2中使用,Vue3中已经弃用 mounted 等生命周期函数选项,我们在下节进行详细讲解… 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_57714647/article/details/130878069。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-12-25 22:28:14
65
转载
PostgreSQL
...据库高效稳定运行,为企业的数字化转型提供强大支持。
2023-12-18 14:08:56
237
林中小径
Hadoop
...和技术。例如,在构建企业级大数据平台时,除了Hadoop与Spark外,可能还会引入Flink用于实时计算,Hive或Presto用于SQL查询,以及HBase或Cassandra作为NoSQL存储解决方案,从而构建起一个既包含批处理又能应对实时分析的全方位大数据处理体系。 总之,Hadoop在大数据领域依然扮演着重要角色,但我们也需紧跟时代步伐,关注如Spark、Flink等新兴技术的演进与发展,以便更好地应对不断变化的大数据挑战,挖掘数据背后的价值。
2023-04-18 09:23:00
470
秋水共长天一色
转载文章
...表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 原网站:https://www.cnblogs.com/minghost/p/11941668.html scroll组件:<template name="scroll"><view class=""><view class="all"><scroll-view class="nav-bar" scroll-x @scroll="scroll"><!-- 要想使用flex布局实现横向滚动,就要在scroll-view里加一层容器包裹,并且使用子组件才会出现滚动效果 --><view class="nav-bar-wrap"><block v-for="(item,index) in navbarArr" :key="index"><view class="nav-bar-item" @click="onNavbarItem(item.id)" :id="item.id"><image :src="item.pic_url" /><text>{ {item.name} }</text></view></block></view></scroll-view></view><view class="slider"><view class="slider-inside .slider-inside-location" :style="{left:lefts}"></view></view></view></template><script>export default {name: "scroll",data() {return {lefts:0} },props: {navbarArr: {type: Array},left: {type: Number} },created: function(e) {console.log(this.left,"leftinfo")},methods: {onNavbarItem(id) {console.log(id)// const id = options.currentTarget.dataset.id// wx.navigateTo({// url: /pages/mysignup/mysignup?id=${id},// })},scroll(event) {let that = thisconsole.log(event)let scrollLeft = event.detail.scrollLeft;let scrllWidth = event.detail.scrollWidth - 375;// that.left = ${(scrollLeft) / scrllWidth 100}%// this.$emit("changeLeft",that.lefts)// 32是剩余要滑动的地方let newLeft = scrollLeft / scrllWidth 32that.lefts =newLeft + 'rpx'} }}</script><style>.all {position: relative;height: 330rpx;overflow: hidden;background: fff;}scroll-view {white-space: nowrap;}/ 去除滚动条 /::-webkit-scrollbar {display: none;width: 0;height: 0;color: transparent;}.nav-bar-wrap {display: flex;flex-flow: column wrap;height: 330rpx;}.nav-bar-item {width: 187.5rpx;display: flex;flex-direction: column;align-items: center;padding-top: 28rpx;}.nav-bar-item image {display: block;height: 90rpx;width: 90rpx;margin: 0;}.nav-bar-item text {margin-top: 5rpx;line-height: 32rpx;font-size: 25rpx;}.slider {position: relative;margin-left: 50%;/ left: 50%; /transform: translateX(-50%);width: 64rpx;height: 6rpx;border-radius: 3rpx;background: eee;}.slider-inside {/ transform: translateX(-50%); /width: 32rpx;height: 100%;border-radius: 3rpx;background-color: 11BEA7;}.slider-inside-location {position: absolute;/ left: 50%; /}</style> 使用组件:<template><view><scroll :navbarArr="navbarArr" :left="left" @changeLeft="changeLeft"></scroll></view></template><script>import scroll from "../../components/scroll.vue"export default {components:{scroll},data() {return {navbarArr: [{pic_url: '../static/images/ic_57@2x.png',name: '骨科',id: 1},{pic_url: '../static/images/ic_59@2x.png',name: '检验科',id: 2},{pic_url: '../static/images/ic_56@2x.png',name: '外壳',id: 3},{pic_url: '../static/images/ic_53@2x.png',name: '口腔科',id: 4},{pic_url: '../static/images/ic_54@2x.png',name: '猫科',id: 5},{pic_url: '../static/images/ic_52@2x.png',name: '内科',id: 6},{pic_url: '../static/images/ic_50@2x.png',name: '皮肤科',id: 7},{pic_url: '../static/images/ic_52@2x.png',name: '肾病',id: 8},{pic_url: '../static/images/ic_58@2x.png',name: '血透科',id: 9},{pic_url: '../static/images/ic_62@2x.png',name: '肾病',id: 10},{pic_url: '../static/images/ic_64@2x.png',name: '血透科',id: 11},],left:0.65625} },methods: {changeLeft(e){let that = thisthat.left = e} },}</script> 本篇文章为转载内容。原文链接:https://blog.csdn.net/qq_45584157/article/details/117958700。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2024-05-06 12:38:02
624
转载
站内搜索
用于搜索本网站内部文章,支持栏目切换。
知识学习
实践的时候请根据实际情况谨慎操作。
随机学习一条linux命令:
ln -s target link
- 创建符号链接。
推荐内容
推荐本栏目内的其它文章,看看还有哪些文章让你感兴趣。
2023-04-28
2023-08-09
2023-06-18
2023-04-14
2023-02-18
2023-04-17
2024-01-11
2023-10-03
2023-09-09
2023-06-13
2023-08-07
2023-03-11
历史内容
快速导航到对应月份的历史文章列表。
随便看看
拉到页底了吧,随便看看还有哪些文章你可能感兴趣。
时光飞逝
"流光容易把人抛,红了樱桃,绿了芭蕉。"