Merge pull request #3 from KeJunMao/patch-1

.gitignore

@@ -29,3 +29,8 @@ htmlcov
 
 .DS_Store
 .idea
+
+# Ignore user config
+user-config.json
+userapiconfig.py
+usermysql.json

.travis.yml

@@ -13,7 +13,7 @@ before_install:
  - sudo dd if=/dev/urandom of=/usr/share/nginx/www/file bs=1M count=10
  - sudo sh -c "echo '127.0.0.1 localhost' > /etc/hosts"
  - sudo service nginx restart
- - pip install pep8 pyflakes nose coverage
+ - pip install pep8 pyflakes nose coverage PySocks cymysql
  - sudo tests/socksify/install.sh
  - sudo tests/libsodium/install.sh
  - sudo tests/setup_tc.sh

CHANGES

@@ -1,3 +1,104 @@
+3.4.0 2017-07-27
+- add auth_chain_b
+- add initmudbjson.sh
+- allow set speed limit in runtime
+- fix bugs & mem leak
+
+3.3.3 2017-06-03
+- add DNS cache
+- add tls1.2_ticket_fastauth
+- fix bugs
+
+3.3.2 2017-05-20
+- revert http reply
+- refine tls1.2_ticket_auth error detector
+
+3.3.1 2017-05-18
+- fix stop script
+- Async DNS query under UDP
+- fix old version of OpenSSL
+- http reply
+
+3.3.0 2017-05-11
+- connect_log include local addr & port
+- fix auth_chain_a UDP bug
+- add "additional_ports_only"
+- add interface legendsockssr
+- run with newest python version
+- parse comment in hosts
+- update mujson_mgr
+- add cymysql setup script
+- new speed tester
+- fix leaks
+- bugs fixed
+
+3.2.0 2017-04-27
+- add auth_chain_a
+- remove auth_aes128, auth_sha1, auth_sha1_v2, verify_simple, auth_simple, verify_sha1
+
+3.1.2 2017-04-07
+- display UID
+- auto adjust TCP MSS
+
+3.1.1 2017-03-25
+- add "New session ticket"
+- ignore bind 10.0.0.0/8 and 192.168.0.0/16 by default
+- improve rand size under auth_aes128_*
+- fix bugs
+
+3.1.0 2017-03-16
+- add "glzjinmod" interface
+- rate limit
+- add additional_ports in config
+
+3.0.4 2017-01-08
+- multi-user in single port
+
+3.0.1 2017-01-03
+- remove auth_aes128_*_compatible
+
+3.0.0 2016-12-23
+- http_simple fix bugs
+- tls1.2_ticket_auth fix bug & defaule time diff set to 86400s
+
+2.9.7 2016-11-22
+- manage client with LRUCache
+- catch bind error
+- fix import error of resource on windows
+- print RLIMIT_NOFILE
+- always close cymysql objects
+- add init script
+
+2.9.6 2016-10-17
+- tls1.2_ticket_auth random packet size
+
+2.9.5.1 2016-10-16
+- UDP bind address
+
+2.9.5 2016-10-13
+- add auth_aes128_md5 and auth_aes128_sha1
+
+2.9.4 2016-10-11
+- sync client version
+
+2.6.13 2015-11-02
+- add protocol setting
+
+2.6.12 2015-10-27
+- IPv6 first
+- Fix mem leaks
+- auth_simple plugin
+- remove FORCE_NEW_PROTOCOL
+- optimize code
+
+2.6.11 2015-10-20
+- Obfs plugin
+- Obfs parameters
+- UDP over TCP
+- TCP over UDP (experimental)
+- Fix socket leaks
+- Catch abnormal UDP package
+
 2.6.10 2015-06-08
 - Optimize LRU cache
 - Refine logging

Dockerfile

