博客首页 → 消息

最新文章列表

RocketMQ（03）——通过Tag对消息分类

通过Tag对消息分类 RocketMQ建议一个业务系统只使用一个Topic，不同类型的消息通过tag来区分。tag可以在构造Message的时候指定，下面代码就指定了发送的消息的tag都为tag0。 @Test public void sendWithTag() throws Exception { DefaultMQProducer producer = new DefaultM ...
RocketMQ消息消费选择Tag 
234390216 评论(0) 有3695人浏览 2019-12-28 19:41

RabbitMQ实战篇（一）--虚拟机上RabbitMQ的安装及使用

我们都知道，RabbitMQ 是目前非常热门的一款消息中间件，不管是互联网行业还是传统行业都在大量地使用。那么什么是消息？什么是消息中间件？这些专有名词都必须有了解。   一、消息中间件概述 1、消息 (Message) 是指在应用间传送的数据。消息可以非常简单，比如只包含文本字符串、JSON 等，也可以很复杂，比如内嵌对象。 2、消息中间件，全称叫消息队列中间件 (Message Qu ...
rabbitMQRabbitMQ消息中间件消息中间件 
zhaodengfeng1989 评论(0) 有1034人浏览 2019-02-01 10:03

Kafka伪分布式环境安装

     单节点的伪分布式环境是指集群由一台ZooKeeper服务器和一台Kafka broker服务器组成。   4.2.1 安装Java 从Oracle官网下载JDK，建议下载JDK8及以上版本，如： wget --no-check-certificate --no-cookie --header "Cookie:oraclelicense=accept-secureba ...
Kafka环境安装分布式消息
拓子轩 评论(0) 有696人浏览 2018-11-25 16:05

Kafka的Consumer主要参数

3.2.2.1 bootstrap.servers 同生产者bootstrap.servers参数。   3.2.2.2 group.id 该参数指定的是consumer group的名字，它能够唯一标识一个consumer group。通常设置一个有业务意义的名字就可以了。   3.2.2.3 key.deserializer consumer代码从broker端获取的任何消息都 ...
Kafkaconsumer消息消费端
拓子轩 评论(0) 有1540人浏览 2018-11-25 15:56

Kafka的Consumer构建

3.2.1.1 消息消费的demo代码 消息消费的demo代码如下： package com.tuozixuan.kafka.demo;   import java.util.Arrays; import java.util.Properties;  
Kafkaconsumer消息
拓子轩 评论(0) 有960人浏览 2018-11-25 15:52

Kafka的Producer主要参数

  1 bootstrap.severs   该参数指定一组host:post对，用于创建向Kafka broker服务器的连接，比如k1:9092,k2:9092,k3:9092。如果Kafka集群中机器数很多，那么只需要指定部分broker即可，不需要列出所有的机器。因为不管指定几台机器，producer都会通过该参数找到并发现集群中所有的broker。为该参数指定多台机器只是为了故障 ...
Kafkaproducer消息参数
拓子轩 评论(0) 有1460人浏览 2018-11-17 16:48

分布式开放消息系统(RocketMQ)的原理与实践

分布式开放消息系统(RocketMQ)的原理与实践 http://www.jianshu.com/p/453c6e7ff81c
消息Messagequeue 
darrenzhu 评论(0) 有673人浏览 2017-05-07 19:55

RabbitMQ安装与配置

一、安装Rabbit MQ   1. 下载并安装Erlang：http://www.erlang.org/downloads 2. 下载并安装Rabbit MQ：http://www.rabbitmq.com/releases/rabbitmq-server/       默认安装的Rabbit MQ 监听端口是15672   二、Rabbit MQ配置和运行   1. 激活管 ...
RabbitMQ消息mq异步 
拓子轩 评论(0) 有5658人浏览 2016-11-14 15:38

MPush开源消息推送系统：简洁、安全、支持集群

引言 由于之前自己团队需要一个消息推送系统来替换JPUSH,一直找了很久基本没有真正可用的开源系统 所有就直接造了个轮子，造轮子的时候就奔着开源做打算的，只是后来创业项目失败一直没时间整理 这一套代码，最近比较闲就拿出来给开源做点贡献。 作为Java版的开源推送系统，MPUSH还是有很多不错的设计的，特别是对想自己搭建一套推送系统的团队 是有很大的借鉴意义的。当然开源出来也是不想曾 ...
pushtcpim消息推送 
ohunbeyond 评论(0) 有863人浏览 2016-08-28 10:04

Kafka 0.9+Zookeeper3.4.6集群搭建、配置，新Client API的使用要点，高可用性测试，以及各种坑

Kafka 0.9版本对java client的api做出了较大调整，本文主要总结了Kafka 0.9在集群搭建、高可用性、新API方面的相关过程和细节，以及本人在安装调试过程中踩出的各种坑。   关于Kafka的结构、功能、特点、适用场景等，网上到处都是，我就不再赘述了，直接进入正文   Kafka 0.9集群安装配置   操作系统：CentOS 6.5     1. 安装J ...
kafka高可用java消息zookeeper 
kelgon 评论(4) 有12465人浏览 2016-04-01 11:57

Kafka 0.9+Zookeeper3.4.6集群搭建、配置，新版Java Client的使用要点，高可用性测试，以及各种坑（二）

上一节中（点此传送），我们完成了Kafka集群的搭建，本节中我们将介绍0.9版本中的新API，以及Kafka集群高可用性的测试   1. 使用Kafka的Producer API来完成消息的推送   1) Kafka 0.9.0.1的java client依赖： <dependency> <groupId>org.apache.kafka</ ...
kafka高可用java消息zookeeper 
kelgon 评论(0) 有10847人浏览 2016-03-31 20:56

Kafka 0.9+Zookeeper3.4.6集群搭建、配置，新版Java Client的使用要点，高可用性测试，以及各种坑（一）

Kafka 0.9版本对java client的api做出了较大调整，本文主要总结了Kafka 0.9在集群搭建、高可用性、新API方面的相关过程和细节，以及本人在安装调试过程中踩出的各种坑。   关于Kafka的结构、功能、特点、适用场景等，网上到处都是，我就不再赘述了，直接进入正文   Kafka 0.9集群安装配置   操作系统：CentOS 6.5     1. 安装J ...
kafka高可用java消息zookeeper 
kelgon 评论(0) 有3257人浏览 2016-03-30 15:44

Apache Kafka 分布式消息系统

Reference： http://www.infoq.com/cn/articles/apache-kafka http://kafka.apache.org/documentation.html RabbitMQ,遵循AMQP协议，由内在高并发的erlanng语言开发，用在实时的对可靠性 ...
kafkaRabbitMQpublish-subscribe消息 
依然任逍遥 评论(0) 有728人浏览 2015-10-13 17:46

Spring3.2.3整合MQ-WS_MQ_V7.5

记录给需要帮助的人~ step ：1 pom.xml <spring-framework.version>3.2.3.RELEASE</spring-framework.version> <mq.version>7.5.0.3</mq.version> <dependency> <groupId&g ...
MQSpring3.2.3监听定时消息 
zhangliguoaccp 评论(0) 有1861人浏览 2015-09-30 10:29

weichat 微信开发之接受普通消息

     接入微信  使用 ngrok  http://knight-black-bob.iteye.com/blog/2244830   接受普通消息  源码下载 ： http://download.csdn.net/download/knight_black_bob/9123671 WeichatServlet.java package com.curiousby.cn; ...
weichat微信开发接受普通消息 
knight_black_bob 评论(0) 有1994人浏览 2015-09-20 17:14

Kafka介绍

1. 引言 互联网够公司的日志无处不在，web日志，js日志，搜索日志，监控日志等等。对于这些日志的离线分析（Hadoop），wget&rsync虽然人力维护成本较高，但可以满足功能行需求。但对于这些日志的实时分析需求（例如实时推荐，监控系统），则往往必须要引入一些“高大上”的系统。 传统的企业消息系统（例如WebSphere）并不是非常适合大规模的日志处理系统，理由如下：1) 过于关 ...
消息kafkatopic 
welcome66 评论(0) 有1453人浏览 2015-06-03 11:40

