2 ncq 1993 ncq_1993 于 2016.04.27 11:49 提问

camel怎么向mina:tcp中发送消息






public void transformService1(Exchange exchange, @Body @Encoded String body,
@Header(value = "Content-Type") String contentType)
throws IOException {
LOGGER.info("body is:" + body);

    System.out.println("测试测试");
    //如果不是json数据,会被过滤掉
    System.out.println(body);
    //MessageVO msg = objectMapper.readValue(body, MessageVO.class);
    // 转换为新的格式 form 方式
   // UriMap map = new UriMap();
    /*map.put("msgId", msg.getMsgId());
    map.put("msgType", msg.getMsgtype());*/
    exchange.getOut().setBody("====");
}

    当我方法走完,mina:tcp://127.0.0.1:60000并没有监听到任何数据,求大神告知下
Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!
其他相关推荐
mina整合spring ,服务端反向发送消息到客户端 完整实例
之前的项目需要用到mina,实现的功能主要是:服务端主动发送消息到客户端,这个的服务端为外网的tomcat,客户端为内网的tomcat,由于无法知道内网tomcat 的地址,也就不能直接通过http的方式发送信息回来,最后想来想去用mina实现了这个功能。 当然,我这里的服务端是整合的了spring 的,也可以直接把服务端独立出来,不整合spring,这个都一样,区别不大。 代
Mina框架并实现Server与Client端的简单消息传递!
Hibernate系列学习阶段到此结束了,那么紧接着进入Apache Mina的开发学习,很多童鞋在微薄和QQ中疑问Himi为什么突然脱离游戏开发了,嘿嘿,其实可能更多的童鞋已经看出来了,Himi在偏向服务器Server端开发了,Hibernate、MySQL等都是为了Server端Mina开发而做的铺垫,当前的Apache Mina才是Himi真正的目的。哈哈。Himi的技术目标是“一个人能做出
第二篇:mina作为tcp服务器如何管理客户端
刚开始用这个玩意的时候,很多东西不是很了解,所以走了很多弯路,大概记录一下。 推荐大家去看看这篇博客,当初也是因为看了这篇博客,才知道自己理解错误的地方:点击打开链接 1.mina框架的编码解码工厂 mina和netty都有这么一个怪毛病,他的编码解码工厂都是单例的,至今未搞懂这么设计的目的,如果有哪位大神知道,可以留言教教我哦。 虽然mina的编码解码工厂都是单例的,但是,当每次有一个客
第三篇: mina作为TCP客户端及注意要点
一.简单的demo ClientMain.java ClientMinaMain.java public class ClientMinaMain { public static void main(String args[]) { NioSocketConnector conn=new NioSocketConnector(); conn.getFilterChain().add
使用Mina2.x编写同时支持TCP和HTTP的服务端
完整版见https://jadyer.github.io/2013/07/12/mina-tcp-http-server/
Mina框架数据发送流程
Mina框架经常用,但是具体的细节还是摸不清楚。稍稍深入了一下代码,看了一下数据流程,在此做一些记录。 先看一下大致的流程。详细的说明网上很多,比如官方网站: http://mina.apache.org/mina-project/userguide/user-guide-toc.html   部分层的细节也没有深究。主要看了一下IoFilter IoFilter is oneof th
mina 服务端主动发送的一种方法
可以在服务端的handler中利用HashSet将session保存下来,具体做法可以是: 在sessionCreateddd的时候加入到HashSet(sessions)中public void sessionCreated(IoSession session) throws Exception { /**/ sessions.add(session);
MINA客户端建立连接,收发消息
public class LocalClient { private static final Logger log = Logger.getLogger(AppLocalClient.class); /** * 当前Session与本地6001端口通信 */ private static IoSession session = null; /** * 执行客户端消息 * @a
mina及时推送客户端服务端实现
一个对推送 及时的处理结束,长连接保持,以及对客户端 和服务端的实现,
Camel In Action 第三章 数据转换
第三章 数据转换 本章包括: 使用EIPs和Java两种方式装换数据 转换XML格式的数据 通用数据格式装换 编写转换器 理解Camel的类型装换机制 在现实生活中,人们说不用的语言,在IT世界中,有不同的协议。当进行系统集成时,软件工程师经常需要在各种协议之间充当调解人。为了解决这个问题,使用的数据模型必须从一种形式转换到另一个协议,以适应任何协议发的接收者都能够理解。