2017-01-16 28 views
5

我剛剛設法調用Google Drive API來啓用文件的推送通知。Google Drive API發送推送通知時的HTTP 302

代碼中設置了推送通知是這樣的:

public class SampleServlet extends AbstractAppEngineAuthorizationCodeServlet { 
    private final static Logger logger = Logger.getLogger(SampleServlet.class.getName()); 
    private static final long serialVersionUID = 1L; 
    // Constants omitted 

    @Override 
    public void doGet(HttpServletRequest req, HttpServletResponse resp) 
      throws IOException, ServletException { 

     AuthorizationCodeFlow authFlow = initializeFlow(); 
     Credential credential = authFlow.loadCredential(getUserId(req)); 

     StringBuilder resultFromWatch = new StringBuilder(); 
     Drive drive = new Drive.Builder(Utils.HTTP_TRANSPORT, Utils.JSON_FACTORY, credential).setApplicationName("t").build(); 

     try { 
      Optional<Channel> channel = watchFile(drive, FILE_ID, CHANNEL_ID, "web_hook", "https://mydomain.appspot.com/drive"); 
      String channelStringTmp; 
      if (channel.isPresent()) { 
       channelStringTmp = channel.get().toString(); 
      } else { 
       channelStringTmp = "null..."; 
      } 
      resultFromWatch.append(channelStringTmp); 
     } catch (Exception e) { 
      resultFromWatch.append(e.getMessage()); 
     } 

     final UserService userService = UserServiceFactory.getUserService(); 
     final String thisUrl = req.getRequestURI(); 
     // Send the results as the response 
     PrintWriter respWriter = resp.getWriter(); 
     resp.setStatus(200); 
     resp.setContentType("text/html"); 

     addLoginLogoutButtons(req, resp, resultFromWatch, userService, thisUrl, respWriter); 
    } 

    private static Optional<Channel> watchFile(Drive service, String fileId, 
               String channelId, String channelType, String channelAddress) throws IOException { 
     final Channel returnValue; 
     Channel channel = new Channel(); 
     channel.setId(channelId); 
     channel.setType(channelType); 
     channel.setAddress(channelAddress); 
     Drive.Files tmp = service.files(); 
     returnValue = tmp.watch(fileId, channel).execute(); 
     return Optional.fromNullable(returnValue); 
    } 

    @Override 
    protected AuthorizationCodeFlow initializeFlow() throws ServletException, IOException { 
     return Utils.initializeFlow(); 
    } 

    @Override 
    protected String getRedirectUri(HttpServletRequest req) throws ServletException, IOException { 
     return Utils.getRedirectUri(req); 
    } 
} 

在我得到這個作爲具有響應呼籲從我的瀏覽器和伐木的servlet的doGet後:

{ 
    "expiration": "1484565747000", 
    "id": SAME_ID_AS_DEFINED_IN_SERVLET, 
    "kind": "api#channel", 
    "resourceId": A_NEW_ID, 
    "resourceUri": "https:\/\/www.googleapis.com\/drive\/v3\/files\/FILE_ID?acknowledgeAbuse=false&alt=json" 
} 

下一步是定義我的控制器,當文件被修改時接收通知。看起來是這樣的:

@RestController 
@RequestMapping("/drive") 
public class ConcreteFileWatchController implements FileWatchController { 
    private final static Logger logger = Logger.getLogger(ConcreteFileWatchController.class.getName()); 

    @RequestMapping(method = RequestMethod.POST) 
    @ResponseStatus(value = HttpStatus.OK) 
    @Override 
    public void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException { 
     logger.info("Received watch call"); 
    } 
} 

最後我嘗試修改文件已經部署的應用程序後(它部署在谷歌應用程序引擎),並期待在GAE日誌後,我可以看到出現了一個電話。但是,我的接收方法沒有執行。我只在日誌中看到一個302,附帶一個大json。除非我沒有注意到我的方法被調用,否則無法真正看到任何錯誤。該路徑在日誌中甚至看起來正確。我可能做錯了什麼?

關於錯誤的細節:

當我去到谷歌雲我看到這個302消息日誌頁面:

