ICode9

精准搜索请尝试: 精确搜索
  • RabbitMQ2022-09-14 22:02:32

    声明:此文是小白本人学习Spring所写,主要参考(搬运)了: 【中间件】--RabbitMQ - 随笔分类 - 唐浩荣 - 博客园 (cnblogs.com) 1、MQ的介绍与应用场景 1.1 什么是MQ MQ(Message Quene) : 翻译为消息队列,就是指存储消息的一个容器。它是一个典型的生产者和消费者模型,生产者不断向消息队

  • Newtonsoft.Json 编辑Json2022-09-08 18:34:43

    Newtonsoft.Json官网 Json.NET - Newtonsoft、   文档地址Introduction (newtonsoft.com)   示例Modifying JSON (newtonsoft.com) string json = @"{ 'channel': { 'title': 'Star Wars', 'link': 'http://www.starwars

  • RabbitMQ 生产者与消费者Code2022-09-08 07:30:09

    Nuget引入RabbitMQ Client   消费者: // See https://aka.ms/new-console-template for more information using RabbitMQ.Client; using System.Text; Console.WriteLine("Hello, World!"); string dir = AppDomain.CurrentDomain.BaseDirectory; string? consumerNa

  • A08_System.Threading.Channels使用(针对发布-订阅,消息缓冲处理)2022-09-04 15:33:26

    在面对 生产者-消费者 的场景下, netcore 提供了一个新的命名空间 System.Threading.Channels 来帮助我们更高效的处理此类问题,有了这个 Channels 存在, 生产者 和 消费者 可以各自处理自己的任务而不相互干扰,有利于两方的并发处理,这篇文章我们就来讨论下如何使用 System.

  • channel补充2022-09-02 22:35:25

    1. channel 1.1 channel的使用 例子:主go程发数据,子go程收数据。 package main import ( "fmt" "time" ) //主go程发数据,子go程收数据 func chanDemo() { c := make(chan int) go func() { for { fmt.Println(<-c)//不断的向信道获取数据,主go程

  • channel2022-08-30 13:00:48

    channel有缓冲与无缓冲同步问题 package main import ( "fmt" "time" ) func main() { c := make(chan int, 3) //带有缓冲的channel fmt.Println("len(c) = ", len(c), ", cap(c)", cap(c)) go func() { defer fmt.Print

  • channel定义与使用2022-08-30 12:32:29

    channel定义与使用 package main import "fmt" func main() { //定义一个channel c := make(chan int) go func() { defer fmt.Println("goroutine结束") fmt.Println("goroutine 正在运行...") c <- 666 //将666 发送给c

  • RabbitMQ 入门系列:6、保障消息:不丢失:发送方、Rabbit存储端、接收方。2022-08-29 10:00:37

    系列目录 RabbitMQ 入门系列:1、MQ的应用场景的选择与RabbitMQ安装。 RabbitMQ 入门系列:2、基础含义:链接、通道、队列、交换机。 RabbitMQ 入门系列:3、基础含义:持久化、排它性、自动删除、强制性、路由键。 RabbitMQ 入门系列:4、基础编码:官方SDK使用:链接创建、单例改造、发送

  • 如何处理消息丢失的问题?2022-08-29 00:01:24

    如何保证消息的可靠性传输?或者说,如何处理消息丢失的问题? 面试官心理分析 这个是肯定的,用 MQ 有个基本原则,就是数据不能多一条,也不能少一条,不能多,就是前面说的重复消费和幂等性问题。不能少,就是说这数据别搞丢了。那这个问题你必须得考虑一下。 如果说你这个是用

  • RabbitMQ 入门系列:6、保障消息:不丢失:发送方、Rabbit存储端、接收方。2022-08-28 01:32:02

    系列目录 RabbitMQ 入门系列:1、MQ的应用场景的选择与RabbitMQ安装。 RabbitMQ 入门系列:2、基础含义:链接、通道、队列、交换机。 RabbitMQ 入门系列:3、基础含义:持久化、排它性、自动删除、强制性、路由键。 RabbitMQ 入门系列:4、基础编码:官方SDK使用:链接创建、单例改造、发送消

  • RabbitMQ 入门系列:5、基础编码:交换机的进阶介绍及编码方式。2022-08-26 00:30:53

    系列目录 RabbitMQ 入门系列:1、MQ的应用场景的选择与RabbitMQ安装。 RabbitMQ 入门系列:2、基础含义:链接、通道、队列、交换机。 RabbitMQ 入门系列:3、基础含义:持久化、排它性、自动删除、强制性、路由键。 RabbitMQ 入门系列:4、基础编码:官方SDK使用:链接创建、单例改造、发送

  • RabbitMQ 入门系列:5、基础编码:交换机的进阶介绍及编码方式。2022-08-24 13:01:28

    系列目录 RabbitMQ 入门系列:1、MQ的应用场景的选择与RabbitMQ安装。 RabbitMQ 入门系列:2、基础含义:链接、通道、队列、交换机。 RabbitMQ 入门系列:3、基础含义:持久化、排它性、自动删除、强制性、路由键。 RabbitMQ 入门系列:4、基础编码:官方SDK使用:链接创建、单例改造、发送消

  • RabbitMQ 入门系列:2、基础含义理解:链接、通道、队列、交换机2022-08-21 15:03:50

    系列目录 RabbitMQ 入门系列:1、MQ的应用场景的选择与RabbitMQ安装。 RabbitMQ 入门系列:2、基础含义:链接、通道、队列、交换机。 RabbitMQ 入门系列:3、基础含义:持久化、排它性、自动删除、强制性、路由键。 RabbitMQ 入门系列:4、基础编码:官方SDK使用:链接创建、单例改造、发送消

  • 中间件2022-08-20 00:32:36

                                                                                                                         生产者: 1 package com.learn.rabbitmq.simple; 2 3 import com.rabbitmq.client.Ch

  • 20. Redis---发布订阅2022-08-17 20:02:40

    1. 前言 Redis PubSub 模块又称发布订阅者模式,是一种消息传递系统,实现了消息多播功能。发布者(即发送方)发送消息,订阅者(即接收方)接收消息,而用来传递消息的链路则被称为 channel。在 Redis 中,一个客户端可以订阅任意数量的 channel(可译为频道)。 消息多播:生产者生产一次消息,中间件负

  • cometd源码阅读-WebSocketTransport处理过程(六)2022-08-17 13:32:08

    说明 comted内置协议 因为comted 有这些内置协议处理,所以上层协议就是应用层 可以是websoket 也可以是长连接轮训 或者轮训jsonp /** * 建立握手 * 当建立连接后 需要访问这个渠道进行握手 comted将维护内置的连接信息 * Constant representing the handsha

  • Netty实例2022-08-08 17:31:17

      本文netty的实例,主要包括几个知识点   1 如何拿到channel (网上的大多数例子都是写在handler 的 channelActive 方法中的)   2  自定义协议格式,使用 LengthFieldBasedFrameDecoder 解码   3  使用CompleteFuture 模拟同步发送(一次发送收到回复后才进行下一次发送)  

  • 浪潮配置WWipim_NF5280M3 – IPMI设置2022-08-07 09:33:42

    1. 查看/设置管理芯片BMP IP 集成IPMI管理卡IP地址可以在BIOS中的”Server Mgmt”→”BMC network configuration” →”BMC Sharelink Management Channel/ BMC Dedicated Management Channel” →”Sation IP address”菜单中查看或设置。 BMC Sharelink Management Channel:指

  • websocket-cometd源码阅读-初始化(二)2022-08-03 13:37:07

    常规配置 <!-- CometD Servlet --> <servlet> <servlet-name>cometd</servlet-name> <!--<1>--> <servlet-class>org.cometd.annotation.server.CometDServlet</servlet-class> <!--liqiang todo 600000--

  • NetCore+RabbitMQ2022-08-02 18:03:14

    1.首先要清楚什么是RabbitMQ,是干啥用的?   RabbitMQ就是一个消息中间件,那什么又是中间件呐?我的理解是,消息中转站,生产者生产完消息,放入中转站,就接着干别的事情去了。 至于你什么时候消费,就看你自己了,一旦消费成功,中间件将不再存储你的消息。类似我们生活中的菜鸟驿站。 厂家就是生

  • 死信队列测试2022-07-30 23:33:30

    什么是死信队列? 死信队列是用于接收普通队列发生失败的消息,其原理与普通队列相同; 失败消息如:被消费者拒绝的消息、TTL超时的消息、队列达到最大数量无法写入的消息; 死信队列创建方法: 在创建普通队列时,在参数"x-dead-letter-exchange"中定义失败消息转发的目标交换机; 再创建一个

  • Go 通道(channel)32022-07-28 22:03:47

    Futures 模式 Futures 模式是指,当需要用到某个值之前,需要先对该值进行计算,这时候可以将该值的计算放到另一个处理器计算该值,当使用该值时已经计算完毕了。 例如,最终需要 part1 与 part2 的和,求和之前part1和part2都需要处理一些自己的事情,而part2为什么要等待part1做完再做呢 ? 他

  • Go 通道(channel)22022-07-27 23:01:49

    通道、超时和计时器(Ticker) 计时器(间隔指定时间发送一次数据) time 包中有一些有趣的功能可以和通道组合使用,其中就包含了 time.Ticker 结构体,这个对象以指定的时间间隔重复的向通道 C 发送时间值: import "time" chRate := time.Tick(time.Second) //每秒向通道发送一次时间数据 f

  • chan2022-07-27 19:04:26

    package mainimport ( "fmt" "math" "sync" "sync/atomic" "time")type semaphore chan bytefunc wait(s semaphore) bool { _, ok := <- s return ok}func wake(s semaphore) { s <- 'k'

  • Go 通道(channel)2022-07-26 22:36:49

    通道(channel),就像一个可以用于发送类型化数据的管道,由其负责协程之间的通信,从而避开所有由共享内存导致的陷阱;这种通过通道进行通信的方式保证了同步性。数据在通道中进行传递:在任何给定时间,一个数据被设计为只有一个协程可以对其访问,所以不会发生数据竞争。 创建通道 ch1 := mak

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有