作业服务在使用凌空抽射将数据发布到服务器时无法正常工作

Question

我正在尝试将SQLite数据与mysql同步，为此创建了每15秒同步一次数据的JobService（仅同步那些状态与mysql不同步的数据）。这与本地主机（xampp服务器）完美配合。但是Web服务器出现问题：它每15秒的JobService就会产生重复的条目。

我的服务.java

    public class MyService extends JobService {
    private DatabaseHelper db;
    SQLiteDatabase sqLiteDatabase;
    private Handler mJobHandler = new Handler( new Handler.Callback() {
        @Override
        public boolean handleMessage( Message msg ) {
            Toast.makeText( getApplicationContext(), "JobService task running", Toast.LENGTH_SHORT ).show();
            jobFinished( (JobParameters) msg.obj, false );
            return true;
        }
    } );
    @Override
    public boolean onStartJob(JobParameters params ) {
        mJobHandler.sendMessage( Message.obtain( mJobHandler, 1, params ) );
        db = DatabaseHelper.getInstance(getApplicationContext());
        postData();
        //db.close();
        return true;
    }
    @Override
    public boolean onStopJob( JobParameters params ) {
        mJobHandler.removeMessages( 1 );
        return false;
    }
    private void postData() {
        Cursor cursor = db.getUnsyncedNames();
        try {
            if (cursor != null) {
                if (cursor.moveToFirst()) {
                    do {
                        saveName(cursor.getInt(cursor.getColumnIndex(DatabaseHelper.COLUMN_ID)), cursor.getString(cursor.getColumnIndex(DatabaseHelper.COLUMN_FROM_NO)), cursor.getString(cursor.getColumnIndex(DatabaseHelper.COLUMN_TO_NO)));
                    } while (cursor.moveToNext());
                }
            }
        }  finally {
            if (cursor != null && !cursor.isClosed())
                cursor.close();
            db.close();
        }
    }
    private void saveName(final int id, final String fromNo, final String toNo) {
        StringRequest stringRequest = new StringRequest(Request.Method.POST, Config.URL_REQUEST_SMS,
                new Response.Listener<String>() {
                    @Override
                    public void onResponse(String response) {
                        try {
                            JSONObject obj = new JSONObject(response);
                            if (!obj.getBoolean("error")) {
                                //updating the status in sqlite
                                db.updateNameStatus(id,NAME_SYNCED_WITH_SERVER);
                                sqLiteDatabase = db.getWritableDatabase();
                                if (sqLiteDatabase != null) {
                                    sqLiteDatabase.delete(DatabaseHelper.TABLE_NAME, null, null);
                                }
                               // db.close();
                                Toast.makeText(getApplicationContext(),"Unsynced no. submitted!",Toast.LENGTH_LONG).show();
                                //calls.clear();
                            }
                        } catch (JSONException e) {
                            e.printStackTrace();
                            Toast.makeText(getApplicationContext(),"JSONException error1 : "+e,Toast.LENGTH_LONG).show();
                        }
                        finally {
                            db.close();
                        }
                    }
                },
                new Response.ErrorListener() {
                    @Override
                    public void onErrorResponse(VolleyError error) {
                        Toast.makeText(getApplicationContext(),"VolleyError error2 : "+error,Toast.LENGTH_LONG).show();
                        error.printStackTrace();
                    }
                }) {
            @Override
            protected Map<String, String> getParams() throws AuthFailureError {
                Map<String, String> params = new HashMap<>();
                params.put("mobile", fromNo);
                params.put("toMob", toNo);
                return params;
            }
        };
                int socketTimeout = 60000;
                RetryPolicy policy = new DefaultRetryPolicy(socketTimeout,
                        DefaultRetryPolicy.DEFAULT_MAX_RETRIES,
                        DefaultRetryPolicy.DEFAULT_BACKOFF_MULT);
                stringRequest.setRetryPolicy(policy);
        MyApplication.getInstance().addToRequestQueue(stringRequest);
    }
}

主要活动.java

  JobInfo.Builder builder = new JobInfo.Builder( 1,
            new ComponentName( getPackageName(), MyService.class.getName() ) );
    builder.setPeriodic(15000);

还有我的日志猫节目

E/表面：获取插槽从缓冲区锁定：未知缓冲区：0x7f517cd1b540

Answer 1

是的，我遇到了同样的问题，事实证明凌空抽射一旦分配内存，就不会取消分配内存。它使内存膨胀并强制操作系统GC，这将停止所有此类服务，移至具有作业服务的Retrofit 2工作完美

最好的解决方案是转向改造 2. 正如我们已经进行了压力测试的那样

Answer 2

您的处理程序正在绕过整个 JobService 流程。它甚至在实际完成之前就将作业标记为已成功完成。

我看到提供的代码存在多个问题：

• 所有数据库逻辑都发生在主线程上，而不是后台线程上。
• 您正在为每个作业创建一个新的数据库连接。
• 您正在泄漏数据库连接（因为您没有在 try 块内连接或运行查询）。

我真的不认为你的问题出在凌空抽射上。