@@ -0,0 +1,31 @@
+FROM alpine:3.6
+
+ENV SERVER_ADDR 0.0.0.0
+ENV SERVER_PORT 51348
+ENV PASSWORD psw
+ENV METHOD aes-128-ctr
+ENV PROTOCOL auth_aes128_md5
+ENV PROTOCOLPARAM 32
+ENV OBFS tls1.2_ticket_auth_compatible
+ENV TIMEOUT 300
+ENV DNS_ADDR 8.8.8.8
+ENV DNS_ADDR_2 8.8.4.4
+
+ARG BRANCH=manyuser
+ARG WORK=~
+
+
+RUN apk --no-cache add python \
+ libsodium \
+ wget
+
+
+RUN mkdir -p $WORK && \
+ wget -qO- --no-check-certificate https://github.com/shadowsocksr-backup/shadowsocksr/archive/$BRANCH.tar.gz | tar -xzf - -C $WORK
+
+
+WORKDIR $WORK/shadowsocksr-$BRANCH/shadowsocks
+
+
+EXPOSE $SERVER_PORT
+CMD python server.py -p $SERVER_PORT -k $PASSWORD -m $METHOD -O $PROTOCOL -o $OBFS -G $PROTOCOLPARAM

README.md

@@ -1,9 +1,7 @@
-shadowsocks
+ShadowsocksR
 ===========
 
-[![PyPI version]][PyPI]
 [![Build Status]][Travis CI]
-[![Coverage Status]][Coverage]
 
 A fast tunnel proxy that helps you bypass firewalls.
 
@@ -14,41 +12,52 @@ Server
 
 Debian / Ubuntu:
 
- apt-get install python-pip
- pip install shadowsocks
+ apt-get install git
+ git clone https://github.com/shadowsocksr/shadowsocksr.git
 
 CentOS:
 
- yum install python-setuptools && easy_install pip
- pip install shadowsocks
+ yum install git
+ git clone https://github.com/shadowsocksr/shadowsocksr.git
 
 Windows:
 
-See [Install Server on Windows]
+ git clone https://github.com/shadowsocksr/shadowsocksr.git
 
-### Usage
+### Usage for single user on linux platform
 
- ssserver -p 443 -k password -m aes-256-cfb
+If you clone it into "~/shadowsocksr" 
+move to "~/shadowsocksr", then run:
+
+ bash initcfg.sh
+
+move to "~/shadowsocksr/shadowsocks", then run:
+
+ python server.py -p 443 -k password -m aes-128-cfb -O auth_aes128_md5 -o tls1.2_ticket_auth_compatible
+
+Check all the options via `-h`.
+
+You can also use a configuration file instead (recommend), move to "~/shadowsocksr" and edit the file "user-config.json", then move to "~/shadowsocksr/shadowsocks" again, just run:
+
+ python server.py
 
 To run in the background:
 
- sudo ssserver -p 443 -k password -m aes-256-cfb --user nobody -d start
+ ./logrun.sh
 
 To stop:
 
- sudo ssserver -d stop
+ ./stop.sh
 
-To check the log:
+To monitor the log:
 
- sudo less /var/log/shadowsocks.log
+ ./tail.sh
 
-Check all the options via `-h`. You can also use a [Configuration] file
-instead.
 
 Client
 ------
 
-* [Windows] / [OS X]
+* [Windows] / [macOS]
 * [Android] / [iOS]
 * [OpenWRT]
 
@@ -80,27 +89,17 @@ under the License.
 Bugs and Issues
 ----------------
 
-* [Troubleshooting]
 * [Issue Tracker]
-* [Mailing list]
 
 
 
-[Android]: https://github.com/shadowsocks/shadowsocks-android
-[Build Status]: https://img.shields.io/travis/shadowsocks/shadowsocks/master.svg?style=flat
-[Configuration]: https://github.com/shadowsocks/shadowsocks/wiki/Configuration-via-Config-File
-[Coverage Status]: https://jenkins.shadowvpn.org/result/shadowsocks
-[Coverage]: https://jenkins.shadowvpn.org/job/Shadowsocks/ws/PYENV/py34/label/linux/htmlcov/index.html
+[Android]: https://github.com/shadowsocksr/shadowsocksr-android
+[Build Status]: https://travis-ci.org/shadowsocksr/shadowsocksr.svg?branch=manyuser
 [Debian sid]: https://packages.debian.org/unstable/python/shadowsocks
 [iOS]: https://github.com/shadowsocks/shadowsocks-iOS/wiki/Help
-[Issue Tracker]: https://github.com/shadowsocks/shadowsocks/issues?state=open
-[Install Server on Windows]: https://github.com/shadowsocks/shadowsocks/wiki/Install-Shadowsocks-Server-on-Windows
-[Mailing list]: https://groups.google.com/group/shadowsocks
+[Issue Tracker]: https://github.com/shadowsocksr/shadowsocksr/issues?state=open
 [OpenWRT]: https://github.com/shadowsocks/openwrt-shadowsocks
