1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
|
//
// ========================================================================
// Copyright (c) 1995-2016 Mort Bay Consulting Pty. Ltd.
// ------------------------------------------------------------------------
// All rights reserved. This program and the accompanying materials
// are made available under the terms of the Eclipse Public License v1.0
// and Apache License v2.0 which accompanies this distribution.
//
// The Eclipse Public License is available at
// http://www.eclipse.org/legal/epl-v10.html
//
// The Apache License v2.0 is available at
// http://www.opensource.org/licenses/apache2.0.php
//
// You may elect to redistribute this code under either of these licenses.
// ========================================================================
//
package org.eclipse.jetty.nosql.mongodb;
import java.net.UnknownHostException;
import java.util.Random;
import java.util.Set;
import javax.servlet.http.HttpServletRequest;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.session.AbstractSessionIdManager;
import org.eclipse.jetty.server.session.Session;
import org.eclipse.jetty.util.ConcurrentHashSet;
import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
import com.mongodb.BasicDBObject;
import com.mongodb.BasicDBObjectBuilder;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
/**
* Manager of session ids based on sessions stored in Mongo.
*
*/
public class MongoSessionIdManager extends AbstractSessionIdManager
{
private final static Logger LOG = Log.getLogger("org.eclipse.jetty.server.session");
final static DBObject __version_1 = new BasicDBObject(MongoSessionDataStore.__VERSION,1);
final static DBObject __valid_false = new BasicDBObject(MongoSessionDataStore.__VALID,false);
final static DBObject __valid_true = new BasicDBObject(MongoSessionDataStore.__VALID,true);
final static DBObject __expiry = new BasicDBObject(MongoSessionDataStore.__EXPIRY, 1);
final DBCollection _sessions;
/**
* the collection of session ids known to this manager
*/
protected final Set<String> _sessionsIds = new ConcurrentHashSet<>();
/* ------------------------------------------------------------ */
public MongoSessionIdManager(Server server) throws UnknownHostException, MongoException
{
this(server, new Mongo().getDB("HttpSessions").getCollection("sessions"));
}
/* ------------------------------------------------------------ */
public MongoSessionIdManager(Server server, DBCollection sessions)
{
super(server, new Random());
_sessions = sessions;
_sessions.ensureIndex(
BasicDBObjectBuilder.start().add("id",1).get(),
BasicDBObjectBuilder.start().add("unique",true).add("sparse",false).get());
_sessions.ensureIndex(
BasicDBObjectBuilder.start().add("id",1).add("version",1).get(),
BasicDBObjectBuilder.start().add("unique",true).add("sparse",false).get());
// index our accessed and valid fields so that purges are faster, note that the "valid" field is first
// so that we can take advantage of index prefixes
// http://docs.mongodb.org/manual/core/index-compound/#compound-index-prefix
_sessions.ensureIndex(
BasicDBObjectBuilder.start().add(MongoSessionDataStore.__VALID, 1).add(MongoSessionDataStore.__ACCESSED, 1).get(),
BasicDBObjectBuilder.start().add("sparse", false).add("background", true).get());
}
/* ------------------------------------------------------------ */
public DBCollection getSessions()
{
return _sessions;
}
/* ------------------------------------------------------------ */
@Override
protected void doStart() throws Exception
{
if (LOG.isDebugEnabled()) LOG.debug("MongoSessionIdManager:starting");
super.doStart();
}
/* ------------------------------------------------------------ */
@Override
protected void doStop() throws Exception
{
if (LOG.isDebugEnabled()) LOG.debug("MongoSessionIdManager:stopping");
super.doStop();
}
/* ------------------------------------------------------------ */
/**
* Searches database to find if the session id known to mongo, and is it valid
*/
@Override
public boolean isIdInUse(String sessionId)
{
/*
* optimize this query to only return the valid and expiry
*/
DBObject fields = new BasicDBObject();
fields.put(MongoSessionDataStore.__VALID, new Long(1));
fields.put(MongoSessionDataStore.__EXPIRY, new Long(1));
DBObject o = _sessions.findOne(new BasicDBObject(MongoSessionDataStore.__ID,sessionId), fields);
if ( o != null )
{
Boolean valid = (Boolean)o.get(MongoSessionDataStore.__VALID);
if ( valid == null )
return false;
Long expiry = (Long)o.get(MongoSessionDataStore.__EXPIRY);
if (expiry < System.currentTimeMillis())
return false;
return valid;
}
return false;
}
/* ------------------------------------------------------------ */
@Override
public void useId(Session session)
{
if (session == null)
return;
/*
* already a part of the index in mongo...
*/
LOG.debug("MongoSessionIdManager:addSession {}", session.getId());
}
/* ------------------------------------------------------------ */
@Override
public boolean removeId(String id)
{
//The corresponding session document will be marked as expired or invalid?
return true; //can't distinguish first remove vs subsequent removes
}
}
|
