加载中
小乞丐 2019/04/30 09:49 回答了问题: 有没有做过棋牌类游戏的小伙伴~~

有兴趣可加微信   luochen220473  详聊~

@小乞丐
寻找个人做过棋牌类游戏的小伙伴~~ base 四川更佳~
哪个是你一点都不重要。中间那个妹子杠杠的~
@小小编辑
Osc乱弹歌单(2019)请戳(这里)【今日歌曲】@花间小酌 :分享周华健的单曲《难念的经》《难念的经》- 周华健...

做少爷去了吗?

@bug制造专家
如果工作外收入是工资的3~5倍,会考虑辞职创业吗?
小乞丐 2018/09/11 15:18 回答了问题: netty4.x 数据发送问题

TCP&UDP测试工具 ,百度下很多。具体用的哪一个我给忘记了。~

@小乞丐
大家好: 最近研究netty中遇到一个奇怪的问题,客户端采用tcp工具模拟,服务端是netty编写,在handle...
5.7以上版本可降低隔离级别,或者单事物条,5.6 版本应该不存在此问题。
@java_龙
目录 概述 问题重现与解析 Innodb lock机制 概述 正在奋力写"BUG"中,同事说出现死锁了,让帮忙看一...
小乞丐 2018/02/07 13:54 评论了博客:如何编写高性能的 RPC 框架
真心希望能使用jdk7 或者 8啊 。 。。。。。。。
@鲁小憨
在 [RPC Benchmark Round 1](https://my.oschina.net/u/101475...

@terrymanu  1.x 还能继续使用吗?

@局长
OSCHINA 本期高手问答(2017 年 3 月 7 日 — 3 月 13 日)我们请来了 @terrymanu...

mian 方法启动使用的是同一个move对象. 及两个线程使用的是同一个锁。

每次只会有一个线程在执行方法. 

所以按照截图代码应该不会存在楼主描述的问题才对。。

@达文西W
为什么运行成这样,就不向下运行了
千万级别表 count(Id)很慢 、ID是主件、如何优化?
@局长
OSCHINA 本期高手问答(2016 年 12 月 6 日 — 12 月 13 日)我们请来了@叶金荣和@吴炳锡...
看着给共产党的个人所得税........ 心里拔凉拔凉的...
@上海大意科技有限公司
50K还是更高,呵呵,大家说说
24 是不是少了点点....
@大力水手奥利弗
近期工作室业务越来越忙~~, 现有人手忙不过来, 所以我们需要找一个合适的javaer, 不需要多牛逼, 但最好是...
你是线程池.. 执行完毕后当然是waiting, 等待新任务呀,当有新任务来到后,被选中执行的线程就会变成running,当执行完成后就变成了waitting,要想关闭就关闭线程池,或者不用线程池,执行完毕后就销毁了
@wohenkuaihuo
问题如下, 我的项目部署在linux之后,在多线程执行完毕之后,调用jstack 命令查看线程使用情况,发现线程池...
/**
     * 推送消息体封装 根据别名推送
     * 
     * @param alias
     * @param message
     * @return
     */
    private PushPayload buildPushObjectForAlias(String alias, String message) {
        return PushPayload.newBuilder()
                .setPlatform(Platform.android_ios())
                .setAudience(Audience.alias(alias))
               .setNotification(Notification.alert(message))
                  /**
                 * 如果目标平台为 iOS 平台 需要在 options 
                 * 中通过 apns_production 字段来制定推送环境。
                 * True 表示推送生产环境,False 表示要推送开发环境; 如
                 * 果不指定则为推送生产环境
                 */
               .setOptions(Options.newBuilder()
                       .setApnsProduction(true)
                       .build())
                .build();
    }
    
@娄外楼
已知现有一个app,但是没有后台管理项目,现在对后台管理进行开发。目前需求在项目中集成极光推送的接口,远程调用。使...
小乞丐 2016/09/20 11:36 回答了问题: 出来工作6年了 存款才30W 怎么破
炫富啊....
@benxiongjava
小弟今年27 毕业在深圳已经是第6个年头了今天特意去银行查了下帐,银行定期存款才30W。心突然感觉拔凉拔凉的,即将...
小乞丐 2016/09/20 11:34 回答了问题: 为什么我坚持招聘程序员必须笔试


+1

@南湖船老大
总是看到有那么多招聘的纠结要不要笔试,应聘的坚决抵制笔试,我就说说我的看法:1.谈架构的10个有9个是骗子,30岁...
小乞丐 2016/07/07 09:57 回答了问题: 大家觉得易语言怎么样
作为中国人,友情支持一下吧~
@上海大意科技有限公司
品味低,就这一点。低品味是从根部开始发散出来的,从作者汉化某语言,到给中学生提供各种外挂模块,就是一种正事不干的感...

客户端代码:

logger.info("开始连接任务调用监控服务器." + host + ":" + port);
		transport = new WstTFramedTransport(new TSocket(host, port, timeout));
		TProtocol protocol = new TCompactProtocol(transport);
		client = new MonitorTaskThriftServer.Client(protocol);
		transport.open();
		logger.info("任务调用监控服务器成功. " + host + ":" + port);

WstTFramedTransport 是复制TFramedTransport类,加了个getTransport方法 来获取transport_ 。

服务端代码:

try{
			TNonblockingServerSocket serverTransport = new TNonblockingServerSocket(new InetSocketAddress("0.0.0.0", port), timeout);
			THsHaServer.Args trArgs = new THsHaServer.Args(serverTransport);
			/**TTransport协议类型参见thrift.txt文件 */
			trArgs.protocolFactory(new TCompactProtocol.Factory());
			trArgs.transportFactory(new WstTFramedTransport.Factory());
			//trArgs.processorFactory(new TProcessorFactory(processor));
			trArgs.processorFactory(new TProcessorFactory(new LogProcessor(processor)));
			server = new THsHaServer(trArgs);
			Executors.newSingleThreadExecutor().execute(new Runnable() {
				@Override
				public void run() {
					server.serve(); //启动服务
				}
			});
		}catch(Exception ex){
			logger.error("thrift 非阻塞服务启动异常." + ex.getMessage());
			throw new ThriftException(ex);
		}



LogProcessor 类:


 /** 
     * 该方法,客户端每调用一次,就会触发一次 
     */ 
	@Override
	public boolean process(TProtocol in, TProtocol out) throws TException {
		  
		 /** 
         * 从TProtocol里面获取TTransport对象 
         * 把TTransport对象转换成TSocket,然后在TSocket里面获取Socket,就可以拿到客户端IP 
         */  
		WstTFramedTransport transport = (WstTFramedTransport)in.getTransport();  
		TSocket socket = (TSocket)transport.getTransport();
	   SocketAddress clientIp = socket.getSocket().getRemoteSocketAddress();
	   logger.info("接收到来至[" + clientIp + "]的请求.");
	   return processor.process(in, out);
	}








@小乞丐
服务端: TNonblockingServerSocket serverTransport = new TNonb...

java.lang.ClassCastException: org.apache.thrift.transport.TMemoryInputTransport cannot be cast to org.apache.thrift.transport.TSocket

按照你说的方式 任然不行哦。

@小乞丐
服务端: TNonblockingServerSocket serverTransport = new TNonb...

没有更多内容

加载失败,请刷新页面

返回顶部
顶部