`

windows mongodb 集群

 
阅读更多

在一台Windows机器下搭建了一个 Replica Sets + Sharding 测试集群环境，以此作为我后续对于Mongodb更进一步学习的实验平台。

只有一台windows机器，配置方案：
1、3个分片sharding
2、每一个分片由3个节点构成1主2备的Replica Sets
3、3个配置节点Configsever
4、1个路由节点Mongos

分片复制集A（三个分片节点构成一个复制集）：

127.0.0.1:10000   127.0.0.1:10001  127.0.0.1:10002

分片复制集B（三个分片节点构成一个复制集）：

127.0.0.1:20000   127.0.0.1:20001  127.0.0.1:20002 

分片复制集C（三个分片节点构成一个复制集）：

127.0.0.1:30000   127.0.0.1:30001  127.0.0.1:30002

Configsvc（三个配置服务器节点）:

127.0.0.1:40000   127.0.0.1:40001  127.0.0.1:4002

mongos（一个路由节点）:

127.0.0.1:50000

 

详细操作步骤如下：

（1）下载mongodb-win32-i386-1.8.0

下载mongodb-win32-i386-1.8.0版本的Mongodb，放置在d:/mongodb-win32-i386-1.8.0目录下。

（2）创建数据和日志文件目录

进入d:/mongodb-win32-i386-1.8.0目录下创建如下目录

创建数据文件目录：

data/a/r0
data/a/r1
data/a/r2
data/b/r0
data/b/r1
data/b/r2
data/c/r0
data/c/r1
data/c/r2
data/configsvr/r0
data/configsvr/r1
data/configsvr/r2

创建日志文件目录:

logs/a
logs/b
logs/c
logs/configsvr

（3）创建分片和复制集

配置第一组：

从命令行进入d:/mongodb-win32-i386-1.8.0/bin目录，分别执行如下命令！

mongod.exe --logpath d:/mongodb-win32-i386-1.8.0/logs/a/r0.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/a/r0 --port 10000 --shardsvr --replSet setA --rest  --oplogSize 64
mongod.exe --logpath d:/mongodb-win32-i386-1.8.0/logs/a/r1.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/a/r1 --port 10001 --shardsvr --replSet setA --rest  --oplogSize 64
mongod.exe --logpath d:/mongodb-win32-i386-1.8.0/logs/a/r2.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/a/r2 --port 10002 --shardsvr --replSet setA --rest  --oplogSize 64

启动上述分片节点之后，再使用mongo的命令行来初始化复制集

D:/mongodb-win32-i386-1.8.0/bin>call mongo.exe 127.0.0.1:10000/admin
MongoDB shell version: 1.8.0
connecting to: 127.0.0.1:10000/admin
> config={_id: 'setA', members:[{_id: 0,host:'127.0.0.1:10000'},{_id:1,host:'127.0.0.1:10001'},{_id:2,host:'
127.0.0.1:10002'}]}
{
        "_id" : "setA",
        "members" : [
                {
                        "_id" : 0,
                        "host" : "127.0.0.1:10000"
                },
                {
                        "_id" : 1,
                        "host" : "127.0.0.1:10001"
                },
                {
                        "_id" : 2,
                        "host" : "127.0.0.1:10002"
                }
        ]
}
setA> rs.initiate(config);

配置第二组：

从命令行进入d:/mongodb-win32-i386-1.8.0/bin目录，分别执行如下命令！

mongod.exe --logpath d:/mongodb-win32-i386-1.8.0/logs/b/r0.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/b/r0 --port 20000 --shardsvr --replSet setB --rest  --oplogSize 64
mongod.exe --logpath d:/mongodb-win32-i386-1.8.0/logs/b/r1.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/b/r1 --port 20001 --shardsvr --replSet setB --rest  --oplogSize 64
mongod.exe --logpath d:/mongodb-win32-i386-1.8.0/logs/b/r2.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/b/r2 --port 20002 --shardsvr --replSet setB --rest  --oplogSize 64

启动上述分片节点之后，再使用mongo的命令行来初始化复制集

D:/mongodb-win32-i386-1.8.0/bin>call mongo.exe 127.0.0.1:20000/admin
MongoDB shell version: 1.8.0
connecting to: 127.0.0.1:20000/admin
> config={_id: 'setB', members:[{_id: 0,host:'127.0.0.1:20000'},{_id:1,host:'127.0.0.1:20001'},{_id:2,host:'
127.0.0.1:20002'}]}
{
        "_id" : "setB",
        "members" : [
                {
                        "_id" : 0,
                        "host" : "127.0.0.1:20000"
                },
                {
                        "_id" : 1,
                        "host" : "127.0.0.1:20001"
                },
                {
                        "_id" : 2,
                        "host" : "127.0.0.1:20002"
                }
        ]
}
> rs.initiate(config);

配置第三组：

从命令行进入d:/mongodb-win32-i386-1.8.0/bin目录，分别执行如下命令！
mongod.exe --logpath d:/mongodb-win32-i386-1.8.0/logs/c/r0.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/c/r0 --port 30000 --shardsvr --replSet setC --rest  --oplogSize 64
mongod.exe --logpath d:/mongodb-win32-i386-1.8.0/logs/c/r1.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/c/r1 --port 30001 --shardsvr --replSet setC --rest  --oplogSize 64
mongod.exe --logpath d:/mongodb-win32-i386-1.8.0/logs/c/r2.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/c/r2 --port 30002 --shardsvr --replSet setC --rest  --oplogSize 64
D:/mongodb-win32-i386-1.8.0/bin>call mongo.exe 127.0.0.1:30000/admin
MongoDB shell version: 1.8.0
connecting to: 127.0.0.1:30000/admin
> config={_id: 'setC', members:[{_id: 0,host:'127.0.0.1:30000'},{_id:1,host:'127.0.0.1:30001'},{_id:2,host:'
127.0.0.1:30002'}]}
{
        "_id" : "setC",
        "members" : [
                {
                        "_id" : 0,
                        "host" : "127.0.0.1:30000"
                },
                {
                        "_id" : 1,
                        "host" : "127.0.0.1:30001"
                },
                {
                        "_id" : 2,
                        "host" : "127.0.0.1:30002"
                }
        ]
}
> rs.initiate(config);

（4）启动三个配置服务节点Configsvr

从命令行分别执行如下命令，配置三个Configsvr

cd d:/mongodb-win32-i386-1.8.0/bin
call mongod.exe --configsvr --logpath d:/mongodb-win32-i386-1.8.0/logs/configsvr/r0.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/configsvr/r0 --port 40000 --shardsvr

cd d:/mongodb-win32-i386-1.8.0/bin
call mongod.exe --configsvr --logpath d:/mongodb-win32-i386-1.8.0/logs/configsvr/r1.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/configsvr/r1 --port 40001 --shardsvr

cd d:/mongodb-win32-i386-1.8.0/bin
call mongod.exe --configsvr --logpath d:/mongodb-win32-i386-1.8.0/logs/configsvr/r2.log --logappend --dbpath d:/mongodb-win32-i386-1.8.0/data/configsvr/r2 --port 40002 --shardsvr

（5）启动一个路由节点mongos

cd d:/mongodb-win32-i386-1.8.0/bin
call mongos.exe --configdb 127.0.0.1:40000,127.0.0.1:40001,127.0.0.1:40002 --logpath d:/mongodb-win32-i386-1.8.0/logs/mongos.log --logappend --port 50000

（6）配置分片

D:/mongodb-win32-i386-1.8.0/cmd>cd d:/mongodb-win32-i386-1.8.0/bin
D:/mongodb-win32-i386-1.8.0/bin>call mongo.exe 127.0.0.1:50000
MongoDB shell version: 1.8.0
connecting to: 127.0.0.1:50000/test
> use admin
switched to db admin
> db.runCommand({addshard:"setA/127.0.0.1:10000,127.0.0.1:10001,127.0.0.1:10002",name:"ShardSetA"})
{ "shardAdded" : "ShardSetA", "ok" : 1 }
> db.runCommand({addshard:"setB/127.0.0.1:20000,127.0.0.1:20001,127.0.0.1:20002",name:"ShardSetB"})
{ "shardAdded" : "ShardSetB", "ok" : 1 }
> db.runCommand({addshard:"setC/127.0.0.1:30000,127.0.0.1:30001,127.0.0.1:30002",name:"ShardSetC"})
{ "shardAdded" : "ShardSetC", "ok" : 1 }
> printShardingStatus()
--- Sharding Status ---
  sharding version: { "_id" : 1, "version" : 3 }
  shards:
      {
        "_id" : "ShardSetA",
        "host" : "setA/127.0.0.1:10000,127.0.0.1:10001,127.0.0.1:10002"
}
      {
        "_id" : "ShardSetB",
        "host" : "setB/127.0.0.1:20000,127.0.0.1:20001,127.0.0.1:20002"
}
      {
        "_id" : "ShardSetC",
        "host" : "setC/127.0.0.1:30000,127.0.0.1:30001,127.0.0.1:30002"
}
  databases:
        { "_id" : "admin", "partitioned" : false, "primary" : "config" }

配置到这里，集群搭建完毕了！

在完成了集群的搭建工作之后，需要做的就是建立一个数据库，建立表，设置分片主键来初始化数据了！

 

Mongodb集群JavaAPI插入数据 .


在完成了集群的搭建工作之后，需要做的就是建立一个数据库，建立表，设置分片主键来初始化数据了！

 

> call mongo.exe 127.0.0.1:50000


> use wlb

>db.createCollection('wlb_orders')

> use admin


>db.runCommand({enablesharding:'wlb'})

>db.runCommand({shardcollection:'wlb.wlb_orders',key:{order_id:1}})  //设置表的分区主键为

> db.printShardingStatus() //查询数据库分片信息

 

（2）用Java代码完成数据初始化

package com.zhangzk.mongodb;

import java.net.UnknownHostException;
import java.util.Date;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.Mongo;
import com.mongodb.MongoException;

public class MongodbTest {
 
 /**
  * 30W 288391
  *
  * @param args
  */
 public static void main(String[] args) {
  initData();
  // query();
 }
 
 private static void initData() {
  long start = new Date().getTime();
  try {
   Mongo db = new Mongo("127.0.0.1", 50000);
   DB mydb = db.getDB("wlb");
   DBCollection coll = mydb.getCollection("wlb_orders");
   for (long i = 1; i <= 300000; i++) {
    BasicDBObject doc = new BasicDBObject();
    doc.put("order_id", i);
    doc.put("company_id", 505 + i);
    doc.put("user_id", 180225429 + i);
    doc.put("fetcher_id", 59803 + i);
    doc.put("fetch_schedule_begin", new Date());
    doc.put("fetch_schedule_end", new Date());
    doc.put("sender_id", 59803 + i);
    doc.put("mail_no", "000000");
    doc.put("mail_type", "301");
    doc.put("order_code", "LP10012700003959" + i);
    doc.put("order_status", 30);
    doc.put("prev_order_id", 0);
    doc.put("trade_id", 2010012706189794L + i);
    doc.put("goods_remark", "");
    doc.put("receiver_name", " 凯撒");
    doc.put("receiver_wangwang_id", "sanglin01");
    doc.put("receiver_mobile_phone", "13021525841");
    doc.put("receiver_zip_code", "650045");
    doc.put("receiver_telephone", "13868117135");
    doc.put("receiver_county_id", 350102);
    doc.put("receiver_address", "福建省^^^福州市^^^鼓楼区^^^的萨芬萨芬萨芬的12号");
    doc.put("gmt_create", new Date());
    doc.put("gmt_modified", new Date());
    doc.put("status_reason", "");
    doc.put("logis_type", 0);
    doc.put("seller_wangwang_id", "tbtest943" + i);
    doc.put("seller_send_confirm", 0);
    doc.put("shipping", 2);
    doc.put("company_code", "");
    doc.put("taobao_trade_id", "2232358300" + i);
    doc.put("options", 2);
    doc.put("shipping2", 0);
    doc.put("order_source", 0);
    doc.put("status_date", new Date());
    doc.put("timeout_status", 2);
    doc.put("feature", "ip=127.0.0.1;SFID=");
    doc.put("service_fee", 0);
    doc.put("seller_store_id", "23100");
    doc.put("items_value", 23100);
    doc.put("pre_status", 0);
    doc.put("ticket_id", "");
    doc.put("tfs_url", "T1DoBbXctCXXXXXXXX");
    coll.insert(doc);
   }
   db.close();
   long endTime = new Date().getTime();
   System.out.println(endTime - start);
   System.out.println((endTime - start) / 10000000);
  } catch (UnknownHostException e) {
   e.printStackTrace();
  } catch (MongoException e) {
   e.printStackTrace();
  }
 }
} 

分享到：
| spring的ioc类图
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    单台windows搭建mongoDb主从集群

    在Windows环境中，搭建MongoDB的主从复制集群是一项常见的任务，以实现数据冗余和高可用性。以下是关于"单台windows搭建mongoDb主从集群"的知识点详细说明： 1. **主从复制（Replication）**: MongoDB的主从复制是...

    MongoDB集群搭建

    MongoDB MongoDB集群搭建 环境集群搭建 MongoDB MongoDB集群搭建 环境集群搭建

    mongodb　集群完整版

    mongodb集群 shard replset 分片 包括windows 和 linux两个版本

    Win10 64位+mongodb集群搭建

    在本文中，我们将深入探讨如何在Windows 10 64位操作系统上搭建MongoDB集群。MongoDB是一个流行的开源、高性能、无模式的文档数据库，适用于处理大量的结构化和非结构化数据。集群搭建能够提供高可用性、容错性和...

    mongodb集群搭建教程

    ### MongoDB集群搭建教程 #### 一、主从模式详解 **主从模式**是MongoDB中最常见的复制方式之一，主要用于实现数据库同步备份、故障恢复以及读取扩展等功能。该模式的核心在于建立一个主节点和一个或多个从节点，...

    MongoDB集群管理工具mongo3.zip

    mongo 是一款超酷的 MongoDB 集群管理工具，它本身提供一个 web 控制台，让你可以像维护普通数据库一样维护 MongoDB。主要特性：非常容易管理你的 MongoDB 集群信息可以获取你配置的实时快照信息深入集群，数据库，...

    mongo-docker, 基于 Docker的即时MongoDB集群环境.zip

    mongo-docker, 基于 Docker的即时MongoDB集群环境 即时MongoDB分片集群这个库为 Vagrantfile 。Dockerfile和 Bootstrap 脚本提供了使用Virtualbox软件管理程序构建的虚拟机来创建MongoDB集群。 在安装完成后，在本地...

    C#开发的Mongodb集群自动部署工具

    本项目是用C#语言开发的一个MongoDB集群自动部署工具，它的主要目标是简化在Linux服务器上部署和管理MongoDB副本集的过程。C#是一种通用的、面向对象的编程语言，通常用于Windows平台，但通过.NET框架和开源库，也...

    mongoDB集群实战.pdf

    MongoDB集群实战的知识点包括了MongoDB的基本概念、集群的部署方法以及主从复制模式的实战部署步骤。 首先，我们来看MongoDB的基本概念。MongoDB是一个开源的非关系型数据库，它的特点包括分布式存储、面向文档的...

    Linux_64位 MongoDB集群软件及详细步骤

    在Linux 64位环境下搭建MongoDB集群，能够实现数据的高可用性和可扩展性。以下是对"Linux_64位 MongoDB集群软件及详细步骤"的详细解析。 1. **MongoDB简介** MongoDB是一种NoSQL数据库，它采用键值对、文档、集合...

    windows mongodb 32位

    在Windows操作系统上，特别是32位系统中，MongoDB提供了支持，以满足那些仍在使用32位系统的用户需求。MongoDB的32位版本虽然在内存使用和性能上可能受限，但它仍然是一个可靠的数据库解决方案，尤其适合小型项目或...

    windows下mongodb的安装

    在Windows上安装MongoDB的步骤如下： 1. 访问MongoDB官方网站（https://www.mongodb.com/download-center），找到对应版本的msi安装包进行下载。 2. 下载完成后，双击安装包，按照向导指示进行安装。可以选择自定义...

    MongoDB4.2分片及副本集群搭建.docx

    MongoDB4.2分片及副本集群搭建详细指导手册，详细描述了MongoDB4.2数据库服务器集群的搭建以及副本和分片服务的配置过程及具体操作指令。

    monggodb集群搭建文档

    ### MongoDB集群搭建详解 #### 一、概述 MongoDB 是一款非常流行的开源文档数据库系统，以其灵活的数据模型、高可用性和可扩展性而受到广泛欢迎。对于需要处理大量数据的应用程序来说，MongoDB 的集群技术提供了...

Magicbox
Global site tag (gtag.js) - Google Analytics