skynet 的 C API 采用异步读写,你可以使用 C 调用,监听一个端口,或发起一个 TCP 连接。但具体的操作结果要等待 skynet 的事件回调。skynet 会把结果以 PTYPE_SOCKET 类型的消息发送给发起请求的服务。(参考skynet_socket.h) 在处理实际业务中,这 ...
分类:
Web程序 时间:
2018-07-05 14:52:21
阅读次数:
183
本文提供的分布式事务解决方案的设计思路在所有微服务架构项目中都适用,与编程语言无关,教程中会重点讲解方案的设计思路。 教程中的样例项目基于龙果学院开源的微支付系统进行实现,使用Dubbo作为服务化框架,教程中所实现的分布式事务解决方案在Java体系中的微服务架构系统都能通用,与具体的开发框架无关。 ...
分类:
其他好文 时间:
2018-07-03 18:18:21
阅读次数:
146
一、发布/订阅模式 在软件工程里面,发布/订阅是一种消息模式,这种模式旨在将消息发送者和消息接收者解耦。发送者不需要关心将消息发送给谁,接收者也不需要知道消息的发送者是谁。发送者将消息发布以后就结束动作,接收者可以订阅自己感兴趣的消息。 除了发布/订阅模式还有一种和它很类似的,消息队列,是一种典型的 ...
分类:
其他好文 时间:
2018-07-03 00:12:05
阅读次数:
162
本章是‘网络是怎么连接的--读后感’第二章 前言 本章是系列博客的第二章;第一章讲数据发送的场景;第二章主要讲叙消息是如何发送出去的. 实现需求 消息发送出去需要四部 连接服务器建立管道; 正文 第一章介绍了数据传输的的场景;本章讲结合第五章具体阐述在用户端电脑及服务器上数据是如何收发的。在浏览器上 ...
分类:
其他好文 时间:
2018-07-02 01:22:51
阅读次数:
232
发布与订阅消息系统。 数据(消息)的发送者不会直接把消息发送给接受者,这是发布与订阅消息系统的一个特点。发布者以某种方式对消息进行分类,接受者订阅他们,以便接受特定类型的消息。发布与订阅系统一般会有一个broker,也就是发布消息的中心点。 传统的交互方式: 用户>应用服务器>db 缺点:高并发服务 ...
分类:
其他好文 时间:
2018-06-26 11:07:22
阅读次数:
400
1.需要的jar包 <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <version>5.15.4</version> </dependency> <dependenc ...
分类:
其他好文 时间:
2018-06-24 14:04:23
阅读次数:
192
在前面的两篇博客中 RabbitMQ入门:Hello RabbitMQ 代码实例 RabbitMQ入门:工作队列(Work Queue) 遇到的实例都是一个消息只发送给一个消费者(工作者),他们的消息模型分别为(P代表生产者,C代表消费者,红色代表队列): 这次我们来看下将一个消息发送给多个消费者( ...
分类:
其他好文 时间:
2018-06-21 13:50:36
阅读次数:
185
并发:多个运算同时发生。并发模型:共享内存 消息传递共享内存:并发模块通过在内存中读写共享对象进行交互 ①两个处理器共享物理内存②两个程序共享文件③两个线程(同一个java程序)共享对象 消息传递:并发模块通过通信通道相互发送消息进行交互。模块发送消息,并将传入的消息发送到每个模块以便处理 ①网络中 ...
分类:
其他好文 时间:
2018-06-16 23:02:05
阅读次数:
238
主角: MVP是一种编程的架构模式,M=Model,负责提供数据;V=View,负责显示数据;P=Presenter,负责处理数据。 应用例子: csharp写的一个qq机器人。 一、Model层 获取消息 发送消息 二、Presenter层 监听消息 处理消息 三、View层 好友消息接收反馈 群 ...
分类:
其他好文 时间:
2018-06-15 00:57:00
阅读次数:
173
基于 NIO 的非阻塞实现并行调用,客户端不需要启动多线程即可完成并行调用多个远程服务,相对多线程开销较小。 在 consumer.xml 中配置: 调用代码: 你也可以设置是否等待消息发出: sent="true" 等待消息发出,消息发送失败将抛出异常。 sent="false" 不等待消息发出, ...
分类:
其他好文 时间:
2018-06-14 01:18:15
阅读次数:
173