-[OS X]: https://github.com/shadowsocks/shadowsocks-iOS/wiki/Shadowsocks-for-OSX-Help
-[PyPI]: https://pypi.python.org/pypi/shadowsocks
-[PyPI version]: https://img.shields.io/pypi/v/shadowsocks.svg?style=flat
-[Travis CI]: https://travis-ci.org/shadowsocks/shadowsocks
-[Troubleshooting]: https://github.com/shadowsocks/shadowsocks/wiki/Troubleshooting
-[Wiki]: https://github.com/shadowsocks/shadowsocks/wiki
-[Windows]: https://github.com/shadowsocks/shadowsocks-csharp
+[macOS]: https://github.com/shadowsocksr/ShadowsocksX-NG
+[Travis CI]: https://travis-ci.org/shadowsocksr/shadowsocksr
+[Windows]: https://github.com/shadowsocksr/shadowsocksr-csharp
+[Wiki]: https://github.com/breakwa11/shadowsocks-rss/wiki

apiconfig.py

@@ -0,0 +1,15 @@
+# Config
+API_INTERFACE = 'sspanelv2' #mudbjson, sspanelv2, sspanelv3, sspanelv3ssr, glzjinmod, legendsockssr, muapiv2(not support)
+UPDATE_TIME = 60
+SERVER_PUB_ADDR = '127.0.0.1' # mujson_mgr need this to generate ssr link
+
+#mudb
+MUDB_FILE = 'mudb.json'
+
+# Mysql
+MYSQL_CONFIG = 'usermysql.json'
+
+# API
+MUAPI_CONFIG = 'usermuapi.json'
+
+

asyncmgr.py

@@ -0,0 +1,99 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+# Copyright (c) 2014 clowwindy
+#
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the "Software"), to deal
+# in the Software without restriction, including without limitation the rights
+# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+# copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice shall be included in
+# all copies or substantial portions of the Software.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+# SOFTWARE.
+
+import time
+import os
+import socket
+import struct
+import re
+import logging
+from shadowsocks import common
+from shadowsocks import lru_cache
+from shadowsocks import eventloop
+import server_pool
+import Config
+
+class ServerMgr(object):
+
+ def __init__(self):
+ self._loop = None
+ self._request_id = 1
+ self._hosts = {}
+ self._hostname_status = {}
+ self._hostname_to_cb = {}
+ self._cb_to_hostname = {}
+ self._last_time = time.time()
+ self._sock = None
+ self._servers = None
+
+ def add_to_loop(self, loop):
+ if self._loop:
+ raise Exception('already add to loop')
+ self._loop = loop
+ # TODO when dns server is IPv6
+ self._sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM,
+ socket.SOL_UDP)
+ self._sock.bind((Config.MANAGE_BIND_IP, Config.MANAGE_PORT))
+ self._sock.setblocking(False)
+ loop.add(self._sock, eventloop.POLL_IN, self)
+
+ def _handle_data(self, sock):
+ data, addr = sock.recvfrom(128)
+ #manage pwd:port:passwd:action
+ args = data.split(':')
+ if len(args) < 4:
+ return
+ if args[0] == Config.MANAGE_PASS:
+ if args[3] == '0':
+ server_pool.ServerPool.get_instance().cb_del_server(args[1])
+ elif args[3] == '1':
+ server_pool.ServerPool.get_instance().new_server(args[1], args[2])
+
+ def handle_event(self, sock, fd, event):
+ if sock != self._sock:
+ return
+ if event & eventloop.POLL_ERR:
+ logging.error('mgr socket err')
+ self._loop.remove(self._sock)
+ self._sock.close()
+ # TODO when dns server is IPv6
+ self._sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM,
+ socket.SOL_UDP)
+ self._sock.setblocking(False)
+ self._loop.add(self._sock, eventloop.POLL_IN, self)
+ else:
+ self._handle_data(sock)
+
+ def close(self):
+ if self._sock:
+ if self._loop:
+ self._loop.remove(self._sock)
+ self._sock.close()
+ self._sock = None
+
+
+def test():
+ pass
+
+if __name__ == '__main__':
+ test()