搜索结果
查询Tags标签： Channel，共有 341条记录-
go并发 - channel
概述 并发编程是利用多核心能力，提升程序性能，而多线程之间需要相互协作、共享资源、线程安全等。任何并发模型都要解决线程间通讯问题，毫不夸张的说线程通讯是并发编程的主要问题。go使用著名的CSP（Communicating Sequential Process，通讯顺序进程）并发模型，从设计…
2023/11/19 18:32:32 人评论 次浏览 -
RabbitMQ
声明：此文是小白本人学习Spring所写，主要参考（搬运）了：【中间件】--RabbitMQ - 随笔分类 - 唐浩荣 - 博客园 (cnblogs.com)1、MQ的介绍与应用场景 1.1 什么是MQ MQ(Message Quene) : 翻译为消息队列，就是指存储消息的一个容器。它是一个典型的生产者和消费者模型，生…
2022/9/14 23:19:09 人评论 次浏览 -
channel定义与使用
channel定义与使用package mainimport "fmt"func main() {//定义一个channelc := make(chan int)go func() {defer fmt.Println("goroutine结束")fmt.Println("goroutine 正在运行...")c <- 666 //将666 发送给c}()num := <-c //从c中…
2022/8/30 23:23:00 人评论 次浏览 -
channel
channel有缓冲与无缓冲同步问题package mainimport ("fmt""time" )func main() {c := make(chan int, 3) //带有缓冲的channelfmt.Println("len(c) = ", len(c), ", cap(c)", cap(c))go func() {defer fmt.Println("子go程结…
2022/8/30 23:22:53 人评论 次浏览 -
RabbitMQ 入门系列：5、基础编码：交换机的进阶介绍及编码方式。
系列目录RabbitMQ 入门系列：1、MQ的应用场景的选择与RabbitMQ安装。 RabbitMQ 入门系列：2、基础含义：链接、通道、队列、交换机。 RabbitMQ 入门系列：3、基础含义：持久化、排它性、自动删除、强制性、路由键。 RabbitMQ 入门系列：4、基础编码：官方SDK使用：链接创建…
2022/8/26 6:55:55 人评论 次浏览 -
Netty实例
本文netty的实例，主要包括几个知识点1 如何拿到channel （网上的大多数例子都是写在handler 的 channelActive 方法中的）2 自定义协议格式，使用 LengthFieldBasedFrameDecoder 解码3 使用CompleteFuture 模拟同步发送（一次发送收到回复后才进行下一次发送）协议体 p…
2022/8/8 23:24:36 人评论 次浏览 -
websocket-cometd源码阅读-初始化(二)
常规配置<!-- CometD Servlet --><servlet><servlet-name>cometd</servlet-name><!--<1>--><servlet-class>org.cometd.annotation.server.CometDServlet</servlet-class><!--liqiang todo 600000--><init-para…
2022/8/4 14:25:18 人评论 次浏览 -
RabbbitMQ客户端发布消息
1、客户端lib<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.15.0</version> </dependency>2、获取连接和信道 //1、设置连接工厂 ConnectionFactory factory = new Conne…
2022/7/26 23:26:11 人评论 次浏览 -
Go 通道（channel）
通道（channel），就像一个可以用于发送类型化数据的管道，由其负责协程之间的通信，从而避开所有由共享内存导致的陷阱；这种通过通道进行通信的方式保证了同步性。数据在通道中进行传递：在任何给定时间，一个数据被设计为只有一个协程可以对其访问，所以不会发生数据竞…
2022/7/26 23:23:39 人评论 次浏览 -
netty系列之:文本聊天室
目录简介 聊天室的工作流程 文本处理器 初始化ChannelHandler 真正的消息处理逻辑 总结简介 经过之前的系列文章，我们已经知道了netty的运行原理，还介绍了基本的netty服务搭建流程和消息处理器的写法。今天本文会给大家介绍一个更加复杂的例子，文本聊天室。 聊天室的工…
2022/7/22 23:33:47 人评论 次浏览 -
NetCore RabbitMQ ，Routing定向模式
十年河东，十年河西，莫欺少年穷 学无止境，精益求精 上篇博客介绍了RabbitMQ的六种工作模式 RabbitMQ的六种工作模式 RabbitMQ的简单模式和Work工作模式请参考：NetCore RabbitMQ 简介及兔子生产者、消费者 【简单模式，work工作模式，竞争消费】 RabbitMQ发布订阅模式之…
2022/7/22 23:29:21 人评论 次浏览 -
RabbitMq在windows安装配置
RabbitMq简介1.1消息队列中间件简介消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题实现高性能，高可用，可伸缩和最终一致性[架构] 使用较多的消息队列有 ActiveMQ（安全），RabbitMQ，ZeroMQ，Kafka（大数据），MetaMQ，RocketMQ以…
2022/7/17 5:16:08 人评论 次浏览 -
flume-day01 flume基本介绍
Flume架构 1.1 Hadoop业务开发流程1.2 Flume概述flume是一个分布式、可靠、和高可用的海量日志采集、聚合和传输的系统。 支持在日志系统中定制各类数据发送方，用于收集数据; 同时，Flume提供对数据进行简单处理，并写到各种数据接受方(比如文本、HDFS、Hbase等)的能力 。…
2022/7/10 23:53:23 人评论 次浏览 -
Docker安装RabbitMQ Java实战详解
下载 RabbitMQ 镜像rabbitmq:3-management 默认安装并启用 rabbitmq_managementdocker pull rabbitmq:3.10-management 创建并运行 RabbitMQ 容器 docker run -d -p 5672:5672 -p 15672:15672 \-e RABBITMQ_DEFAULT_USER=admin \-e RABBITMQ_DEFAULT_PASS=admin \--hostna…
2022/7/7 1:22:34 人评论 次浏览 -
详细图解 Netty Reactor 启动全流程 | 万字长文 | 多图预警
本系列Netty源码解析文章基于 4.1.56.Final版本大家第一眼看到这幅流程图，是不是脑瓜子嗡嗡的呢？大家先不要惊慌，问题不大，本文笔者的目的就是要让大家清晰的理解这幅流程图，从而深刻的理解Netty Reactor的启动全流程，包括其中涉及到的各种代码设计实现细节。在上篇…
2022/7/5 0:00:28 人评论 次浏览
