inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-10-08 14:51:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merged HEAD-BUG-FIX (5.1/Cloud) to HEAD (5.1/Cloud)

Browse Source 
107012: Merged 5.0.N (5.0.3) to HEAD-BUG-FIX (5.1/Cloud)
      106968: Merged DEV to 5.0.N (5.0.3)
         106962: MNT-13706 : Admin console unusable after we set any  busy port in Port Number Value for subsystem
            - Implemented fix for Transformations (JodConverter), FTP, SMTP and IMAP.


git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@107051 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Alan Davis
2015-06-25 08:28:27 +00:00
parent 1eda74e709
commit 594145b66b
8 changed files with 2190 additions and 1880 deletions
Download Patch File Download Diff File Expand all files Collapse all files

718
source/java/org/alfresco/repo/imap/AlfrescoImapServer.java
View File

@@ -1,348 +1,370 @@
/*
* Copyright (C) 2005-2010 Alfresco Software Limited.
*
* This file is part of Alfresco
*
* Alfresco is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* Alfresco is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
*/
package org.alfresco.repo.imap;
import java.io.IOException;
import java.net.ServerSocket;
import java.util.Date;
import java.util.concurrent.atomic.AtomicReference;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.ApplicationEvent;
import org.springframework.extensions.surf.util.AbstractLifecycleBean;
import com.icegreen.greenmail.Managers;
import com.icegreen.greenmail.imap.ImapHostManager;
import com.icegreen.greenmail.imap.ImapServer;
import com.icegreen.greenmail.user.UserManager;
import com.icegreen.greenmail.util.DummySSLServerSocketFactory;
import com.icegreen.greenmail.util.ServerSetup;
import javax.net.ssl.SSLServerSocketFactory;
import javax.net.ssl.SSLServerSocket;
/**
* @author Mike Shavnev
*/
public class AlfrescoImapServer extends AbstractLifecycleBean
{
private class SecureImapServer extends ImapServer
{
public SecureImapServer(ServerSetup setup, Managers managers, AtomicReference<Exception> serverOpeningExceptionRef)
{
super(setup, managers,serverOpeningExceptionRef);
}
/**
* @override
* Use Java's default SSL Server SocketFactory
* controlled via System Properties
* -Djavax.net.ssl.keyStore=mySrvKeystore
* -Djavax.net.ssl.keyStorePassword=123456
*/
// MER - also consider using SSLContext
protected synchronized ServerSocket openServerSocket() throws IOException {
ServerSocket ret;
if (setup.isSecure())
{
try
{
ret = (SSLServerSocket) SSLServerSocketFactory.getDefault().createServerSocket(
setup.getPort(), 0, bindTo);
}
catch (IOException e)
{
if(logger.isErrorEnabled())
{
logger.error("Unable to open socket bindTo:" + bindTo + "port " + setup.getPort(), e);
}
throw e;
}
}
else
{
try
{
ret = new ServerSocket(setup.getPort(), 0, bindTo);
}
catch (IOException e)
{
if(logger.isErrorEnabled())
{
logger.error("Unable to open socket bindTo:" + bindTo + "port " + setup.getPort(), e);
}
throw e;
}
}
return ret;
}
}
private class DefaultImapServer extends ImapServer
{
public DefaultImapServer(ServerSetup setup, Managers managers, AtomicReference<Exception> serverOpeningExceptionRef)
{
super(setup, managers, serverOpeningExceptionRef);
}
// same behavior as in overridden method, just added exception logging
protected synchronized ServerSocket openServerSocket() throws IOException {
ServerSocket ret;
if (setup.isSecure())
{
try
{
ret = (SSLServerSocket) DummySSLServerSocketFactory.getDefault().createServerSocket(
setup.getPort(), 0, bindTo);
}
catch (IOException e)
{
if(logger.isErrorEnabled())
{
logger.error("Unable to open socket bindTo:" + bindTo + " port " + setup.getPort(), e);
}
throw e;
}
}
else
{
try
{
ret = new ServerSocket(setup.getPort(), 0, bindTo);
}
catch (IOException e)
{
if(logger.isErrorEnabled())
{
logger.error("Unable to open socket bindTo:" + bindTo + " port " + setup.getPort(), e);
}
throw e;
}
}
return ret;
}
}
private static Log logger = LogFactory.getLog(AlfrescoImapServer.class);
private ImapServer serverImpl;
private ImapServer secureServerImpl;
private int port = 143;
private int securePort = 993;
private boolean imapsEnabled = false;
private boolean imapEnabled = true;
private String host = "0.0.0.0";
private UserManager imapUserManager;
private ImapService imapService;
private boolean imapServerEnabled;
public void setImapServerEnabled(boolean imapServerEnabled)
{
this.imapServerEnabled = imapServerEnabled;
}
public boolean isImapServerEnabled()
{
return imapServerEnabled;
}
public void setPort(int port)
{
this.port = port;
}
public void setHost(String host)
{
this.host = host;
}
public int getPort()
{
return port;
}
public void setSecurePort(int securePort)
{
this.securePort = securePort;
}
public int getSecurePort()
{
return securePort;
}
public String getHost()
{
return host;
}
public void setImapService(ImapService imapService)
{
this.imapService = imapService;
}
public void setImapUserManager(UserManager imapUserManager)
{
this.imapUserManager = imapUserManager;
}
protected void onBootstrap(ApplicationEvent event)
{
if (imapServerEnabled)
{
startup();
}
else
{
if (logger.isDebugEnabled())
{
logger.debug("IMAP service is disabled.");
}
}
}
protected void onShutdown(ApplicationEvent event)
{
shutdown();
}
public void startup()
{
if(serverImpl == null)
{
final Managers imapManagers = new Managers()
{
// We create a new Host Manager instance per session to allow for session state tracking
public ImapHostManager getImapHostManager()
{
return new AlfrescoImapHostManager(AlfrescoImapServer.this.imapService);
}
public UserManager getUserManager()
{
return imapUserManager;
}
};
if(isImapEnabled())
{
AtomicReference<Exception> serverOpeningExceptionRef = new AtomicReference<Exception>();
serverImpl = new DefaultImapServer(new ServerSetup(port, host, ServerSetup.PROTOCOL_IMAP), imapManagers, serverOpeningExceptionRef);
serverImpl.startService(null);
checkForOpeningExceptions(serverOpeningExceptionRef);
if (logger.isInfoEnabled())
{
logger.info("IMAP service started on host:port " + host + ":" + this.port);
}
}
if(isImapsEnabled())
{
AtomicReference<Exception> serverOpeningExceptionRef = new AtomicReference<Exception>();
secureServerImpl = new SecureImapServer(new ServerSetup(securePort, host, ServerSetup.PROTOCOL_IMAPS), imapManagers, serverOpeningExceptionRef);
secureServerImpl.startService(null);
checkForOpeningExceptions(serverOpeningExceptionRef);
if (logger.isInfoEnabled())
{
logger.info("IMAPS service started on host:port " + host + ":" + this.securePort );
}
}
}
else
{
if (logger.isDebugEnabled())
{
logger.debug("IMAP server already running.");
}
}
}
public void checkForOpeningExceptions(AtomicReference<Exception> serverOpeningExceptionRef)
{
synchronized (serverOpeningExceptionRef)
{
try
{
//wait for openServerSocket() method to finish
serverOpeningExceptionRef.wait();
if (serverOpeningExceptionRef.get() != null)
{
throw new RuntimeException(serverOpeningExceptionRef.get());
}
} catch (InterruptedException e) {
if (logger.isDebugEnabled())
{
logger.debug(e.getMessage(), e);
}
}
}
}
public void shutdown()
{
if (serverImpl != null)
{
if (logger.isDebugEnabled())
{
logger.debug("IMAP service stopping.");
}
serverImpl.stopService(null);
}
if (secureServerImpl != null)
{
if (logger.isDebugEnabled())
{
logger.debug("IMAPS service stopping.");
}
secureServerImpl.stopService(null);
}
}
public void setImapsEnabled(boolean imapsEnabled)
{
this.imapsEnabled = imapsEnabled;
}
public boolean isImapsEnabled()
{
return imapsEnabled;
}
public void setImapEnabled(boolean imapEnabled)
{
this.imapEnabled = imapEnabled;
}
public boolean isImapEnabled()
{
return imapEnabled;
}
}
/*
* Copyright (C) 2005-2010 Alfresco Software Limited.
*
* This file is part of Alfresco
*
* Alfresco is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* Alfresco is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
*/
package org.alfresco.repo.imap;
import java.io.IOException;
import java.net.ServerSocket;
import java.util.Date;
import java.util.concurrent.atomic.AtomicReference;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.ApplicationEvent;
import org.springframework.extensions.surf.util.AbstractLifecycleBean;
import com.icegreen.greenmail.Managers;
import com.icegreen.greenmail.imap.ImapHostManager;
import com.icegreen.greenmail.imap.ImapServer;
import com.icegreen.greenmail.user.UserManager;
import com.icegreen.greenmail.util.DummySSLServerSocketFactory;
import com.icegreen.greenmail.util.ServerSetup;
import javax.net.ssl.SSLServerSocketFactory;
import javax.net.ssl.SSLServerSocket;
import org.alfresco.error.AlfrescoRuntimeException;
import org.alfresco.repo.management.subsystems.LoggableErrorEvent;
import org.alfresco.util.PortUtil;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
/**
* @author Mike Shavnev
*/
public class AlfrescoImapServer extends AbstractLifecycleBean implements ApplicationEventPublisherAware
{
private static final String IMAP_PORT_OCCUPIED_MESSAGE = "system.imap.err.port_in_use";
private ApplicationEventPublisher applicationEventPublisher;
@Override
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
{
this.applicationEventPublisher = applicationEventPublisher;
}
private class SecureImapServer extends ImapServer
{
public SecureImapServer(ServerSetup setup, Managers managers, AtomicReference<Exception> serverOpeningExceptionRef)
{
super(setup, managers,serverOpeningExceptionRef);
}
/**
* @override
* Use Java's default SSL Server SocketFactory
* controlled via System Properties
* -Djavax.net.ssl.keyStore=mySrvKeystore
* -Djavax.net.ssl.keyStorePassword=123456
*/
// MER - also consider using SSLContext
protected synchronized ServerSocket openServerSocket() throws IOException {
ServerSocket ret;
if (setup.isSecure())
{
try
{
ret = (SSLServerSocket) SSLServerSocketFactory.getDefault().createServerSocket(
setup.getPort(), 0, bindTo);
}
catch (IOException e)
{
if(logger.isErrorEnabled())
{
logger.error("Unable to open socket bindTo:" + bindTo + "port " + setup.getPort(), e);
}
throw e;
}
}
else
{
try
{
ret = new ServerSocket(setup.getPort(), 0, bindTo);
}
catch (IOException e)
{
if(logger.isErrorEnabled())
{
logger.error("Unable to open socket bindTo:" + bindTo + "port " + setup.getPort(), e);
}
throw e;
}
}
return ret;
}
}
private class DefaultImapServer extends ImapServer
{
public DefaultImapServer(ServerSetup setup, Managers managers, AtomicReference<Exception> serverOpeningExceptionRef)
{
super(setup, managers, serverOpeningExceptionRef);
}
// same behavior as in overridden method, just added exception logging
protected synchronized ServerSocket openServerSocket() throws IOException {
ServerSocket ret;
if (setup.isSecure())
{
try
{
ret = (SSLServerSocket) DummySSLServerSocketFactory.getDefault().createServerSocket(
setup.getPort(), 0, bindTo);
}
catch (IOException e)
{
if(logger.isErrorEnabled())
{
logger.error("Unable to open socket bindTo:" + bindTo + " port " + setup.getPort(), e);
}
throw e;
}
}
else
{
try
{
ret = new ServerSocket(setup.getPort(), 0, bindTo);
}
catch (IOException e)
{
if(logger.isErrorEnabled())
{
logger.error("Unable to open socket bindTo:" + bindTo + " port " + setup.getPort(), e);
}
throw e;
}
}
return ret;
}
}
private static Log logger = LogFactory.getLog(AlfrescoImapServer.class);
private ImapServer serverImpl;
private ImapServer secureServerImpl;
private int port = 143;
private int securePort = 993;
private boolean imapsEnabled = false;
private boolean imapEnabled = true;
private String host = "0.0.0.0";
private UserManager imapUserManager;
private ImapService imapService;
private boolean imapServerEnabled;
public void setImapServerEnabled(boolean imapServerEnabled)
{
this.imapServerEnabled = imapServerEnabled;
}
public boolean isImapServerEnabled()
{
return imapServerEnabled;
}
public void setPort(int port)
{
this.port = port;
}
public void setHost(String host)
{
this.host = host;
}
public int getPort()
{
return port;
}
public void setSecurePort(int securePort)
{
this.securePort = securePort;
}
public int getSecurePort()
{
return securePort;
}
public String getHost()
{
return host;
}
public void setImapService(ImapService imapService)
{
this.imapService = imapService;
}
public void setImapUserManager(UserManager imapUserManager)
{
this.imapUserManager = imapUserManager;
}
protected void onBootstrap(ApplicationEvent event)
{
if (imapServerEnabled)
{
startup();
}
else
{
if (logger.isDebugEnabled())
{
logger.debug("IMAP service is disabled.");
}
}
}
protected void onShutdown(ApplicationEvent event)
{
shutdown();
}
public void startup()
{
if(serverImpl == null)
{
final Managers imapManagers = new Managers()
{
// We create a new Host Manager instance per session to allow for session state tracking
public ImapHostManager getImapHostManager()
{
return new AlfrescoImapHostManager(AlfrescoImapServer.this.imapService);
}
public UserManager getUserManager()
{
return imapUserManager;
}
};
if(isImapEnabled())
{
// Check if port is occupied.
if (!PortUtil.isPortFree(port))
{
applicationEventPublisher.publishEvent(new LoggableErrorEvent(this,
new AlfrescoRuntimeException(IMAP_PORT_OCCUPIED_MESSAGE, new String[] { "" + port })));
}
AtomicReference<Exception> serverOpeningExceptionRef = new AtomicReference<Exception>();
serverImpl = new DefaultImapServer(new ServerSetup(port, host, ServerSetup.PROTOCOL_IMAP), imapManagers, serverOpeningExceptionRef);
serverImpl.startService(null);
checkForOpeningExceptions(serverOpeningExceptionRef);
if (logger.isInfoEnabled())
{
logger.info("IMAP service started on host:port " + host + ":" + this.port);
}
}
if(isImapsEnabled())
{
AtomicReference<Exception> serverOpeningExceptionRef = new AtomicReference<Exception>();
secureServerImpl = new SecureImapServer(new ServerSetup(securePort, host, ServerSetup.PROTOCOL_IMAPS), imapManagers, serverOpeningExceptionRef);
secureServerImpl.startService(null);
checkForOpeningExceptions(serverOpeningExceptionRef);
if (logger.isInfoEnabled())
{
logger.info("IMAPS service started on host:port " + host + ":" + this.securePort );
}
}
}
else
{
if (logger.isDebugEnabled())
{
logger.debug("IMAP server already running.");
}
}
}
public void checkForOpeningExceptions(AtomicReference<Exception> serverOpeningExceptionRef)
{
synchronized (serverOpeningExceptionRef)
{
try
{
//wait for openServerSocket() method to finish
serverOpeningExceptionRef.wait();
if (serverOpeningExceptionRef.get() != null)
{
throw new RuntimeException(serverOpeningExceptionRef.get());
}
} catch (InterruptedException e) {
if (logger.isDebugEnabled())
{
logger.debug(e.getMessage(), e);
}
}
}
}
public void shutdown()
{
if (serverImpl != null)
{
if (logger.isDebugEnabled())
{
logger.debug("IMAP service stopping.");
}
serverImpl.stopService(null);
}
if (secureServerImpl != null)
{
if (logger.isDebugEnabled())
{
logger.debug("IMAPS service stopping.");
}
secureServerImpl.stopService(null);
}
}
public void setImapsEnabled(boolean imapsEnabled)
{
this.imapsEnabled = imapsEnabled;
}
public boolean isImapsEnabled()
{
return imapsEnabled;
}
public void setImapEnabled(boolean imapEnabled)
{
this.imapEnabled = imapEnabled;
}
public boolean isImapEnabled()
{
return imapEnabled;
}
}