11:34:35.957 
POST 
302 
0 B 
22 ms 
APIs-Google; (+https://developers.google.com/webmasters/APIs-Google.html) 
/drive 
10.72.94.97 - - [16/Jan/2017:11:34:35 +0100] "POST /drive HTTP/1.1" 302 - - "APIs-Google; (+https://developers.google.com/webmasters/APIs-Google.html)" "mydomain.appspot.com" ms=22 cpu_ms=0 cpm_usd=0 loading_request=0 instance=- app_engine_release=1.9.48 trace_id=d0e888dd3989e353344e40e41758fdf4 

還有尋找一種像這樣的JSON:

{ 
    protoPayload: { 
    @ 
    type: "type.googleapis.com/google.appengine.logging.v1.RequestLog" 
    appId: "p~blabla" 
    versionId: "201t113050" 
    requestId: "587ca1bb00ff05706f727465726261636b656e640001323031373031313674313133303530000100" 
    ip: "10.76.94.97" 
    startTime: "2017-01-16T10:34:35.957904Z" 
    endTime: "2017-01-16T10:34:35.980366Z" 
    latency: "0.022462s" 
    method: "POST" 
    resource: "/drive" 
    httpVersion: "HTTP/1.1" 
    status: 302 
    userAgent: "APIs-Google; (+https://developers.google.com/webmasters/APIs-Google.html)" 
    host: "blabla.appspot.com" 
    instanceIndex: -1 
    finished: true 
    appEngineRelease: "1.9.48" 
    traceId: "d0e888dd390f41758fdf4" 
    first: true 
} 
insertId: "587cf6df9ded23f7" 
httpRequest: { 
status: 302 
} 
resource: { 
type: "gae_app" 
labels: {…} 
} 
timestamp: "2017-01-16T10:34:35.957904Z" 
labels: { 
appengine.googleapis.com/version_id: "2017013050" 
clone_id: "" 
appengine.googleapis.com/clone_id: "" 
appengine.googleapis.com/module_id: "default" 
version_id: "20170116t113050" 
request_id: "587ca1bb00ff0e9dd0f39f31350001707e6561737974696d657265706f721373031313674313133303530000100" 
appengine.googleapis.com/request_id: "587ca1bb00ff0e9dd0f39f31350001707e6561737974696d6572653674313133303530000100" 
module_id: "default" 
} 
logName: "projects/blabla/logs/appengine.googleapis.com%2Frequest_log" 
operation: { 
id: "587ca1bb00ff0e9dde640001323031373031313674313133303530000100" 
producer: "appengine.googleapis.com/request_id" 
first: true 
last: true 
} 
} 

web.xml:

<web-app> 
    <context-param> 
     <param-name>contextConfigLocation</param-name> 
     <param-value>/WEB-INF/mvc-dispatcher-servlet.xml</param-value> 
    </context-param> 
    <filter> 
     <filter-name>CORS</filter-name> 
     <filter-class>com.thetransactioncompany.cors.CORSFilter</filter-class> 
    </filter> 
    <filter-mapping> 
     <filter-name>CORS</filter-name> 
     <url-pattern>/*</url-pattern> 
    </filter-mapping> 
    <listener> 
     <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> 
    </listener> 
    <servlet> 
     <servlet-name>dispatcher</servlet-name> 
     <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> 
     <init-param> 
      <param-name>contextConfigLocation</param-name> 
      <param-value></param-value> 
     </init-param> 
     <load-on-startup>1</load-on-startup> 
    </servlet> 

    <servlet> 
     <servlet-name>PlusBasicServlet</servlet-name> 
     <servlet-class>packagename.PlusBasicServlet</servlet-class> 
    </servlet> 
    <servlet-mapping> 
     <servlet-name>PlusBasicServlet</servlet-name> 
     <url-pattern>/plusbasicservlet</url-pattern> 
    </servlet-mapping> 

    <servlet> 
     <servlet-name>PlusSampleServlet</servlet-name> 
     <servlet-class>packagename.PlusSampleServlet</servlet-class> 
    </servlet> 
    <servlet-mapping> 
     <servlet-name>PlusSampleServlet</servlet-name> 
     <url-pattern>/plussampleservlet</url-pattern> 
    </servlet-mapping> 
    <servlet> 
     <servlet-name>FileWatchTestServlet</servlet-name> 
     <servlet-class>packagename.ConcreteFileWatchController</servlet-class> 
    </servlet> 
    <servlet-mapping> 
     <servlet-name>FileWatchTestServlet</servlet-name> 
     <url-pattern>/drive</url-pattern> 
    </servlet-mapping> 
    <servlet> 
     <servlet-name>PlusSampleAuthCallbackServlet</servlet-name> 
     <servlet-class>packagename.PlusSampleAuthCallbackServlet</servlet-class> 
    </servlet> 
    <servlet-mapping> 
     <servlet-name>PlusSampleAuthCallbackServlet</servlet-name> 
     <url-pattern>/oauth2callback</url-pattern> 
    </servlet-mapping> 
    <security-constraint> 
     <web-resource-collection> 
      <web-resource-name>any</web-resource-name> 
      <url-pattern>/plussampleservlet</url-pattern> 
     </web-resource-collection> 
     <auth-constraint> 
      <role-name>*</role-name> 
     </auth-constraint> 
    </security-constraint> 
</web-app> 
從日誌

截圖:

enter image description here

+0

你能分享302錯誤的描述嗎? –

+0

我添加了所有可以在雲日誌中找到的數據。 –

+0

如果我沒有弄錯,HTTP 302是URL重定向的代碼。可能你需要點擊你被重定向到的url .. –

回答

2

由於你的回調正在通過Spring MVC的服務,確保你沒有在其他地方設置任何隱藏重定向。

public class FileWatchTestServlet extends HttpServlet { 
    private final static Logger logger = Logger.getLogger(FileWatchTestServlet.class.getSimpleName()); 

    @Override 
    public void doPost(HttpServletRequest req, HttpServletResponse resp) throws IOException { 
     logger.info("Received watch call"); 
    } 
} 

而且在web.xml:

<servlet> 
    <servlet-name>FileWatchTestServlet</servlet-name> 
    <servlet-class>com.mydomain.FileWatchTestServlet</servlet-class> 
</servlet> 
<servlet-mapping> 
    <servlet-name>FileWatchTestServlet</servlet-name> 
    <url-pattern>/drive</url-pattern> 
</servlet-mapping> 

如果302消失,問題是Spring MVC的調度,所以你應該看看那裏,你應該使用常規的servlet首先測試回調任何可能導致重定向的東西(例如在你的視圖中)。

+0

感謝您的建議。仍然獲得302.從日誌發佈屏幕截圖。我認爲重定向是我的安全配置將我重定向到Google用戶身份驗證。不知道如何解決這個問題。 –

+0

您的安全約束條件僅適用於'/ rest/plussampleservlet'。實際上,從[plus-appengine-sample]複製它看起來有些額外的東西(https://github.com/google/google-api-java-client-samples/tree/master/plus -appengine-sample),所以你應該刪除它。如果您已經擁有,那麼請發佈您的更新的web.xml,該web.xml只包含與您的應用相關的配置。 – Adam

+0

另外,驗證您的假設的另一種方法是簡單地測試整個部分註釋掉。 – Adam