greemranqq
- 浏览: 975429 次
- 性别:
- 来自: 重庆
-
最新评论
-
Carvendy许：
16/11/18 16:21:17 ERROR SparkDe ...
spark 笔记1 -- spark程序连接 -
谁说长得帅就不爷们：
什么情况下会有 p!=t ?
源码分析-ConcurrentLinkedQueue -
di1984HIT：
spring +ehcache 持久化数据，重启恢复 -
lc464297691：
给个我实现的代码，需要自己写一个类继承之～
public ab ...
JAVA数据库连接池实现 -
lc464297691：
100%发生死锁！ if (isValid(conn)) ...
JAVA数据库连接池实现
文章列表
一、序言
消息大多数情况都是发送到broker 的，在知道Destination 的情况下，都可以消费，因此有些情况下需要我们将消息分组、隔离，或则指定A消息，只能有A消费者消费等等情况，这里做个大概的介绍和实例。
二、实例场景
我们通过有时候我们需要一个queue/topic 通道，然后发送消息，但是我们要对不同消费者接受的消息进行限制，或者说过滤，就可以使用这种情况。
我这里建立一个queue,分别发送 300条A,B消息，分别有消费者A,B接收
三、代码实例
基本连接代码这里就就不贴了，建议前的
...
一、序言
JMS 用于系统解耦有一定帮助，像我们 iteye 的一些系统消息，可能非重要要消息，就没那么严格的限制，统一异步发送就行了，反正上线你就能看到。有些情况下我们需要消息两端进行确认，比如一些比较重要的金额之类的信息。
二、实例场景
我们ERP系统中的财务模块是分开的，当成一个单独的财务系统，那么从ERP那么那送的财务信息，或者财务系统接收了，需要给ERP 那边一个确认信息，不然消息没处理成功或者其他异常，导致金额数据出问题，这个麻烦比较大的。
三、JMS 场景对应
场景一：
1.Producer -- ...
一、序言
现在互联网应用很多，每个应用又以服务的形式提供给其他应用，这样颗粒度比较细，相互影响就会减低，因此提供了很多SOA 的一些RPC的框架，比如：dubbo 、webservice、GRPC、dubbo、commonRPC等，这里先提供一个dubbo 的实例。
二、dubbo 基本工作原理
来源：http://alibaba.github.io/dubbo-doc-static/Home-zh.htm
1.原理图：来自网络
从上图我们可以看出
1：register 注册到服务中心 ...
一、序言
有些情况下，我们需要将公共的工程，或者公共的接口打成jar,然后上传到公共仓库，让其他工程共用，这里我模拟dubbo 的，写一个简单接口工程，然后打成jar,让其他工程使用。
二、实践
1.用idea 建立一个maven 工程，目录结构src->main->java
2.在Java 下面建立一个接口 和一个静态类，并且作为java source ，表示我要让其他人调用
public interface HelloService {
public void sayHello(String ...
一、序言
这里记录了安装ubuntu 系统，以及里面常用的东西，jdk,idea,maven,svn,git 等等工具的安装，因为这些动作不是经常操作的，因此这里做一个记录，方便新手或者忘记的时候看看。
二、JDK 安装
1.关于ubuntu 的安装，我这里不介绍了，用的是U盘启动的方式，版本是14.1，直接从官方网站下下来，我8G内存，用的64位的系统，当然一些基本的命令这里不介绍了。
2.JDK 的安装，我用的JDK8，先去官网下载为1.8.xxx.tar.gz,我放到自己建立的program 文件下
...
一、序言
有时候我们追求最快的方式发送消息，我们就采用的异步方式，并且不持久化。但是这样带来的问题有这样几个：
1.如果消费者的消费能力低于生产者，那么消息就会积压在broker, 从而导致broker 可能挂掉。
2.我们知道存放内存的模式，只要出现宕机或者其他问题，容易丢消息，因此得看情况而定
对于问题1，activemq 采用了限流 内存溢出提醒的方式进行处理，下面是一些实例过程。
官方介绍可以参考：http://activemq.apache.org/producer-flow ...
一、序言
这里简单介绍了JAVA 应用程序部署linux 服务器上的一些常用监控信息，虽然现在很多自动化监控的东西，但是一些基本的东西，我们还是需要了解。这里是简单记录一下：
二、操作过程
1.我习惯性先看看 CPU 和内存的使用情况，做一个简单的关注
命令：top 可以关注运行状态
命令：大写P：按CPU 使用排序，大写M：按内存使用排序，小写c:详细显示应用
比如A应用出现
VIRT:虚拟内存总共2G，RES：物理已经内存占用：1.8G，并且 ...
一、序言
这里有个任务，通过每天用户的登录日志文件，对固定信息进行切割，然后保存到新的文件，并上传到另外的服务器进行处理。
二、日志信息：
当天的日志文件名：webapp-login.log
日志主要内容：
[INFO ] [16:09:31] LOGIN - 张三(803521136) - pramms_xxxxxxxxx
[INFO ] [16:09:35] LOGIN - 李四(803521136) - pramms_xxxxxxxxx
[INFO ] [16:09:35] LOGIN - ERROR - 王五(803521136) ...
一、序言
以下是我对zookeeper 的一些理解： zookeeper 作为一个服务注册信息存储的管理工具，好吧，这样说得很抽象，我们举个“栗子”。
栗子1号：
假设我是一家KTV的老板，我同时拥有5家KTV，我肯 ...
原文地址：http://ifeve.com/how-to-calculate-threadpool-size/
感谢网友【蒋小强】投稿。
如何合理地估算线程池大小？
这个问题虽然看起来很小，却并不那么容易回答。大家如果有更好的方法欢迎赐教，先来一个天真的估算方法：假设要求一个系统的TPS（Transaction Per Second或者Task Per Second）至少为20，然后假设每个Transaction由一个线程完成，继续假设平均每个线程处理一个Transaction的时间为4s。那么问题转化为：
如何设计线程池大小，使得可以在1s内处理完20个Transaction？
...
spring xmemcached 注解介绍
- 博客分类：
- 缓存
一、序言
前面介绍了下simple-spring-memcache 的一些基本配置，这里就介绍下 一些注解和简单场景的试用。
二、基本场景和注解使用
2.1.通过 userId 返回数据，先从数据库查询，然后缓存，以便后面直接从缓存获取
@ReadThroughSingleCache
@ReadThroughSingleCache(namespace = "test", expiration = 30000)
// 这注解主要返回带参数的对象，如果是User 类似的对象 要记得序列化
pub ...
一、序言
有了缓存，还是喜欢用注解去使用，本想和spring 写一个类似ehcache 的东西，后来发google 已经提供了spring 和memcache 的 注解配置，那就先拿来用用了~。~。
二、基本配置：
2.1 先把spring 和 memcached 结合起来，创建一个spring-xmemcached.xml 的文件
<!-- 用这个代替xmemcacheClient去构建client -->
<bean id="xmemcacheBuilder" class=&qu ...
一、序言
这里先简单介绍下memcache 缓存在windows 上的安装 以及应用，然后再进行一些简单的测试，客户端用是xmemcached ，因为业界整体效果不错
1.先现在windos 64 位的，我是win8，
参考：http://blog.couchbase.com/memcached-windows-64-bit-pre-release-available，解压到 。 f:\memcache\下
2.打开DOS 在文件目录下执行：memcached.exe -d in ...
一、序言
demo2 留下了两个问题：
1.我们利用demo2 的配置，在queue 模式下 连续发送10W消息出现出现状况。
2.topic 模式下，消费者重启时间段收不到监听的信息怎么办？
二、问题解析：
1.测试 发送10W消息，中途会出现
socket: tcp://localhost:61616 due to: java.net.BindException: Address already in use: JVM_Bind 异常。
你关掉activemq,利用netstat ...
这里仅仅记录下topic 模式的的消息情况：
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
import java.io.Serializable;
/**
* Created by qiqiang on 2014/12/11.
*/
public class Sender {
static ConnectionFactory f ...