线程及消息传递机制

一：创建线程     1.通过Thread类的构造方法创建。 Thread thread = new Thread(new Runnable() { @Override public void run() { // do something; } });     2.通过实现Runnable接口创建。   public class PageActivity1 ...
Android线程消息 
elviszhao 评论(0) 有1529人浏览 2015-05-09 10:41

MQ、JMS以及ActiveMQ 关系的理解

详见： http://blog.yemou.net/article/query/info/tytfjhfascvhzxcyt127 ms 的一个标准或者说是一个协议. 通常用于企业级应用的消息传递. 主要有topic 消息(1 对多), queue 消息(1对1). activemq 是一个jms 的实现, apache 出的. 另外还其它的实现 jboss 啦啥的 ...
消息队列消息MQactiveMQJMS 
grefr 评论(0) 有1299人浏览 2015-03-18 13:31

消息转发机制

之前想了解runtime的先关知识，无意中发现了消息转发机制，就自己动手写了些。     如上图所示：在oc中调用方法时，本类及父类找不到此方法时，有如下步骤。要重写一下方法。   第一步：尝试动态方法解析   void dynamicMethod(id self, SEL _cmd) { printf("SEL %s did not exist\n" ...
ios消息转发
liubo0_0 评论(0) 有1046人浏览 2014-08-13 16:44

最近博客热门TAG

Java(141744) C(73651) C++(68608) SQL(64571) C#(59609) XML(59133) HTML(59043) JavaScript(54919) .net(54785) Web(54514) 工作(54118) Linux(50905) Oracle(49875) 应用服务器(43289) Spring(40812) 编程(39454) Windows(39381) JSP(37542) MySQL(37267) 数据结构(36424)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics