异步调用,返回的结果要怎么处理

java,
a方法调用b方法,b方法的返回值是string类型的,a在调用b方法的时候,b方法先返回一个“正在处理,请稍后” 的默认返回值,然后b方法中异步调用c方法,c方法上贴了@async这个spring的注解,c方法执行完之后将结果封装到asyncResult中返回给b,请问,b在获取到c的结果时应该怎么样再次将结果返回给a???

1个回答

异步任务返回的是一个 Future 类型的结果,那么就需要由其调用者 B 来处理该结果,此时 B 已经返回结果给了 A ,所以 B 不可能再返回结果给 A 了。如果希望 B 直接将异步结果返回给 A ,那么不应该返回字符串,而是 C 的异步结果,然后在 A 中轮询该异步结果是否完成。参照https://www.cnblogs.com/wihainan/p/6516858.html 该文第二个例子,while(true) 轮询异步任务结果。

如果这是 Web 应用,A 作为控制层的话,通用方式是:立即返回“正在处理” 的信息给前台,后台异步任务完成后推送一条消息给前台再回显异步任务的结果。

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
一个奇怪的c#客户端 异步事件调用datagridview控件的问题
我的客户端有两个界面,下面就简称为Form1 和Form2。 Form1有一个datagridview控件,需要有的操作就是在控件里循环载入数据库中的数据并清空再下一轮载入数据。 Form2的功能是监听网络请求并如果收到请求告诉Form1开始工作。 然后问题就来了如果 在Form1 中调用这个操作没有任何问题,如果用Form2调用这个操作的方法(这里是用了一个委托事件触发的,而且因为在调用Form中方法的同时还需要保持监听,所以用线程池做成异步来处理)就会返回main主函数抛出一个空指针异常,但是我断点调试没有找到空指针的对象。异常如图: ![图片说明](https://img-ask.csdn.net/upload/201912/13/1576202647_246492.png) ![图片说明](https://img-ask.csdn.net/upload/201912/13/1576202720_799585.png) 然后上错误代码: Form1对控件操作: ``` public void test() { Monitor.Enter(this); try { for (int i = 0; i < 7; i++) { Control.CheckForIllegalCrossThreadCalls = false; string fn = list[i]; OpenDB(fn); //Thread.Sleep(1000); } } finally { Monitor.Exit(this); } } void connectToDB(string fn) { m_dbConnection = new SQLiteConnection("Data Source=" + fn + ";Version=3;"); //m_dbConnection.SetPassword("abc"); m_dbConnection.SetPassword("1234LiaoQiu4321"); m_dbConnection.Open(); } public void OpenDB(string fn) { try { string sql; SQLiteCommand command; connectToDB(fn); sql = @"SELECT * FROM [评分细则] ORDER BY [步骤];"; command = new SQLiteCommand(sql, m_dbConnection); SQLiteDataReader reader = command.ExecuteReader(); dataGridView2.Rows.Clear(); object[] obj = new object[10]; while (reader.Read()) { for (int i = 0; i < 10; ++i) { obj[i] = reader[i]; } dataGridView2.Rows.Add(obj); } reader.Close(); } catch //(Exception ex) { MessageBox.Show("打开失败!", "错误", MessageBoxButtons.OK, MessageBoxIcon.Exclamation); } finally { m_dbConnection.Close(); } } /// <summary> /// 事件订阅 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void 其他窗口运行ToolStripMenuItem_Click(object sender, EventArgs e) { Form2 ab = new Form2(); ab.getEvent += test; ab.Show(); } ``` Form2: ``` public delegate void getHandler(); public event getHandler getEvent; private void button1_Click(object sender, EventArgs e) { ThreadPool.QueueUserWorkItem(new WaitCallback(test), new object()); } public void test(object val) { getEvent(); } ``` Form2这里是我写的一个模拟错误调用的demo,因为监听网络调用调式比较麻烦,所以用button模拟触发 收到消息这个动作。考虑过跨线程调用控件的问题,所以已经加了禁用语句。 问题奇怪的地方有三个:1.如果是Form1本身的线程调用,或者Form2中不加异步就不会抛异常;2,调试时发现循环第一次不会出错,也就是会往控件里加载一次数据,但是第N次循环就可能会出现问题,出错的循环次数是哪一次无法确定,但是肯定会有一次出错。3.报错的位置不在调试时卡住的地方而是回到main主函数报错 而且目前找到一种解决办法就是在循环提内加入延迟,就是Thread.Sleep(500),这样也不会报错,但是不理解这样做就不报错的原因
有关于Socket异步通讯的问题
在长连接状态下的客户端程序;首先分为两部分,第一部分是发送方法,发送方法被用来响应整个程序的某些事件和Http请求,这些事件和请求驱动发送方法向服务器发送相应的数据; 第二部分是接收部分,接收部分开启一个线程不断的异步接收从服务器发送过来的数据根据协议来完成解析,解析出的不同数据传入不同的方法进行相应的处理。 以上是我这个做的这个小项目中收发机制的一小部分描述; 接下来是我想问的,客户端程序发送相应的包文之后,如果被服务器接收并解析成功则会收到服务器的一份回应包文,用以反映该包文是否提交成功。问题就是我在两边都异步处理的情况下,回应包文在接收线程中被处理了,我在发送的方法中怎么去获取我此次发送的回应包文呢,这样我才能知道我发送是否成功了,才能给调用事件和HTTP请求正确的返回值! 新菜一只,求大佬们解答!这是个小白问题,大佬们飕飕的回答我吧
AsynTask中怎么返回数据填充到ListView中
我调用新浪微博的SDK,其中调用官方的APT方法--userTimelineIds获取微博ID,官方方法如下: /** * 获取用户发布的微博的ID * * @param uid 需要查询的用户ID * @param since_id 若指定此参数,则返回ID比since_id大的微博(即比since_id时间晚的微博),默认为0 * @param max_id 若指定此参数,则返回ID小于或等于max_id的微博,默认为0 * @param count 单页返回的记录条数,默认为50 * @param page 返回结果的页码,默认为1 * @param base_app 是否只获取当前应用的数据。false为否(所有数据),true为是(仅当前应用),默认为false * @param featureType 过滤类型ID,0:全部、1:原创、2:图片、3:视频、4:音乐,默认为0 * <li> {@link #FEATURE_ALL} * <li> {@link #FEATURE_ORIGINAL} * <li> {@link #FEATURE_PICTURE} * <li> {@link #FEATURE_VIDEO} * <li> {@link #FEATURE_MUSICE} * @param listener 异步请求回调接口 */ public void userTimelineIds(long uid, long since_id, long max_id, int count, int page, boolean base_app, int featureType, RequestListener listener) { WeiboParameters params = buildTimeLineWithApp(since_id, max_id, count, page, base_app, featureType); params.put("uid", uid); requestAsync(SERVER_URL_PRIX + "/user_timeline/ids.json", params, HTTPMETHOD_GET, listener); } 可以看出是用了AsynTask实现的异步回调。但是具体的requestAsync被新浪封装,无法查看和修改。 在我自己的Activity中调用如下: /** * 通过登录的用户id获取其发过的所有微博id */ mStatuseAPI.userTimelineIds(uid, 0L, 0L, 50, 1, false, StatusesAPI.FEATURE_ALL, new RequestListener() { //异步回调就是发起请求后,不等待响应就先去处理自己的响应 @Override public void onWeiboException(WeiboException error) { // TODO Auto-generated method stub //出错就打印出错信息 error.printStackTrace(); } @Override public void onComplete(String result) { // TODO Auto-generated method stub Log.i(TAG, result); //当括号内参数为(null)或者("")时,返回true,此方法既可以判断字符串也可以判断对象 if(!TextUtils.isEmpty(result)){ getWbList(result); }else{ Log.i(TAG, "获取不到微博ID或者此用户没有发过微博"); } } }); 这里onComplete方法返回的result是在异步回调线程中的,请问怎么将数据拿到Activity中。这里由于requestAsync无法查看和修改。就不能重载AsynTask里的onPostExcate()方法传回结果。 请问该怎么在主线程中拿到数据?
请问微信支付支付成功后如何获取所谓notify的返回值
情况其实不复杂,就是有一个地方一直没搞明白。我已经按照demo构成好了xml包,顺利的换取到了prepal_id,也通过js的那个接口,顺利的能弹出输入密码的对话框,也能输入密码并且钱也到了我的账户上来,都OK。 但一直困扰我的是这个:$input->SetNotify_url("http://www.xxxx.com/index.php/aaa/bbb");这一行似乎一直不起作用。因为在调用了获取prepal_id的unifiedOrder接口后,返回的数据已经不包含这个参数了。而在付完钱也弹出相应的官方的账单页面后,我发现bbb函数压根没有执行(已经提前在bbb函数中写了一段创建文件的代码,但未有新文件生成)。 其他教程基本都教到掉用JS接口弹出输入框就结束了,后面附加一句,当交易成功中,通知接口会收到一份XML文档(含有transaction_id等参数),可以用GET方法获取。所谓通知接口应该就是我们事先设置好的notify_url没跑了。但这个notify_url在文档的解释是异步处理,那理论上不需要我们另外调用,我试过另行跳转,但无法GET到相关信息。 那么不主动跳转的话,这个异步动作是在什么时候执行的呢?我要如何GET到transaction_id等参数,在收到钱的同时做些别的事情呢(给买家派发短信等)?
【Struts2】如何处理网站首页中的各个子栏目或频道?
网站的首页一般都会调用很多栏目的最新内容,但是一个action往往只能完成一项任务,请教如何通过一个参数来控制各个栏目的数据调用? 第一次学习struts2,一直没有搞明白?希望大家帮助。 [b]问题补充:[/b] 多个list的确可以做在action中,但是灵活性和效率都很差。我希望能够使用一个参数或者像函数调用一样的获取各个栏目的list然后去迭代。 从灵活性,效率上来说还有没有更好的方法? 谢谢! [b]问题补充:[/b] 【例如javaeye的首页】 http://www.iteye.com/ 《Java编程和企业应用热点》和《动态语言编程热点》等栏目都是调用同一个数据库知识分类不同而已,难道没有更简单的办法吗? [b]问题补充:[/b] [quote]你可以把这些操作都封装成一个服务层的方法,每次只要传栏目的ID,再调用服务层的方法,就可以得到该栏目下对应的记录。[/quote] 如何与action联系呢,url调用的时候毕竟对应一个action,对于数据不同类型有异的返回也就是一个result. 那么如何根据不同的类别(参数)返回不同的result? [b]问题补充:[/b] 【sunlightcs 】 尽管不是我所期盼的答案,还是很感谢您。 谢谢! :idea: [b]问题补充:[/b] 【一般可以使用ajax异步加载首页内容,这个时候Ba类的queryList可以返回JSON数据,然后再返回客户端再处理。】 如果这样处理,就和dwr和Ext的方式就差不多了,十分感谢您的回答。
在OLTP环境下,spark使用场景
现在有个OLTP系统,调用的接口规则比较复杂,接口传入数据也比较多,需要1-2秒返回结果,有1000条记录2-3个字段,能否利用spark相关组件作为服务程序,并行处理这些记录,加快响应时间,或在本地多线程并行处理,spark设计主要目的是处理异步模型,对于同步模型处理是否在机制上有时延。
ActiveMQ,使用设置监听的方式异步获取消息
使用设置监听的方式,在收到MQ消息后,需要对消息进行解析处理,我是直接在这个内部类里面调用外部类的方法进行处理的。想请教一下,外部类是否可以获取到这个内部类收到的MQ消息? ``` consumer.setMessageListener(new MessageListener() { @Override public void onMessage(Message message) { TextMessage tm = null; String msg; if(message instanceof ActiveMQTextMessage){ tm = (TextMessage) message; try { msg = tm.getText(); logger.info("获取前台发送的MQ信息" + msg); System.out.println( msg); String result=""; is_summary=getInstance().getIs_summary(msg); List<FundsInvestorInfoModel> iList=getInstance().getInvestorInfoModelList(msg); List<String> ticketList=getInstance().getTicketList(msg); is_all=getInstance().is_all(msg); result=getInstance().checkDeposit(is_summary, is_all, iList, ticketList); getInstance().sendMQ(result,""); logger.info("返回到前台的MQ消息" +result); System.out.println( result); } catch (JMSException e) { logger.error(e.getMessage(), e); } } } }); ```
请问 Mysql master/slaver 方式实际解决办法
1.Mysql里复制由于异步特性(如果同步,写性能肯定比较糟糕)所以延迟是理论上肯定的。某些时候需要进行数据处理的时候,系统中突然产生大量的数据写入,master和slaver都要承担相同的写压力,这时候slaver也基本会产生很大延迟的。比方我举个例子: 页面上通过Page1提交请求从系统外更新一批数据(比如调用其他网站的API),请求完成后页面调转到Page2,Page2请求上次API的调用结果,由于Page1请求和API调用都很快完成,但是Mysql复制发生了延迟,结果Page2请求却没有得到任何数据,更用户带来数据丢失的感觉。后台处理流程如下:Page1请求获取数据成功,数据存入master,然后数据开始异步复制。Page2数据请求中数据库操作被路由到某一个延迟的slaver,没有读取到数据而返回,请问你们在实际中是怎么处理的?过程图在附件中 2。写入Master的数据在写入slaver中的过程中但没有完成,Master就坏了(我知道master/slaver可以双向的,master坏了可以变slaver),这部分只保存在Master的数据请问你们在实际中是怎么恢复呢? 感谢
关于回调函数的问题,请大佬们解答下,谢谢
今天百度了一天回调函数的内容,知道了回调函数实际上是将整个函数以一个参数的形式传递给另一个参数,但是在用Jquery的ajax时一直搞不明白,我们执行完一个url后会返回数据data,然后success(data)会再进一步处理数据,success就是回调函数了,但完全搞不懂为什么这个回调函数是在主体函数执行完才结束的,难道说主体函数结束的最后一句语句就是调用这个回调函数吗?还是说js有自己的机制,检测到是回调函数就会用浏览器的异步形式去处理,再放到队列中等到主体函数执行完再放进栈中处理?求教大神帮忙解答一下,困惑了一天。
主线程等待子线程运行结束再完成的效果如何实现
主线程抛出一个子线程异步处理一些东西,这时主线程要等待子线程运行完成再完成(其实我是为了统计运行时间的)。 这里抛出的子线程可能递归的调用自己,就是再抛一个他的子线程出来,但是到底一共抛多少,事先是不知道的。 应用场景: 1)多线程扫描文件夹内的文件,遇到文件夹内有子文件夹,要递归调用扫描线程的,等到全部扫描完成后,返回结果,显示; 2)多线程快速排序,第一次肯定是单线程的,第一次排序完成后,会分两半,这两半多线程排,递归调用了这个排序线程,这两半很有可能,极大有可能再各分两半,也就是会有4个子线程的子线程再排序。 我试过网上的那个 CountDownLatch ,但是他只能实现定义好子线程的数量,但是在以上两种情景下,事先你是不知道会有多少个子线程的! c++里有个WaitForSingleObject,java里有么?
为啥接受不到数据AJAX
``` <script src ="Js/jquery-3.4.1.js"> </script> <script> ////定义变量保存XmlHttpRequest对象 //var xmlHttp = null; ////用于创建AJAX请求核心对象XmlHttpRequest //function createXmlHttpRequest() { // try // { // xmlHttp = new XMLHttpRequest();//适用于IE7+,Fireiox,Chrome等主流浏览器 // } // catch (Error) // { // xmlHttp = new ActiveXObject("Microsoft.XMLHTTP");//适用于IE低版本7以下的 // } //} //$(function () { // $("#ImgButOn").click(function () { // //调用函数创建XmlHttpRequest对象 // createXmlHttpRequest(); // //获得需要提交给服务器的数据 // var UserId = $("#TxtUser").val(); // var UserPwd = $("#TxtPwd").val(); // //服务端路劲,同时把数据传送到服务器地址拦 // var serverPath = "server.ashx?UserId=" + UserId + "&UserPwd=" + UserPwd + ""; // //设置XmlHttpRequest对象参数 // xmlHttp.open("get", serverPath, true); // //服务端处理结果,使用XmlHttpRequest对象状态监测 // xmlHttp.onreadystatechange = clicentCallback; // //通过XmlHttpRequest对象发送请求 // xmlHttp.send(); // }) //}) //function clicentCallback() { // //XmlHttpRequest对象状态从开始发送请求到服务端经历了4个分别是: // //返回值 0 :请求位初始化 // //返回值 1 :和服务端连接已经建立 // //返回值 2 : 请求已被服务端接受 // //返回值 3 :请求处理中 // //返回值 4 :请求处理完 // if (xmlHttp.readyState == 4) { // if (xmlHttp.status == 200) { // //获得服务端返回给客户端的结果(纯文本,xml,josn,html) // var msg = xmlHttp.responseText; // alert(msg); // } // } //} //#Jquery封装函数使用AJAX异步请求 $(function () { $("#ImgButOn").click(function () { $.ajax({ url:"server.ashx",//请求服务端地址 type:"get",//请求方式 data:{ "UserId": $("#TxtUser").val(), "UserPwd":$("#TxtPwd").val() }//发送到服务端的数据 success:function (date, status, xmlhttp) {//服务端成功处理时回调函数 alert(date + ":" + status); }, error: function () {//服务端失败时的回调函数 alert("请求未成功!"); }, dataType:"text"//预期服务端发回数据类型 }) }) </script> public void ProcessRequest(HttpContext context) { SES_Model.User user = new SES_Model.User(); //服务端要获得客户端以AJAX请求发送过来的数据 string UserId = context.Request.QueryString["UserId"]; string UserPwd = context.Request.QueryString["UserPwd"]; //在服务器中处理数据 user = SES_BLL.Users_Service.User_Enter(UserId, UserPwd); string msg = string.Empty; if (user != null) { msg = "ok"; } else { msg = "error!"; } context.Response.ContentType = "text/plain"; context.Response.Write(null); } ```
asp.net 微信扫码支付 回调处理的问题
我使用开发模式二,先调用统一下单接口生成订单,然后在回调地址里面处理更新订单状态以及商品库存的逻辑,最后通知微信支付完成。 下载了官方的demo,发现回调方法里面的代码是这样的。 ``` public override void ProcessNotify() { WxPayData notifyData = GetNotifyData(); //检查openid和product_id是否返回 if (!notifyData.IsSet("openid") || !notifyData.IsSet("product_id")) { WxPayData res = new WxPayData(); res.SetValue("return_code", "FAIL"); res.SetValue("return_msg", "回调数据异常"); Log.Info(this.GetType().ToString(), "The data WeChat post is error : " + res.ToXml()); page.Response.Write(res.ToXml()); page.Response.End(); } //调统一下单接口,获得下单结果 string openid = notifyData.GetValue("openid").ToString(); string product_id = notifyData.GetValue("product_id").ToString(); WxPayData unifiedOrderResult = new WxPayData(); try { unifiedOrderResult = UnifiedOrder(openid, product_id); } catch (Exception ex)//若在调统一下单接口时抛异常,立即返回结果给微信支付后台 { WxPayData res = new WxPayData(); res.SetValue("return_code", "FAIL"); res.SetValue("return_msg", "统一下单失败"); Log.Error(this.GetType().ToString(), "UnifiedOrder failure : " + res.ToXml()); page.Response.Write(res.ToXml()); page.Response.End(); } //若下单失败,则立即返回结果给微信支付后台 if (!unifiedOrderResult.IsSet("appid") || !unifiedOrderResult.IsSet("mch_id") || !unifiedOrderResult.IsSet("prepay_id")) { WxPayData res = new WxPayData(); res.SetValue("return_code", "FAIL"); res.SetValue("return_msg", "统一下单失败"); Log.Error(this.GetType().ToString(), "UnifiedOrder failure : " + res.ToXml()); page.Response.Write(res.ToXml()); page.Response.End(); } //统一下单成功,则返回成功结果给微信支付后台 WxPayData data = new WxPayData(); data.SetValue("return_code", "SUCCESS"); data.SetValue("return_msg", "OK"); data.SetValue("appid", WxPayConfig.APPID); data.SetValue("mch_id", WxPayConfig.MCHID); data.SetValue("nonce_str", WxPayApi.GenerateNonceStr()); data.SetValue("prepay_id", unifiedOrderResult.GetValue("prepay_id")); data.SetValue("result_code", "SUCCESS"); data.SetValue("err_code_des", "OK"); data.SetValue("sign", data.MakeSign()); Log.Info(this.GetType().ToString(), "UnifiedOrder success , send data to WeChat : " + data.ToXml()); page.Response.Write(data.ToXml()); page.Response.End(); } private WxPayData UnifiedOrder(string openId, string productId) { //统一下单 WxPayData req = new WxPayData(); req.SetValue("body", "test"); req.SetValue("attach", "test"); req.SetValue("out_trade_no", WxPayApi.GenerateOutTradeNo()); req.SetValue("total_fee", 1); req.SetValue("time_start", DateTime.Now.ToString("yyyyMMddHHmmss")); req.SetValue("time_expire", DateTime.Now.AddMinutes(10).ToString("yyyyMMddHHmmss")); req.SetValue("goods_tag", "test"); req.SetValue("trade_type", "NATIVE"); req.SetValue("openid", openId); req.SetValue("product_id", productId); WxPayData result = WxPayApi.UnifiedOrder(req); return result; } ``` 文档中第十步是这样写的 ** (10)微信支付系统通过发送异步消息通知商户后台系统支付结果。商户后台系统需回复接收情况,通知微信后台系统不再发送该单的支付通知。** 为何没有看到对订单状态更新的逻辑代码呢?为什么又调用了一次统一下单API呢? 百思不得其解,求大神指导,谢谢!
ajax获取不到php从数据库里面读取到的数据,(php读取到的数据已经成功转换成了json数据)
javascript代码: ```javascript // 初始化两个数组,盛装从数据库中获取到的数据 var dates = new Array(), moneys = new Array(); //调用ajax来实现异步的加载数据 function getusers() { $.ajax({ type: "post", async: false, data:{}, url: "dataDemo/dataIndex.php", data: {}, dataType: "json", success: function(result){ if(result){ for(var i = 0; i < result.length; i++){ dates.push(result[i].sum); moneys.push(result[i].money); } } }, error: function(errmsg) { alert("Ajax获取服务器数据出错了!"+ errmsg); } }); return dates, moneys; } //执行异步请求 getusers(); ``` public_function.php代码: ```php <?php function dbInit(){ global $con; $dsn = "mysql:dbname=info;localhost=127.0.0.1"; $user = "root"; $password = "644066YanMin&&!+"; try{ $con = new PDO($dsn,$user,$password); }catch(PDOExcepetion $e){ die ("Error!: " . $e->getMessage() . "<br/>"); } } /* 处理结果集中有多条数据的函数; */ function fetchAll($sql){ global $con; class user{ public $times; public $money; } if($result = $con->query($sql)){ //声明数组,用于接收结果集; $data = array(); //遍历结果集; while($row = $result->fetch(PDO::FETCH_ASSOC)){ $user = new User(); $user->times = $row['times']; $user->money = $row['sum']; $data[] = $user; } return $data; }else{ //执行失败; return false; } } ``` dataIndex.php代码 ```php <?php require "public_function.php"; dbInit(); $sql = 'select times,sum from date'; $datas = fetchAll($sql); // 返回JSON类型的数据 echo json_encode($datas); //$con = null; require "dataIndex.html"; ```
android 关于支付宝移动支付的一些问题
从支付宝官网下载了一个支付的demo。在植入自己的项目时候我把关于支付的代码都抽取出来了。 手机上有支付宝客户端的时候能正常调用。当卸载支付宝后无法调用了。 /** * @date 2016年6月6日 下午7:54:33 * @Class MpayUtils */ package com.example.testzhifu; import java.io.UnsupportedEncodingException; import java.net.URLEncoder; import java.text.SimpleDateFormat; import java.util.Date; import java.util.Locale; import java.util.Random; import com.alipay.sdk.app.PayTask; import android.annotation.SuppressLint; import android.app.AlertDialog; import android.content.Context; import android.content.DialogInterface; import android.os.Handler; import android.os.Message; import android.support.v4.app.FragmentActivity; import android.text.TextUtils; import android.widget.Toast; public class MpayUtils { private FragmentActivity activity; public MpayUtils(Context context, FragmentActivity activity) { super(); this.activity = activity; } // 商户PID public static final String PARTNER = ""; // 商户收款账号 public static final String SELLER = ""; // 商户私钥,pkcs8格式 public static final String RSA_PRIVATE = ""; // 支付宝公钥 public static final String RSA_PUBLIC = ""; private static final int SDK_PAY_FLAG = 1; @SuppressLint("HandlerLeak") private Handler mHandler = new Handler() { @SuppressWarnings("unused") public void handleMessage(Message msg) { switch (msg.what) { case SDK_PAY_FLAG: { PayResult payResult = new PayResult((String) msg.obj); /** * 同步返回的结果必须放置到服务端进行验证(验证的规则请看https://doc.open.alipay.com/doc2/ * detail.htm?spm=0.0.0.0.xdvAU6&treeId=59&articleId=103665& * docType=1) 建议商户依赖异步通知 */ String resultInfo = payResult.getResult();// 同步返回需要验证的信息 String resultStatus = payResult.getResultStatus(); // 判断resultStatus 为“9000”则代表支付成功,具体状态码代表含义可参考接口文档 if (TextUtils.equals(resultStatus, "9000")) { Toast.makeText(activity, "支付成功", Toast.LENGTH_SHORT).show(); } else { // 判断resultStatus 为非"9000"则代表可能支付失败 // "8000"代表支付结果因为支付渠道原因或者系统原因还在等待支付结果确认,最终交易是否成功以服务端异步通知为准(小概率状态) if (TextUtils.equals(resultStatus, "8000")) { Toast.makeText(activity, "支付结果确认中", Toast.LENGTH_SHORT).show(); } else { // 其他值就可以判断为支付失败,包括用户主动取消支付,或者系统返回的错误 Toast.makeText(activity, "支付失败", Toast.LENGTH_SHORT).show(); } } break; } default: break; } }; }; /** * call alipay sdk pay. 调用SDK支付 * */ public void pay(String arg1, String arg2, String arg3) { if (TextUtils.isEmpty(PARTNER) || TextUtils.isEmpty(RSA_PRIVATE) || TextUtils.isEmpty(SELLER)) { new AlertDialog.Builder(activity).setTitle("警告").setMessage("需要配置PARTNER | RSA_PRIVATE| SELLER") .setPositiveButton("确定", new DialogInterface.OnClickListener() { public void onClick(DialogInterface dialoginterface, int i) { // } }).show(); return; } String orderInfo = getOrderInfo(arg1, arg2, arg3); /** * 特别注意,这里的签名逻辑需要放在服务端,切勿将私钥泄露在代码中! */ String sign = sign(orderInfo); try { /** * 仅需对sign 做URL编码 */ sign = URLEncoder.encode(sign, "UTF-8"); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } /** * 完整的符合支付宝参数规范的订单信息 */ final String payInfo = orderInfo + "&sign=\"" + sign + "\"&" + getSignType(); Runnable payRunnable = new Runnable() { @Override public void run() { // 构造PayTask 对象 PayTask alipay = new PayTask(activity); // 调用支付接口,获取支付结果 String result = alipay.pay(payInfo, true); Message msg = new Message(); msg.what = SDK_PAY_FLAG; msg.obj = result; mHandler.sendMessage(msg); } }; // 必须异步调用 Thread payThread = new Thread(payRunnable); payThread.start(); } /** * create the order info. 创建订单信息 * */ private String getOrderInfo(String subject, String body, String price) { // 签约合作者身份ID String orderInfo = "partner=" + "\"" + PARTNER + "\""; // 签约卖家支付宝账号 orderInfo += "&seller_id=" + "\"" + SELLER + "\""; // 商户网站唯一订单号 orderInfo += "&out_trade_no=" + "\"" + getOutTradeNo() + "\""; // 商品名称 orderInfo += "&subject=" + "\"" + subject + "\""; // 商品详情 orderInfo += "&body=" + "\"" + body + "\""; // 商品金额 orderInfo += "&total_fee=" + "\"" + price + "\""; // 服务器异步通知页面路径 orderInfo += "&notify_url=" + "\"" + "http://notify.msp.hk/notify.htm" + "\""; // 服务接口名称, 固定值 orderInfo += "&service=\"mobile.securitypay.pay\""; // 支付类型, 固定值 orderInfo += "&payment_type=\"1\""; // 参数编码, 固定值 orderInfo += "&_input_charset=\"utf-8\""; // 设置未付款交易的超时时间 // 默认30分钟,一旦超时,该笔交易就会自动被关闭。 // 取值范围:1m~15d。 // m-分钟,h-小时,d-天,1c-当天(无论交易何时创建,都在0点关闭)。 // 该参数数值不接受小数点,如1.5h,可转换为90m。 orderInfo += "&it_b_pay=\"30m\""; // extern_token为经过快登授权获取到的alipay_open_id,带上此参数用户将使用授权的账户进行支付 // orderInfo += "&extern_token=" + "\"" + extern_token + "\""; // 支付宝处理完请求后,当前页面跳转到商户指定页面的路径,可空 orderInfo += "&return_url=\"m.alipay.com\""; // 调用银行卡支付,需配置此参数,参与签名, 固定值 (需要签约《无线银行卡快捷支付》才能使用) // orderInfo += "&paymethod=\"expressGateway\""; return orderInfo; } /** * get the out_trade_no for an order. 生成商户订单号,该值在商户端应保持唯一(可自定义格式规范) * */ private String getOutTradeNo() { SimpleDateFormat format = new SimpleDateFormat("MMddHHmmss", Locale.getDefault()); Date date = new Date(); String key = format.format(date); Random r = new Random(); key = key + r.nextInt(); key = key.substring(0, 15); return key; } /** * sign the order info. 对订单信息进行签名 * * @param content * 待签名订单信息 */ private String sign(String content) { return SignUtils.sign(content, RSA_PRIVATE); } /** * get the sign type we use. 获取签名方式 * */ private String getSignType() { return "sign_type=\"RSA\""; } }
菜鸟新学Ajax,为什么加载不出PHP文档
4-1.html如下: ``` <html xmlns="http://www.w3.org/1999/xhtml"> <head> <meta http-equiv="Content-Type" content="text/html; charset=utf-8" /> <title>使用Ajax技术载入文档</title> </head> <body> <script type="text/javascript"> function Ajax(){ //定义一个函数来异步获取信息 var xmlHttpReq; xmlHttpReq = new XMLHttpRequest(); //实例化一个XMLHttpRequest对象 if (xmlHttpReq != null){ //如果对象实例化成功 xmlHttpReq.open("get","4-1.php"); //设置异步请求的方式和请求的URL xmlHttpReq.send(null); //用send方法发送请求 xmlHttpReq.onreadystatechange = RequestCallBack;}//设置回调函数 function RequestCallBack(){ //一旦readyState值改变,将调用这个函数 if(xmlHttpReq.readyState == 4 && xmlHttpReq.status==200){ //如果浏览器处理完毕并且没有出错 document.getElementById("target").innerHTML = xmlHttpReq.responseText;}//将服务器返回的内容载入到#target元素中 }} </script> <input type="button" value="Ajax载入" onclick="Ajax();"/> <div id="target"></div> </body> </html> ``` 4-1.php代码如下: ``` <?php echo '<b>Hello Ajax!</b>'.date("Y年m月d日"); ?> ``` 点击按钮后出来的效果是 Hello Ajax!'.date("Y年m月d日"); ?> 理想效果应该是加载出具体的年月日 Hello Ajax!2015年10月25日
native client demo 无法加载本地native模块
你好,我刚学习native client,使用sdk里面的例子跑发现无法加载本地native 模块对象。自己按照你说的方法也写了一个demo,但是运行也是发现加载native module对象失败,该值为空。无法加载本地native模块对象。这是怎么回事呀?具体代码如下: 前端: <!DOCTYPE html> <html> <head> <title>hello_tutorial</title> <script type="text/javascript"> hello_tutorialModule = null; // 模块的全局对象 statusText = 'NO-STATUS'; // 更新状态 function moduleDidLoad() { hello_tutorialModule = document.getElementById('hello_tutorial'); updateStatus('SUCCESS'); // 向模块发送消息 hello_tutorialModule.postMessage('hello'); } // 消息句柄函数。句柄在NaCl模块发送相应消息时自动唤起。 // 在C中是PPB_Messaging.PostMessage(),C++中则是pp::Instance.PostMessage() // 在这个demo当中,我们收到消息之后弹窗示意 function handleMessage(message_event) { alert(message_event.data); } // 页面载入时很可能NaCl模块还没有载入,因此我们将状态写为正在读取; // 而如果模块已经载入,则什么都不做。 function pageDidLoad() { if (hello_tutorialModule == null) { updateStatus('LOADING...'); } else { // 事实上,NaCl模块的载入成功事件是不可能在页面载入成功事件之前就发生的, // 因此我们这里简单的认为页面载入之后所更新显示的消息仍旧是当前消息,而不是'SUCCESS'。 updateStatus(); } } // 设置状态。如果存在id为'statusField'的元素,那么将其设置为参数携带的状态 function updateStatus(opt_message) { if (opt_message) statusText = opt_message; var statusField = document.getElementById('status_field'); if (statusField) { statusField.innerHTML = statusText; } } </script> </head> <body onload="pageDidLoad()"> <h1>Native Client Module hello_tutorial</h1> <p> <!-- 读取.nexe文件。通过.nmf,浏览器将结合目前所处的CPU架构来读取不同的模块文件。 于此同时,<embed>元素之外的<div>还绑定着两个事件监听('load'以及'message'), 之所以绑定在div上,而不是embed之上,是为了确保模块在载入之前就可以将监听的绑定彻底完成, 同时也确保了开发者可以在模块内部的初始化阶段调用API发送消息。 --> <div id="listener"> <script type="text/javascript"> var listener = document.getElementById('listener'); listener.addEventListener('load', moduleDidLoad, true); listener.addEventListener('message', handleMessage, true); </script> <embed name="nacl_module" id="hello_tutorial" width=0 height=0 src="hello_tutorial.nmf" type="application/x-nacl" /> </div> </p> <h2>Status</h2> <div id="status_field">NO-STATUS</div> </body> </html> native端: /// @file hello_tutorial.cc /// 载入NaCl模块时,浏览器首先将搜索CreateModule()方法,CreateModule()会返回一个对象实例, /// 之后浏览器会调用该实例的CreateInstance()方法,这时浏览器每遇到一次相应的<embed>就会调用一次。 /// /// 浏览器通过Javascript的postMessage()函数与NaCl通信。 /// 当调用postMessage()时,浏览器会转而调用pp::Instance的HandleMessage()方法。 /// 而如果模块需要与外界主动通信,则是使用pp::Instance的postMessage()方法。 /// 注意,这两个postMessage()都是异步的,因此两者在调用之后迅速返回。 #include <cstdio> #include <string> #include "ppapi/cpp/instance.h" #include "ppapi/cpp/module.h" #include "ppapi/cpp/var.h" namespace { // 这个字符串用来判断消息是否是我们期望的内容 const char* const kHelloString = "hello"; // 这个字符串用来向浏览器返回内容 const char* const kReplyString = "hello from NaCl"; } // namespace /// 每一个NaCl模块都将有一个相应的pp::Instance子类实例对应, /// 为了与浏览器进行通信,你必须重载 HandleMessage()方法以及PostMessage()方法 class hello_tutorialInstance : public pp::Instance { public: explicit hello_tutorialInstance(PP_Instance instance) : pp::Instance(instance) {} virtual ~hello_tutorialInstance() {} /// HandleMessage() 负责接收浏览器中postMessage()发送的消息内容 /// 其中的参数几乎可以表示任何东西,但通常都是JSON字符串,比如这样: /// var json_message = JSON.stringify({ "myMethod" : "3.14159" }); /// nacl_module.postMessage(json_message); virtual void HandleMessage(const pp::Var& var_message) { // 这里是处理消息的代码了 if (!var_message.is_string()) return; std::string message = var_message.AsString(); pp::Var var_reply; if (message == kHelloString) { var_reply = pp::Var(kReplyString); PostMessage(var_reply); } } }; class hello_tutorialModule : public pp::Module { public: hello_tutorialModule() : pp::Module() {} virtual ~hello_tutorialModule() {} virtual pp::Instance* CreateInstance(PP_Instance instance) { return new hello_tutorialInstance(instance); } }; namespace pp { Module* CreateModule() { return new hello_tutorialModule(); } } // namespace pp
手机测试 wx.config 无反应,愿意发微信红包, 求大佬帮忙分析解决
我在微信开发工具测试, wx.config 显示ok , wx.chooseWXPay.没有此SDK或暂不支持此SDK模拟 **问题出在, 我用手机测试 (ios,android) wx.config无反应,** erro和ready均不进入 wx.chooseWXPay也无法用, 我在https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=jsapisign 验证了签名是一毛一样的, 求教大佬, 我这代码是出了啥毛病 ``` <!doctype html> <%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%> <html lang="zh-cn"> <head> <%@include file="/pc/inc/commoncontent.inc"%> <script type="text/javascript" src="http://res.wx.qq.com/open/js/jweixin-1.2.0.js"></script> <script src="<%=contextPath%>/m/smartHotel/script/jquery.min.js" type="text/javascript"></script> <script type="text/javascript"> </script> <title>订单-支付</title> <span class="disb picNum padTB30"><i class="disib iconPic" onClick="openPic(this);" >3532rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr张</i></span> </head> <body> <script type="text/javascript"> var appId1,timeStamp1,nonceStr1,packageStr1,signType1,paySign1; $(document).ready(function () { $.ajax({ url : contextPath+ "/weixin/hotelorder/wxPay.action", type:"post", dataType:'json', //接受数据格式 async: false, data:{url:window.location.href.split('#')[0].replace(/\&/g,"%26")},//传参,建议使用json //1:手机号, 2:房间数.3单价4总价 5: 当前bedid 6 :入住人 姓名 7 发票8 入住日离开日 error:function(data){//请求失败时处理 // alert(data); window.location.href = '<%=contextPath%>/m/smartHotel/html/yysb.html'/*预订失败页*/ }, success:function(data) { if( data) { appId1 = data.pay.appId; timeStamp1 = data.pay.timeStamp; nonceStr1 = data.pay.nonceStr; packageStr1 = data.pay.package; signType1 = data.pay.signType; paySign1 = data.pay.paySign; } wx.config({ debug:false, // 开启调试模式,调用的所有api的返回值会在客户端alert出来,若要查看传入的参数,可以在pc端打开,参数信息会通过log打出,仅在pc端时才会打印。 appId:data.pay.appId, // 必填,公众号的唯一标识 timestamp:data.config.timestamp, // 必填,生成签名的时间戳 nonceStr:data.config.noncestr, // 必填,生成签名的随机串 signature:data.config.configSign, // 必填,签名,见附录1 jsApiList:['chooseWXPay','closeWindow'] }); wx.error(function(res){ alert("error enter"); }); wx.ready(function(){ alert("ready enter"); pay(); }); //onBridgeReady(); // alert("success inter"); } }); }); function pay() { // config信息验证后会执行ready方法,所有接口调用都必须在config接口获得结果之后,config是一个客户端的异步操作,所以如果需要在页面加载时就调用相关接口,则须把相关接口放在ready函数中调用来确保正确执行。对于用户触发时才调用的接口,则可以直接调用,不需要放在ready函数中。 console.log(appId1 +" / "+ timeStamp1+" / " + nonceStr1+" / "+packageStr1 +" / "+ signType1+" / "+paySign1); wx.chooseWXPay({ timestamp:timeStamp1, // 支付签名时间戳,注意微信jssdk中的所有使用timestamp字段均为小写。但最新版的支付后台生成签名使用的timeStamp字段名需大写其中的S字符 nonceStr:nonceStr1, // 支付签名随机串,不长于 32 位 package:packageStr1, // 统一支付接口返回的prepay_id参数值,提交格式如:prepay_id=***) signType:signType1, // 签名方式,默认为'SHA1',使用新版支付需传入'MD5' paySign:paySign1, // 支付签名 success:function(res) { alert("8888888888888"); alert(res); alert(res.errMsg); console.log(res.errMsg); // 支付成功后的回调函数 if (res.errMsg == "chooseWXPay:ok") { //支付成功 alert('支付成功'); } else { alert(res.errMsg); } } }); } function onBridgeReady(){ alert("进入了onbridgeready"); WeixinJSBridge.log("889"); WeixinJSBridge.invoke( 'getBrandWCPayRequest', { "appId":appId1, //公众号名称,由商户传入 "timeStamp":timeStamp1, //时间戳,自1970年以来的秒数 "nonceStr":nonceStr1, //随机串 "package":packageStr1, "signType":"MD5", //微信签名方式: "paySign":paySign1 //微信签名 }, function(res){ WeixinJSBridge.log(res); alert("进入了success"); alert(res.errorMsg); // 使用以下方式判断前端返回,微信团队郑重提示:res.err_msg将在用户支付成功后返回 ok,但并不保证它绝对可靠。 if(res.errMsg == "get_brand_wcpay_request:ok") { alert("支付成功"); // window.location.href = "${pageContext.request.contextPath}/wx/success?orderId=${orderId}"; }else if(res.errMsg == "get_brand_wcpay_request:fail"){ alert('支付失败'); }else if(res.errMsg == "get_brand_wcpay_request:cancel"){ alert('支付取消'); }else{ alert(res.errMsg); } } ); } function openPic() { pay(); //wx.closeWindow(); } //调用模拟 回调 // $.ajax({ // url : contextPath+ "/weixin/hotelorder/moniWXPay.action", // type:"post", // dataType:'json', //接受数据格式 // async: false, // data:{parm1:getQueryString2("orderId")},//传参,建议使用json // error:function(data){//请求失败时处理 // alert(data); // }, // success:function(data) // { // if(data.result =="success") // { // window.location.href = '<%=contextPath%>/m/smartHotel/html/yycg.jsp?orderId='+getQueryString2("orderId"); // } // // } // }); function getQueryString2(name) { var reg = new RegExp("(^|&)" + name + "=([^&]*)(&|$)", "i"); var r = window.location.search.substr(1).match(reg); if(r != null) return decodeURI(r[2]); return null; } </script> </body> </html> ```
Java AIO AsynchronousServerSocketChannel阻塞问题
我在win7 下用aio做了AIO线程测试,大致步骤如下: 1. 使用AsynchronousServerSocketChannel监听6025端口 2. 为第一步设置的channel设定一个大小为4的AsynchronousChannelGroup 3. 为CompletionHandler实现了一个匿名内部类,并且在completed方法中强制当前线程sleep20秒。 4. 然后我开了两个command line窗口,各尝试了一次telnet 6025端口:'telnet localhost 6025' 在我预想中,这两个telnet应该会直接返回,并且在后台打印出相关内容,两次telnet调用应该不会阻塞。 但事实情况是第二次调用会等到第一次调用20s sleep时间过去之后再处理第二条。这是console log,注意一下两次打印的时间差了20s: ``` the main thread is 1 Listening on localhost:6025 Channel Provider : sun.nio.ch.WindowsAsynchronousChannelProvider@17f17060 waiting.... current thread is 10 sleep the thread 10,current time is Fri Aug 04 08:48:21 CST 2017 thread 10 has wake up!!! waiting.... current thread is 11 sleep the thread 11,current time is Fri Aug 04 08:48:41 CST 2017 thread 11 has wake up!!! ``` 这难道就是传说中的阻塞?虽然我知道在completed方法中要是有长时间未响应的处理,很容易hang掉系统,尤其是fixthreadpool,但前提是线程池撑爆了!但我的线程池有4个,而且并未用满,为什么还会阻塞呢? 下面是我的代码: ``` public class AIOEchoServer { private AsynchronousServerSocketChannel server; public static void main(String[] args) throws Exception { System.out.println("the main thread is "+Thread.currentThread().getId()); AIOEchoServer aioServer = new AIOEchoServer(); aioServer.init("localhost", 6025); } private void init(String host, int port) throws IOException, Exception { AsynchronousChannelGroup group = AsynchronousChannelGroup.withThreadPool(Executors.newFixedThreadPool(4)); server = AsynchronousServerSocketChannel.open(group); server.setOption(StandardSocketOptions.SO_REUSEADDR, true); server.setOption(StandardSocketOptions.SO_RCVBUF, 16 * 1024); server.bind(new InetSocketAddress(host, port)); System.out.println("Listening on " + host + ":" + port); System.out.println("Channel Provider : " + server.provider()); server.accept(null, new CompletionHandler<AsynchronousSocketChannel, Object>() { final ByteBuffer buffer = ByteBuffer.allocate(1024); @Override public void completed(AsynchronousSocketChannel result, Object attachment) { System.out.println("waiting...."); buffer.clear(); System.out.println("current thread is "+Thread.currentThread().getId()); try { System.out.println("sleep the thread "+Thread.currentThread().getId()+",current time is "+new Date()); Thread.currentThread().sleep(20000l); System.out.println("thread "+Thread.currentThread().getId()+" has wake up!!!"); } catch (InterruptedException e) { e.printStackTrace(); } finally { try { result.close(); server.accept(null, this); } catch (IOException e) { e.printStackTrace(); } } } @Override public void failed(Throwable exc, Object attachment) { System.out.print("Server failed...." + exc.getCause()); } }); group.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS); } } ```
如何能在多个web服务器1个DB的情况下保证数据唯一?
公司里做的项目, 打算用多个web服务器, 共同连一个DB, 在某个基础表里的数据需要逻辑唯一, 既某对象(attr1="a", attr2="b")在数据库里只能存在一条记录, 由于这个基础表在用户使用中是用户自定义的, 因此有可能a,b2个用户通过web服务器a和web服务器b同时提交对象(attr1="a", attr2="b")...那么在这种情况下如何使DB里面最终只有一条记录? <br /> <br />公司的做法是: <br /><pre name="code" class="java"> public synchronized A save(A a){ //查找数据库看有没有a if(没有记录){ //锁表 //插入记录 }else{ //返回数据库记录 } } </pre> <br /> <br />但我觉得这样还是有问题啊, 因为在查数据库完了之后, 有可能另一台服务器正在保存了, 不过他们解释如果另一台服务器如果正在保存, 这边这台锁表不会成功的, 请问一下, 大家遇到这种情况是怎么处理的? <br /> <br />================================= <br />也许是我没说清楚, 后面有个同学说得对, 说白了就是多服务器下并发插入的问题, 如何能做到并发插入时保证数据唯一 <br />下面是大家的一些方案(排名不分先后<img src="/images/smiles/icon_biggrin.gif"/> ), 看看还有没有其他的方案: <br />1. 把save交给一台机器处理,然后暴露API给其他机器使用 <br />2. 乐观锁(这个我觉得似乎不能解决并发插入问题啊) <br />3. 联合主键 <br />4. 唯一索引 <br />5. 直接往数据库里面插数据,加个时间字段,精确到毫秒级就差不多了,取最新的那个时间字段的行 <br />6. 做一个数据库操作锁,方法调用前都要取锁,取到锁的才用执行,否则等待,这个锁可以放在缓存服务器中,集群中的所有节点连上这台缓存服务器 <br /> <br />=============================== <br /><span style="color: red">加说一下: 这个表是有pk的..比如表结构是:A(id pk auto_increment, attr1, attr2, attr3....) <br />id是数据库自己递增的, 业务要求是:attr1, attr2....任意2条数据不能重复, - -!这样是不是用唯一性索引就能解决了?</span><br/><strong>问题补充</strong><br/><div class="quote_title">rain2005 写道</div><div class="quote_div">可以在数据库里面建一个版本行。。。 <br />如果提交a或者b就更新版本行</div> <br />建版本好像不能解决问题啊,不管有没版本,都要先查询数据库有没有记录才能决定是插入还是不插入(或者更新),但是这个2个动作之间要是被人抢先插入,就会出问题 <br /><br/><strong>问题补充</strong><br/><div class="quote_title">rain2005 写道</div><div class="quote_div"><div class="quote_title">by5739 写道</div><div class="quote_div"><div class="quote_title">rain2005 写道</div><div class="quote_div">可以在数据库里面建一个版本行。。。 <br />如果提交a或者b就更新版本行</div> <br />建版本好像不能解决问题啊,不管有没版本,都要先查询数据库有没有记录才能决定是插入还是不插入(或者更新),但是这个2个动作之间要是被人抢先插入,就会出问题 <br /></div> <br /> <br />所以说才加个版本行啊,提交是看版本有没有变化撒,如果版本行版本发生变化就会滚事务,不是很easy的事么? <br /></div> <br /> <br />不太明白啊。。。比如顺序是这样的: <br />a服务器检查DB发现没有数据 <br />b服务器检查DB发现没有数据 <br />b服务器插入版本为1,id=1的数据 <br />a服务器插入版本为1,id=2的数据 <br /> <br />id是db自动生成,这样好像不能控制数据唯一吧? <br /><br/><strong>问题补充</strong><br/><div class="quote_title">dmewy 写道</div><div class="quote_div">PK是干嘛的?</div> <br />如果pk是DB自动生成的...估计也不行吧?<br/><strong>问题补充</strong><br/><div class="quote_title">pipilu 写道</div><div class="quote_div">你那是跨进程的东西,加上sychronized有用么?服务器A上的实例跟服务器B上的实例互斥?</div> <br />不是, 那个是防止2个用户在同一台web服务器新增同样的数据用的<br/><strong>问题补充</strong><br/><div class="quote_title">nwangwei 写道</div><div class="quote_div">1.针对这两个字段做唯一索引; <br />2.然后web服务器上直接插入,抓特定的Exception判断是不是违反了唯一性。</div> <br />这个...我看行... <br /><br/><strong>问题补充</strong><br/><div class="quote_title">lixjluck 写道</div><div class="quote_div"><div class="quote_title">treblesoftware 写道</div><div class="quote_div"><div class="quote_title">zelsa 写道</div><div class="quote_div">把save交给一台机器处理,然后暴露API给其他机器使用</div> <br /> <br />如果这样子,是不是有些浪费了,而且SAVA请求过多,是不是会网络堵塞,有更好的解决方案吗。</div> <br />交给一台机器也有并发的问题吧 <br /> <br />是否考虑使用MQ的queue,所有的web发送到mq上,有一个消费者消费这些数据 <br /> <br />这种方式有几个问题: <br />1、异步,不知业务允许 <br />2、消费稍微有些慢 <br /> <br /> <br />ps. 为什么是会员设置的数据,但是这个表有不和userId有关联。</div> <br /> <br />这个是基础业务数据, 是使用者自己录入然后在上面做业务的, 是大家共享的基础数据, 所以不和userid挂钩<br/><strong>问题补充</strong><br/>对的, 我现在只会1web服务器1db的情况, 我很想学构架方面, 但是没找到合适的书籍, 上面兄弟有没有好的架构方面的书籍推荐? 不胜感激.....
Java学习的正确打开方式
在博主认为,对于入门级学习java的最佳学习方法莫过于视频+博客+书籍+总结,前三者博主将淋漓尽致地挥毫于这篇博客文章中,至于总结在于个人,实际上越到后面你会发现学习的最好方式就是阅读参考官方文档其次就是国内的书籍,博客次之,这又是一个层次了,这里暂时不提后面再谈。博主将为各位入门java保驾护航,各位只管冲鸭!!!上天是公平的,只要不辜负时间,时间自然不会辜负你。 何谓学习?博主所理解的学习,它是一个过程,是一个不断累积、不断沉淀、不断总结、善于传达自己的个人见解以及乐于分享的过程。
程序员必须掌握的核心算法有哪些?
由于我之前一直强调数据结构以及算法学习的重要性,所以就有一些读者经常问我,数据结构与算法应该要学习到哪个程度呢?,说实话,这个问题我不知道要怎么回答你,主要取决于你想学习到哪些程度,不过针对这个问题,我稍微总结一下我学过的算法知识点,以及我觉得值得学习的算法。这些算法与数据结构的学习大多数是零散的,并没有一本把他们全部覆盖的书籍。下面是我觉得值得学习的一些算法以及数据结构,当然,我也会整理一些看过...
为啥国人偏爱Mybatis,而老外喜欢Hibernate/JPA呢?
关于SQL和ORM的争论,永远都不会终止,我也一直在思考这个问题。昨天又跟群里的小伙伴进行了一番讨论,感触还是有一些,于是就有了今天这篇文。 声明:本文不会下关于Mybatis和JPA两个持久层框架哪个更好这样的结论。只是摆事实,讲道理,所以,请各位看官勿喷。 一、事件起因 关于Mybatis和JPA孰优孰劣的问题,争论已经很多年了。一直也没有结论,毕竟每个人的喜好和习惯是大不相同的。我也看...
阿里P8数据架构师:顶级开发者都在用什么数据库?
其实从去年已经隐隐约约感觉到数据库的有变化,只是没有想到变得这么快。今年的一些事情实实在在地给了某些数据库重击,如果以前去某数据库还是喊喊,然后该用还用,今年从传统领域刮起的去某数据库的风,已经开始了,并且后面的乌云密布也看得见。 最近看一篇国外的开源产品提供厂商的一篇文字,主要是在询问了他的几百位客户后得出了下图中的2019年数据库的使用趋势。 从图中可以看出,MySQL以38.9...
面试官:关于Java性能优化,你有什么技巧
通过使用一些辅助性工具来找到程序中的瓶颈,然后就可以对瓶颈部分的代码进行优化。 一般有两种方案:即优化代码或更改设计方法。我们一般会选择后者,因为不去调用以下代码要比调用一些优化的代码更能提高程序的性能。而一个设计良好的程序能够精简代码,从而提高性能。 下面将提供一些在JAVA程序的设计和编码中,为了能够提高JAVA程序的性能,而经常采用的一些方法和技巧。 1.对象的生成和大小的调整。 J...
互联网公司分布式系统架构演进之路
介绍 分布式和集群的概念经常被搞混,现在一句话让你明白两者的区别。 分布式:一个业务拆分成多个子业务,部署在不同的服务器上 集群:同一个业务,部署在多个服务器上 例如:电商系统可以拆分成商品,订单,用户等子系统。这就是分布式,而为了应对并发,同时部署好几个用户系统,这就是集群 1 单应用架构 2 应用服务器和数据库服务器分离 单机负载越来越来,所以要将应用服务器和数据库服务器分离 3 应用服务...
【图解算法面试】记一次面试:说说游戏中的敏感词过滤是如何实现的?
版权声明:本文为苦逼的码农原创。未经同意禁止任何形式转载,特别是那些复制粘贴到别的平台的,否则,必定追究。欢迎大家多多转发,谢谢。 小秋今天去面试了,面试官问了一个与敏感词过滤算法相关的问题,然而小秋对敏感词过滤算法一点也没听说过。于是,有了下下事情的发生… 面试官开怼 面试官:玩过王者荣耀吧?了解过敏感词过滤吗?,例如在游戏里,如果我们发送“你在干嘛?麻痹演员啊你?”,由于“麻痹”是一个敏感词,...
程序员需要了解的硬核知识之汇编语言(一)
之前的系列文章从 CPU 和内存方面简单介绍了一下汇编语言,但是还没有系统的了解一下汇编语言,汇编语言作为第二代计算机语言,会用一些容易理解和记忆的字母,单词来代替一个特定的指令,作为高级编程语言的基础,有必要系统的了解一下汇编语言,那么本篇文章希望大家跟我一起来了解一下汇编语言。 汇编语言和本地代码 我们在之前的文章中探讨过,计算机 CPU 只能运行本地代码(机器语言)程序,用 C 语言等高级语...
OpenCV-Python 绘图功能 | 七
目标 学习使用OpenCV绘制不同的几何形状 您将学习以下功能:cv.line(),cv.circle(),cv.rectangle(),cv.ellipse(),cv.putText()等。 代码 在上述所有功能中,您将看到一些常见的参数,如下所示: img:您要绘制形状的图像 color:形状的颜色。对于BGR,将其作为元组传递,例如:(255,0,0)对于蓝色。对于灰度,只需传递...
GitHub 标星 1.6w+,我发现了一个宝藏项目,作为编程新手有福了!
大家好,我是 Rocky0429,一个最近老在 GitHub 上闲逛的蒟蒻… 特别惭愧的是,虽然我很早就知道 GitHub,但是学会逛 GitHub 的时间特别晚。当时一方面是因为菜,看着这种全是英文的东西难受,不知道该怎么去玩,另一方面是一直在搞 ACM,没有做一些工程类的项目,所以想当然的以为和 GitHub 也没什么关系(当然这种想法是错误的)。 后来自己花了一个星期看完了 Pyt...
Java知识体系最强总结(2020版)
更新于2019-12-15 10:38:00 本人从事Java开发已多年,平时有记录问题解决方案和总结知识点的习惯,整理了一些有关Java的知识体系,这不是最终版,会不定期的更新。也算是记录自己在从事编程工作的成长足迹,通过博客可以促进博主与阅读者的共同进步,结交更多志同道合的朋友。特此分享给大家,本人见识有限,写的博客难免有错误或者疏忽的地方,还望各位大佬指点,在此表示感激不尽。 文章目录...
计算机专业的书普遍都这么贵,你们都是怎么获取资源的?
介绍几个可以下载编程电子书籍的网站。 1.Github Github上编程书资源很多,你可以根据类型和语言去搜索。推荐几个热门的: free-programming-books-zh_CN:58K 星的GitHub,编程语言、WEB、函数、大数据、操作系统、在线课程、数据库相关书籍应有尽有,共有几百本。 Go语言高级编程:涵盖CGO,Go汇编语言,RPC实现,Protobuf插件实现,Web框架实...
卸载 x 雷某度!GitHub 标星 1.5w+,从此我只用这款全能高速下载工具!
作者 | Rocky0429 来源 | Python空间 大家好,我是 Rocky0429,一个喜欢在网上收集各种资源的蒟蒻… 网上资源眼花缭乱,下载的方式也同样千奇百怪,比如 BT 下载,磁力链接,网盘资源等等等等,下个资源可真不容易,不一样的方式要用不同的下载软件,因此某比较有名的 x 雷和某度网盘成了我经常使用的工具。 作为一个没有钱的穷鬼,某度网盘几十 kb 的下载速度让我...
毕业5年,我问遍了身边的大佬,总结了他们的学习方法
我问了身边10个大佬,总结了他们的学习方法,原来成功都是有迹可循的。
推荐10个堪称神器的学习网站
每天都会收到很多读者的私信,问我:“二哥,有什么推荐的学习网站吗?最近很浮躁,手头的一些网站都看烦了,想看看二哥这里有什么新鲜货。” 今天一早做了个恶梦,梦到被老板辞退了。虽然说在我们公司,只有我辞退老板的份,没有老板辞退我这一说,但是还是被吓得 4 点多都起来了。(主要是因为我掌握着公司所有的核心源码,哈哈哈) 既然 4 点多起来,就得好好利用起来。于是我就挑选了 10 个堪称神器的学习网站,推...
这些软件太强了,Windows必装!尤其程序员!
Windows可谓是大多数人的生产力工具,集娱乐办公于一体,虽然在程序员这个群体中都说苹果是信仰,但是大部分不都是从Windows过来的,而且现在依然有很多的程序员用Windows。 所以,今天我就把我私藏的Windows必装的软件分享给大家,如果有一个你没有用过甚至没有听过,那你就赚了????,这可都是提升你幸福感的高效率生产力工具哦! 走起!???? NO、1 ScreenToGif 屏幕,摄像头和白板...
大学四年因为知道了这32个网站,我成了别人眼中的大神!
依稀记得,毕业那天,我们导员发给我毕业证的时候对我说“你可是咱们系的风云人物啊”,哎呀,别提当时多开心啦????,嗯,我们导员是所有导员中最帅的一个,真的???? 不过,导员说的是实话,很多人都叫我大神的,为啥,因为我知道这32个网站啊,你说强不强????,这次是绝对的干货,看好啦,走起来! PS:每个网站都是学计算机混互联网必须知道的,真的牛杯,我就不过多介绍了,大家自行探索,觉得没用的,尽管留言吐槽吧???? 社...
看完这篇HTTP,跟面试官扯皮就没问题了
我是一名程序员,我的主要编程语言是 Java,我更是一名 Web 开发人员,所以我必须要了解 HTTP,所以本篇文章就来带你从 HTTP 入门到进阶,看完让你有一种恍然大悟、醍醐灌顶的感觉。 最初在有网络之前,我们的电脑都是单机的,单机系统是孤立的,我还记得 05 年前那会儿家里有个电脑,想打电脑游戏还得两个人在一个电脑上玩儿,及其不方便。我就想为什么家里人不让上网,我的同学 xxx 家里有网,每...
史上最全的IDEA快捷键总结
现在Idea成了主流开发工具,这篇博客对其使用的快捷键做了总结,希望对大家的开发工作有所帮助。
阿里程序员写了一个新手都写不出的低级bug,被骂惨了。
这种新手都不会范的错,居然被一个工作好几年的小伙子写出来,差点被当场开除了。
Fiddler+夜神模拟器进行APP抓包
Fiddler+夜神模拟器进行APP抓包 作者:霞落满天 需求:对公司APP进行抓包获取详细的接口信息,这是现在开发必备的。 工具:Fiddler抓包,夜神模拟器 模拟手机 安装APP 1.下载Fiddler https://www.telerik.com/download/fiddler Fiddler正是在这里帮助您记录计算机和Internet之间传递的所有HTTP和HTTPS通信...
小白学 Python 爬虫(42):春节去哪里玩(系列终篇)
人生苦短,我用 Python 前文传送门: 小白学 Python 爬虫(1):开篇 小白学 Python 爬虫(2):前置准备(一)基本类库的安装 小白学 Python 爬虫(3):前置准备(二)Linux基础入门 小白学 Python 爬虫(4):前置准备(三)Docker基础入门 小白学 Python 爬虫(5):前置准备(四)数据库基础 小白学 Python 爬虫(6):前置准备(...
一文带你看清 HTTP 所有概念
上一篇文章我们大致讲解了一下 HTTP 的基本特征和使用,大家反响很不错,那么本篇文章我们就来深究一下 HTTP 的特性。我们接着上篇文章没有说完的 HTTP 标头继续来介绍(此篇文章会介绍所有标头的概念,但没有深入底层) HTTP 标头 先来回顾一下 HTTP1.1 标头都有哪几种 HTTP 1.1 的标头主要分为四种,通用标头、实体标头、请求标头、响应标头,现在我们来对这几种标头进行介绍 通用...
作为一个程序员,CPU的这些硬核知识你必须会!
CPU对每个程序员来说,是个既熟悉又陌生的东西? 如果你只知道CPU是中央处理器的话,那可能对你并没有什么用,那么作为程序员的我们,必须要搞懂的就是CPU这家伙是如何运行的,尤其要搞懂它里面的寄存器是怎么一回事,因为这将让你从底层明白程序的运行机制。 随我一起,来好好认识下CPU这货吧 把CPU掰开来看 对于CPU来说,我们首先就要搞明白它是怎么回事,也就是它的内部构造,当然,CPU那么牛的一个东...
破14亿,Python分析我国存在哪些人口危机!
一、背景 二、爬取数据 三、数据分析 1、总人口 2、男女人口比例 3、人口城镇化 4、人口增长率 5、人口老化(抚养比) 6、各省人口 7、世界人口 四、遇到的问题 遇到的问题 1、数据分页,需要获取从1949-2018年数据,观察到有近20年参数:LAST20,由此推测获取近70年的参数可设置为:LAST70 2、2019年数据没有放上去,可以手动添加上去 3、将数据进行 行列转换 4、列名...
在家远程办公效率低?那你一定要收好这个「在家办公」神器!
相信大家都已经收到国务院延长春节假期的消息,接下来,在家远程办公可能将会持续一段时间。 但是问题来了。远程办公不是人在电脑前就当坐班了,相反,对于沟通效率,文件协作,以及信息安全都有着极高的要求。有着非常多的挑战,比如: 1在异地互相不见面的会议上,如何提高沟通效率? 2文件之间的来往反馈如何做到及时性?如何保证信息安全? 3如何规划安排每天工作,以及如何进行成果验收? ...... ...
这个世界上人真的分三六九等,你信吗?
偶然间,在知乎上看到一个问题 一时间,勾起了我深深的回忆。 以前在厂里打过两次工,做过家教,干过辅导班,做过中介。零下几度的晚上,贴过广告,满脸、满手地长冻疮。 再回首那段岁月,虽然苦,但让我学会了坚持和忍耐。让我明白了,在这个世界上,无论环境多么的恶劣,只要心存希望,星星之火,亦可燎原。 下文是原回答,希望能对你能有所启发。 如果我说,这个世界上人真的分三六九等,...
[数据结构与算法] 排序算法之归并排序与基数排序
归并排序 归并排序(MERGE-SORT)是利用归并的思想实现的排序方法,该算法采用经典的分治(divide-and-conquer)策略(分治法将问题分(divide)成一些小的问题然后递归求解,而治(conquer)的阶段则将分的阶段得到的各答案"修补"在一起,即分而治之)。 基本思想 可以看到这种结构很像一棵完全二叉树,本文的归并排序我们采用递归去实现(也可采用迭代的方式去实现)。分阶段可以...
B 站上有哪些很好的学习资源?
哇说起B站,在小九眼里就是宝藏般的存在,放年假宅在家时一天刷6、7个小时不在话下,更别提今年的跨年晚会,我简直是跪着看完的!! 最早大家聚在在B站是为了追番,再后来我在上面刷欧美新歌和漂亮小姐姐的舞蹈视频,最近两年我和周围的朋友们已经把B站当作学习教室了,而且学习成本还免费,真是个励志的好平台ヽ(.◕ฺˇд ˇ◕ฺ;)ノ 下面我们就来盘点一下B站上优质的学习资源: 综合类 Oeasy: 综合...
史上最牛逼的 Eclipse 快捷键,提高开发效率!
如果你在使用IDEA,请参考博主另外的一篇idea快捷键的博客。
相关热词 c# singleton c#中类的默认值是 c#各种进制之间的转换 c# 正则表达式保留汉字 c#后台跨域 c#基础代码大全 c#指定combox选择 c#关系 mono c# 相差毫秒 用c#做一个简易计算器
立即提问