Mobabel | Just One Pure Coder

Mobabel Blog

May 17, 2019

[总结]消息中间件–5 消息处理失败&死信队列

消息中间件消费到的消息处理失败怎么办？一般生产环境中，如果你有丰富的架构设计经验，都会在使用MQ的时候设计两个队列：一个是核心业务队列，一个是死信队列。核心业务队列，就是比如专门用来让订单系统发送订单消息的，然后另外一个死信队列就是用来处理异常情况的。比如说要是第三方物流系统故障了，此时无法请求，那么仓储系统每次消费到一条订单消息，尝试通知发货和配送，都会遇到对方的接口报错。此时仓储系统就可以把这条消息拒绝访问，或者标志位处理失败！注意，这个步骤很重要。

Tips

April 21, 2019

mybatis 动态参数及其 foreach collection使用

Mybatis里传参数入Mapper一般基于基本类型，Integer、String、List、Hashtable，然后以此构架foreach迭代动态sql。

<select id="findUserListByIdList" parameterType="java.util.ArrayList" resultType="User">  
    select * from user user  
    <where>  
        user.id in 
        <foreach  collection="listName" item="guard" index="index" 
            separator="," open="(" separator="," close=")" > #{guard} </foreach>   
    </where>  
</select>

select * from user user

<where>

user.id in

<foreach collection="listName" item="guard" index="index"

separator="," open="(" separator="," close=")" > #{guard} </foreach>

</where>

</select>

但是这种方法只针对一级引用，如果参数是Object，比如将下面的Page作为参数传入，其中的PageData已经put了一个名为listName的List。

public class Page
{
   private PageData pd = new PageData();
}


public class PageData extends HashMap<Object, Object> implements
   Map<Object, Object>
{

}

List listName = new ArrayList();

Page page = new Page();
page.getPageData().put("listName", listName );

public class Page

{

private PageData pd = new PageData();

}

public class PageData extends HashMap<Object, Object> implements

Map<Object, Object>

{

}

List listName = new ArrayList();

Page page = new Page();

page.getPageData().put("listName", listName );

但是下面例子调用失败，mybatis无法辨认二级参数pd.listName是个List。

<select id="findUserListByIdList" parameterType="PageData" resultType="User">  
    select * from user user  
    <where>  
        user.id in 
        <foreach  collection="pd.listName" item="guard" index="index" 
             separator="," open="(" separator="," close=")" > #{guard} </foreach>  
    </where>  
</select>

select * from user user

<where>

user.id in

<foreach collection="pd.listName" item="guard" index="index"

separator="," open="(" separator="," close=")" > #{guard} </foreach>

</where>

</select>

没找到直接解决办法，只能绕过foreach而采用String基本类型，尝试如下：

page.getPageData().put("listIdString", “1,2,3,4,5,6” );


<select id="findUserListByIdList" parameterType="PageData" resultType="User">  
    select * from user user  
    <where>  
        user.id in ( #{listIdString})  
    </where>  
</select>

page.getPageData().put("listIdString", “1,2,3,4,5,6” );

select * from user user

<where>

user.id in ( #{listIdString})

</where>

</select>

结果测试结果始终返回id为1的一个数据，而不是1,2,3,4,5,6六个数据。原因是带 #{} 的参数使用的是PreparedStatement，会有类型转换，最终注入sql的不是

user.ID in ( 1,2,3,4,5,6)

1	user.ID in ( 1,2,3,4,5,6)

而是加一层包装作为String注入：

user.ID in ( “1,2,3,4,5,6”)

1	user.ID in ( “1,2,3,4,5,6”)

解决办法，使用 $ {} 参数，这样mybatis不会做任何预处理，直接作为String使用。

<select id="findUserListByIdList" parameterType="PageData" resultType="User">  
    select * from user user  
    <where>  
        user.id in ( ${listIdString})  
    </where>  
</select>

select * from user user

<where>

user.id in ( ${listIdString})

</where>

</select>

注意但是在mybatis中，”${xxx}”这样格式的参数会直接参与sql编译，从而不能避免注入攻击。在涉及到动态表名和列名时，只能使用“${xxx}”这样的参数格式，所以，这样的参数需要我们在代码中手工进行处理来防止注入。参考 mybatis 传入参数及其 foreach collection的三种用法 https://stackoverflow.com/questions/11760074/mybatis-string-as-parameter Mybatis 中$和#千万不要乱用

Log Aggregation

April 12, 2019

[总结]日志开发经验

Spring Boot是如何实现日志的？

SOA Architect and MS Architect

April 12, 2019

[汇总]微服务构架经验

微服务架构，多“微”才合适？

CI & Automation Test

April 12, 2019

[转]阿里巴巴如何基于 Kubernetes 实践 CI/CD

首先简单解释一下何为 Kubernetes 来帮助大家理解。Kubernetes 是一个生产可用的容器编排系统。Kubernetes 一方面在集群中把所有 Node 资源做一个资源池，然后它调度的单元是 Pod，当然 Pod 里面可以有多个容器。就像一个人左手抓着 ECS 资源或计算资源，右手抓容器，然后把它们两个匹配起来，这样它就可以作为一个容器的编排系统。