在windows server 2008上安装websphere mq7.5 服务端,建立队列。通过java client向我的机器的队列发送消息和接收消息。 mq安装成功,队列管理器、队列、通道也都建起来了,用mq自带的api检测程序检测也成功了。 接下来,在另外一台机器上通过程序发送消息,结果就 ...
分类:
其他好文 时间:
2020-06-18 10:54:47
阅读次数:
312
前言: 要了解rocketMq 需要知道 数据在 rocketMq 中 是如何进行传输,在底层的结构到底是一个什么亚子,这个需要我们对Netty 对字符编解码有一些了解。 开始: 我们从生产者发送消息,broker 接收消息 为例,来开展底层对消息结构。 1. 如下是一段生产者发送消息的代码,这里我 ...
分类:
Web程序 时间:
2020-06-13 23:10:22
阅读次数:
78
介绍 Redis发布订阅(pub/sub)是一种消息通信模式:发布者(pub)发送消息,订阅者(sub)接收消息。 应用的领域:微信公众号、微博的关注、还有一些关注系统等! Redis客户端可以订阅任意数量的频道。 订阅/发布消息图: 总共有三个对象:消息的发送者、频道、消息的订阅者! 下图展示了频 ...
分类:
其他好文 时间:
2020-06-06 15:38:30
阅读次数:
66
急速入门 - 消息生成与消费 1. ConnectionFactory : 获取连接工厂 2. Connection : 一个连接 3. Channel:数据通信信道,可发送和接收消息 4. Queue:具体的消息存储队列 5. Producer & Consumer 生产者和消费者 RabbitM ...
分类:
其他好文 时间:
2020-06-06 13:17:57
阅读次数:
56
1.Rabbitmq是如何在接收消息之后将队列中的消息删除呢? channel.basicConsume("myQueue",true,new DefaultConsumer(channel){})//第二个参数是true,代表的就是接收消息之后自动删除队列中的消息。 手动确认消息是怎么实现的呢? ...
分类:
其他好文 时间:
2020-06-04 13:57:09
阅读次数:
55
一、简介 Redis 发布订阅(pub/sub)是一种 消息通信模式 :发送者(pub)发送消息,订阅者(sub)接收消息。(比如:微信、 微博、关注系统!) Redis 客户端可以订阅任意数量的频道。 订阅/发布消息图: 第一个:消息发送者, 第二个:频道 第三个:消息订阅者! 下图展示了频道 c ...
分类:
其他好文 时间:
2020-05-27 01:12:50
阅读次数:
66
本文主要介绍 1. 立即执行函数 :又叫自执行函数,定义即执行 2. 变量提升 : 作用域内提升 3. 闭包 : 一个可以访问私有作用域的函数及其所在的运行环境的组合 4. 使用闭包定义私有变量 :变量私有化 5. 模块化 :作用域独立化及私有化 6. 柯里化 :定义多参数函数增加函数使用灵活性 7 ...
分类:
Web程序 时间:
2020-05-22 13:14:14
阅读次数:
54
命令write,功能是给指定用户发信息(接收信息的用户要处于登录状态,相当于QQ的私聊),例如:用户xbb给用户liuyifei发消息:I want to eat together!(发送消息以CRTL+D保存结束) 接收消息的一方会及时显示发送消息的用户以及终端和时间,并显示具体的消息内容 命令w ...
分类:
系统相关 时间:
2020-05-01 12:26:53
阅读次数:
68
实验平台 linux 实验内容 编写UDP服务器和客户端程序,客户端发送消息,服务器接收消息,并打印客户端的IP地址和端口号。 实验原理 UDP是无需连接的通信,其主要实现过程如下: 同样,我们可以按照上一篇博客:基于TCP的客户端和服务器端的代码设计 的办法,将服务器代码分成两部分,一个是初始化, ...
分类:
其他好文 时间:
2020-04-10 12:02:14
阅读次数:
65
1.引入依赖 2.配置ServerEndpointExporter 这个bean会自动注册使用了@ServerEndpoint注解声明的Websocket endpoint。 3.创建websocket的ServerEndpoint端点 4.前端配置连接与接收消息 5.实现后端推送消息至浏览器端 此 ...
分类:
编程语言 时间:
2020-04-07 12:55:53
阅读次数:
78