文章目錄

ManggoDB
- 參考資料
- 安裝配置
- 配置
MongoDB 復制集（Replica Set）搭建
- 搭建偽節點
- 集群測驗
- 注意
- 配置Debezium的connect
- - 連接器
  - 創建資料庫
  - 組態檔啟動
  - 注意關閉順序
  - 檢驗
  - 解決無法遠程連接的問題-服務啟動失敗
  - 組態檔
- 待解決服務啟動問題
Linux
- wget下載url檔案

ManggoDB

參考資料

介于關系型資料庫非關系型資料庫之間
菜鳥教程
https://www.runoob.com/mongodb
https://www.mongodb.org.cn/

安裝配置

MongoDB 原始碼下載地址：https://www.mongodb.com/download-center#community
在這里插入圖片描述
centos下載
wget下載url檔案

// 安裝wget命令
yum install wget
// 直接下載檔案url
wget 檔案url

// 獲取路徑
pwd
/opt/install/mongodb-linux-x86_64-rhel70-4.4.1
// 修改配置
vi /etc/profile
source /etc/profile
//

配置

tgz沒找到conf
rpm安裝，不建議使用直接配置conf添加配置吧

// rpm安裝
rpm -ivh rpm檔案
// 查看帶mongo的檔案
find / -name mongo
// 查看是否啟了行程
ps -aux | grep mongo
// 查看mongod配置資訊
more /usr/lib/systemd/system/mongod.service
[root@hadoop01 etc]# more /usr/lib/systemd/system/mongod.service
[Unit]
Description=MongoDB Database Server
Documentation=https://docs.mongodb.org/manual
After=network.target

[Service]
User=mongod
Group=mongod
Environment="OPTIONS=-f /etc/mongod.conf"
EnvironmentFile=-/etc/sysconfig/mongod
ExecStart=/usr/bin/mongod $OPTIONS
ExecStartPre=/usr/bin/mkdir -p /var/run/mongodb
ExecStartPre=/usr/bin/chown mongod:mongod /var/run/mongodb
ExecStartPre=/usr/bin/chmod 0755 /var/run/mongodb
PermissionsStartOnly=true
PIDFile=/var/run/mongodb/mongod.pid

more /etc/mongod.conf

vi mongodb.conf
在這里插入圖片描述

// 參考補充

#開放所有的ip可訪問
bind_ip=0.0.0.0  
port=27017
#如果沒有目錄需要創建
dbpath=/opt /module/mongodb/data
#如果沒有目錄需要創建
logpath=/opt/module/mongodb/log/out.log  
logappend=true

啟動
到達.conf的目錄

mongod -f mongodb.conf &

驗證（訪問url輸出字符）

// 法1看url 埠
http://192.168.137.121:27017/
It looks like you are trying to access MongoDB over HTTP on the native driver port.

// 法2 看行程
[root@hadoop01 kafka_2.13-2.6.0]# ps -ef | grep mongo
root      20603      1  1 10月30 ?      00:00:11 mongod -f mongod.conf

連接客戶端

// mongo有自帶的shell
etc]# mongo
>1+1
>2
> show dbs
admin   0.000GB
config  0.000GB
local   0.000GB

MongoDB 復制集（Replica Set）搭建

通常，為了防止單點故障應用程式需要做集群，然而在資料庫中除了防止單點故障，還需要做到資料庫備份，讀寫分離，故障轉移等，而 MongoDB 的 Replica Set 恰恰都能滿足這些要求，

搭建偽節點

// 準備資料輸出目錄
[root@hadoop01 mongo]# pwd
/opt/install/mongo
[root@hadoop01 mongo]# ll
總用量 0
drwxr-xr-x. 2 root root 6 10月 31 00:49 data1
drwxr-xr-x. 2 root root 6 10月 31 00:49 data2
drwxr-xr-x. 2 root root 6 10月 31 00:49 data3

// 到/etc目錄下，有mongo 進行三個偽行程啟動
27017
27027
27037

mongod --port 27017 --dbpath /opt/install/mongo/data1 --replSet myrs
mongod --port 27027 --dbpath /opt/install/mongo/data2 --replSet myrs
mongod --port 27037 --dbpath /opt/install/mongo/data3 --replSet myrs

// 鏈接到啟動的行程服務
mongo -port 27017

在Mongo客戶端使用命令rs.initiate()來啟動一個新的副本集，
我們可以使用rs.conf()來查看副本集的配置
查看副本集狀態使用 rs.status() 命令

只能通過主節點，添加到副節點中，判斷當前運行的Mongo服務是否為主節點可以使用命令db.isMaster() 

// 啟動一個新的副本集
rs.initiate()
myrs:PRIMARY> rs.conf()
{
	"_id" : "myrs",
	"version" : 1,
	"term" : 1,
	"protocolVersion" : NumberLong(1),
	"writeConcernMajorityJournalDefault" : true,
	"members" : [
		{
			"_id" : 0,
			"host" : "localhost:27017",
			"arbiterOnly" : false,
			"buildIndexes" : true,
			"hidden" : false,
			"priority" : 1,
			"tags" : {
				
			},
			"slaveDelay" : NumberLong(0),
			"votes" : 1
		}
	],
	"settings" : {
		"chainingAllowed" : true,
		"heartbeatIntervalMillis" : 2000,
		"heartbeatTimeoutSecs" : 10,
		"electionTimeoutMillis" : 10000,
		"catchUpTimeoutMillis" : -1,
		"catchUpTakeoverDelayMillis" : 30000,
		"getLastErrorModes" : {
			
		},
		"getLastErrorDefaults" : {
			"w" : 1,
			"wtimeout" : 0
		},
		"replicaSetId" : ObjectId("5f9fc57450e3bf89a3a1016c")
	}
}

// 添加除此節點的另外兩個節點
myrs:PRIMARY> rs.add("127.0.0.1:27027")
{
	"ok" : 1,
	"$clusterTime" : {
		"clusterTime" : Timestamp(1604306642, 2),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	},
	"operationTime" : Timestamp(1604306642, 2)
}
// 添加另外一個節點
myrs:PRIMARY> rs.add("127.0.0.1:27037")
{
	"ok" : 1,
	"$clusterTime" : {
		"clusterTime" : Timestamp(1604306692, 2),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	},
	"operationTime" : Timestamp(1604306692, 2)
}

// 檢測master
myrs:PRIMARY> db.isMaster()
{
	"topologyVersion" : {
		"processId" : ObjectId("5f9fc36d50e3bf89a3a10155"),
		"counter" : NumberLong(8)
	},
	"hosts" : [
		"localhost:27017",
		"127.0.0.1:27027",
		"127.0.0.1:27037"
	],
	"setName" : "myrs",
	"setVersion" : 3,
	"ismaster" : true,
	"secondary" : false,
	"primary" : "localhost:27017",
	"me" : "localhost:27017",
	"electionId" : ObjectId("7fffffff0000000000000001"),
	"lastWrite" : {
		"opTime" : {
			"ts" : Timestamp(1604306752, 1),
			"t" : NumberLong(1)
		},
		"lastWriteDate" : ISODate("2020-11-02T08:45:52Z"),
		"majorityOpTime" : {
			"ts" : Timestamp(1604306752, 1),
			"t" : NumberLong(1)
		},
		"majorityWriteDate" : ISODate("2020-11-02T08:45:52Z")
	},
	"maxBsonObjectSize" : 16777216,
	"maxMessageSizeBytes" : 48000000,
	"maxWriteBatchSize" : 100000,
	"localTime" : ISODate("2020-11-02T08:46:00.379Z"),
	"logicalSessionTimeoutMinutes" : 30,
	"connectionId" : 1,
	"minWireVersion" : 0,
	"maxWireVersion" : 9,
	"readOnly" : false,
	"ok" : 1,
	"$clusterTime" : {
		"clusterTime" : Timestamp(1604306752, 1),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	},
	"operationTime" : Timestamp(1604306752, 1)
}

// status
myrs:PRIMARY> rs.status()
{
	"set" : "myrs",
	"date" : ISODate("2020-11-02T08:46:59.662Z"),
	"myState" : 1,
	"term" : NumberLong(1),
	"syncSourceHost" : "",
	"syncSourceId" : -1,
	"heartbeatIntervalMillis" : NumberLong(2000),
	"majorityVoteCount" : 2,
	"writeMajorityCount" : 2,
	"votingMembersCount" : 3,
	"writableVotingMembersCount" : 3,
	"optimes" : {
		"lastCommittedOpTime" : {
			"ts" : Timestamp(1604306812, 1),
			"t" : NumberLong(1)
		},
		"lastCommittedWallTime" : ISODate("2020-11-02T08:46:52.212Z"),
		"readConcernMajorityOpTime" : {
			"ts" : Timestamp(1604306812, 1),
			"t" : NumberLong(1)
		},
		"readConcernMajorityWallTime" : ISODate("2020-11-02T08:46:52.212Z"),
		"appliedOpTime" : {
			"ts" : Timestamp(1604306812, 1),
			"t" : NumberLong(1)
		},
		"durableOpTime" : {
			"ts" : Timestamp(1604306812, 1),
			"t" : NumberLong(1)
		},
		"lastAppliedWallTime" : ISODate("2020-11-02T08:46:52.212Z"),
		"lastDurableWallTime" : ISODate("2020-11-02T08:46:52.212Z")
	},
	"lastStableRecoveryTimestamp" : Timestamp(1604306772, 1),
	"electionCandidateMetrics" : {
		"lastElectionReason" : "electionTimeout",
		"lastElectionDate" : ISODate("2020-11-02T08:38:12.097Z"),
		"electionTerm" : NumberLong(1),
		"lastCommittedOpTimeAtElection" : {
			"ts" : Timestamp(0, 0),
			"t" : NumberLong(-1)
		},
		"lastSeenOpTimeAtElection" : {
			"ts" : Timestamp(1604306292, 1),
			"t" : NumberLong(-1)
		},
		"numVotesNeeded" : 1,
		"priorityAtElection" : 1,
		"electionTimeoutMillis" : NumberLong(10000),
		"newTermStartDate" : ISODate("2020-11-02T08:38:12.118Z"),
		"wMajorityWriteAvailabilityDate" : ISODate("2020-11-02T08:38:12.145Z")
	},
	"members" : [
		{
			"_id" : 0,
			"name" : "localhost:27017",
			"health" : 1,
			"state" : 1,
			"stateStr" : "PRIMARY",
			"uptime" : 1046,
			"optime" : {
				"ts" : Timestamp(1604306812, 1),
				"t" : NumberLong(1)
			},
			"optimeDate" : ISODate("2020-11-02T08:46:52Z"),
			"syncSourceHost" : "",
			"syncSourceId" : -1,
			"infoMessage" : "",
			"electionTime" : Timestamp(1604306292, 2),
			"electionDate" : ISODate("2020-11-02T08:38:12Z"),
			"configVersion" : 3,
			"configTerm" : 1,
			"self" : true,
			"lastHeartbeatMessage" : ""
		},
		{
			"_id" : 1,
			"name" : "127.0.0.1:27027",
			"health" : 1,
			"state" : 2,
			"stateStr" : "SECONDARY",
			"uptime" : 176,
			"optime" : {
				"ts" : Timestamp(1604306812, 1),
				"t" : NumberLong(1)
			},
			"optimeDurable" : {
				"ts" : Timestamp(1604306812, 1),
				"t" : NumberLong(1)
			},
			"optimeDate" : ISODate("2020-11-02T08:46:52Z"),
			"optimeDurableDate" : ISODate("2020-11-02T08:46:52Z"),
			"lastHeartbeat" : ISODate("2020-11-02T08:46:58.918Z"),
			"lastHeartbeatRecv" : ISODate("2020-11-02T08:46:58.959Z"),
			"pingMs" : NumberLong(0),
			"lastHeartbeatMessage" : "",
			"syncSourceHost" : "localhost:27017",
			"syncSourceId" : 0,
			"infoMessage" : "",
			"configVersion" : 3,
			"configTerm" : 1
		},
		{
			"_id" : 2,
			"name" : "127.0.0.1:27037",
			"health" : 1,
			"state" : 2,
			"stateStr" : "SECONDARY",
			"uptime" : 126,
			"optime" : {
				"ts" : Timestamp(1604306812, 1),
				"t" : NumberLong(1)
			},
			"optimeDurable" : {
				"ts" : Timestamp(1604306812, 1),
				"t" : NumberLong(1)
			},
			"optimeDate" : ISODate("2020-11-02T08:46:52Z"),
			"optimeDurableDate" : ISODate("2020-11-02T08:46:52Z"),
			"lastHeartbeat" : ISODate("2020-11-02T08:46:58.940Z"),
			"lastHeartbeatRecv" : ISODate("2020-11-02T08:46:59.287Z"),
			"pingMs" : NumberLong(0),
			"lastHeartbeatMessage" : "",
			"syncSourceHost" : "127.0.0.1:27027",
			"syncSourceId" : 1,
			"infoMessage" : "",
			"configVersion" : 3,
			"configTerm" : 1
		}
	],
	"ok" : 1,
	"$clusterTime" : {
		"clusterTime" : Timestamp(1604306812, 1),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	},
	"operationTime" : Timestamp(1604306812, 1)
}

集群測驗

在主節點（40000）插入、查詢資料，是否成功？
在從節點（40001）插入、查詢資料，是否成功？
主節點（40000）關閉
查看從節點，看從節點是否成為主節點
重新啟動原來的主節點（40000），查看節點狀態

myapp:PRIMARY> db.stu.find()
myapp:PRIMARY> db.stu.insert({name:'zhangsan'})
WriteResult({ "nInserted" : 1 })
myapp:PRIMARY> db.stu.find()
{ "_id" : ObjectId("5f58d9aaafeaa3a829c63d4b"), "name" : "zhangsan" }
myapp:PRIMARY>




//主節點關機（40000）


myapp:PRIMARY> use admin
switched to db admin
myapp:PRIMARY> db.shutdownServer()
server should be down...
2020-09-09T21:38:20.925+0800 I NETWORK  [thread1] trying reconnect to 127.0.0.1:40000 (127.0.0.1) failed
2020-09-09T21:38:21.635+0800 I NETWORK  [thread1] Socket recv() Connection reset by peer 127.0.0.1:40000
2020-09-09T21:38:21.635+0800 I NETWORK  [thread1] SocketException: remote: (NONE):0 error: SocketException socket exception [RECV_ERROR] server [127.0.0.1:40000] 
2020-09-09T21:38:21.636+0800 I NETWORK  [thread1] reconnect 127.0.0.1:40000 (127.0.0.1) failed failed 
>

//觀察從節點，40002成為master
[hadoop@hadoop1 bin]$ mongo -port 40002

myapp:PRIMARY> db.isMaster()
{
	"hosts" : [
		"localhost:40000",
		"127.0.0.1:40001",
		"127.0.0.1:40002"
	],
	"setName" : "myapp",
	"setVersion" : 3,
	"ismaster" : true,
	"secondary" : false,
	"primary" : "127.0.0.1:40002",
	"me" : "127.0.0.1:40002",
	"electionId" : ObjectId("7fffffff0000000000000002"),
	"lastWrite" : {
		"opTime" : {
			"ts" : Timestamp(1599658861, 1),
			"t" : NumberLong(2)
		},
		"lastWriteDate" : ISODate("2020-09-09T13:41:01Z"),
		"majorityOpTime" : {
			"ts" : Timestamp(1599658861, 1),
			"t" : NumberLong(2)
		},
		"majorityWriteDate" : ISODate("2020-09-09T13:41:01Z")
	},
	"maxBsonObjectSize" : 16777216,
	"maxMessageSizeBytes" : 48000000,
	"maxWriteBatchSize" : 100000,
	"localTime" : ISODate("2020-09-09T13:41:04.249Z"),
	"logicalSessionTimeoutMinutes" : 30,
	"minWireVersion" : 0,
	"maxWireVersion" : 6,
	"readOnly" : false,
	"ok" : 1,
	"operationTime" : Timestamp(1599658861, 1),
	"$clusterTime" : {
		"clusterTime" : Timestamp(1599658861, 1),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	}
}
myapp:PRIMARY>

// 40002 可以查詢資料
myapp:PRIMARY> db.stu.find()
{ "_id" : ObjectId("5f58d9aaafeaa3a829c63d4b"), "name" : "zhangsan" }
myapp:PRIMARY>

// 40001 不允許查詢資料
myapp:SECONDARY> db.stu.find()
Error: error: {
	"operationTime" : Timestamp(1599658961, 1),
	"ok" : 0,
	"errmsg" : "not master and slaveOk=false",
	"code" : 13435,
	"codeName" : "NotMasterNoSlaveOk",
	"$clusterTime" : {
		"clusterTime" : Timestamp(1599658961, 1),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	}
}
myapp:SECONDARY>


重新啟動40000


[hadoop@hadoop1 bin]$ mongod --replSet myapp --dbpath /opt/module/mongodb/data1 --port 40000

[hadoop@hadoop1 bin]$ mongo -port 40000


myapp:SECONDARY> rs.isMaster()
{
	"hosts" : [
		"localhost:40000",
		"127.0.0.1:40001",
		"127.0.0.1:40002"
	],
	"setName" : "myapp",
	"setVersion" : 3,
	"ismaster" : false,
	"secondary" : true,
	"primary" : "127.0.0.1:40002",
	"me" : "localhost:40000",
	"lastWrite" : {
		"opTime" : {
			"ts" : Timestamp(1599659401, 1),
			"t" : NumberLong(2)
		},
		"lastWriteDate" : ISODate("2020-09-09T13:50:01Z"),
		"majorityOpTime" : {
			"ts" : Timestamp(1599659401, 1),
			"t" : NumberLong(2)
		},
		"majorityWriteDate" : ISODate("2020-09-09T13:50:01Z")
	},
	"maxBsonObjectSize" : 16777216,
	"maxMessageSizeBytes" : 48000000,
	"maxWriteBatchSize" : 100000,
	"localTime" : ISODate("2020-09-09T13:50:10.511Z"),
	"logicalSessionTimeoutMinutes" : 30,
	"minWireVersion" : 0,
	"maxWireVersion" : 6,
	"readOnly" : false,
	"ok" : 1,
	"operationTime" : Timestamp(1599659401, 1),
	"$clusterTime" : {
		"clusterTime" : Timestamp(1599659401, 1),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	}
}
myapp:SECONDARY>

注意

只能通過主節點，添加到副節點中，判斷當前運行的Mongo服務是否為主節點可以使用命令db.isMaster()
只能通過，主節點來查

配置Debezium的connect

參考博客
local下的讀權限，獲取日志
zookeeper和kafka的啟動
連接的debezium啟動

./bin/connect-distributed.sh -daemon config/connect-distributed.properties
# 分布式啟動，單例模式需要指定下一個代碼段的配置資訊

kafka的conf檔案夾中找到connect-distributed.properties檔案(同mysql的偽分布式配置一樣)

連接器

在這里插入圖片描述

'{
"name": "mongodb-connector",   # 名字自己取
    "config": {
        "connector.class": "io.debezium.connector.mongodb.MongoDbConnector",  # connector連接器class名稱
        "task.max": "1",        
        "mongodb.hosts": "rs77/172.168.31.77:27001, rs77/172.168.31.77:27002, rs77/172.168.31.77:27003",  # 這里注意要副本集+地址埠形式，不然可能無法連接
        "mongodb.user": "mongo", 
        "mongodb.password": "123", 
        "mongodb.authsource": "kafkatest",  # 認證庫， 即你shell登錄要先use到所在的庫才可以進行改庫的賬戶登錄 
        "mongodb.name": "rs77",     # 副本集名稱
        "database.history.kafka.bootstrap.servers": "172.168.31.77:9092, 172.168.31.78:9092, 172.168.31.79:9092",  # kafka地址
        "snapshot.delay.ms": "3000", 
        "database.whitelist": "kafkatest"   # 監測的庫名，可以正則匹配
        }
}'

實際使用

{
  "name": "mongodb-connector",  
  "config": {
    "connector.class": "io.debezium.connector.mongodb.MongoDbConnector", 
    "mongodb.hosts": "myrs/192.168.137.121:27017, myrs/192.168.137.121:27027, myrs/192.168.137.121:27037", 
    "mongodb.name": "myrs", 
    "database.history.kafka.bootstrap.servers": "192.168.137.121:9092", 
    "collection.whitelist": "kafkatest"
  }
}

昌杰修正版

{
        "connector.class": "io.debezium.connector.mongodb.MongoDbConnector",
        "name": "mongodb-connector1",
        "mongodb.name": "myrs",
        "mongodb.hosts": "myrs/192.168.137.121:27017",
        "collection.whitelist": "kafkatest.rxguo"
    }

創建資料庫

myrs:PRIMARY> use kafkatest
switched to db kafkatest
myrs:PRIMARY> db
kafkatest
myrs:PRIMARY> show dbs
admin   0.000GB
config  0.000GB
local   0.001GB
test    0.000GB
myrs:PRIMARY> db.kafkatest.insert({"name", "菜鳥教程"})
uncaught exception: SyntaxError: missing : after property id :
@(shell):1:27
myrs:PRIMARY> db
kafkatest
myrs:PRIMARY> db.kafkatest.insert({"name", "測驗"})
uncaught exception: SyntaxError: missing : after property id :
@(shell):1:27
myrs:PRIMARY> db.kafkatest.insert({"name":"測驗"})
WriteResult({ "nInserted" : 1 })
myrs:PRIMARY> db.kafkatest.insert({"name":"菜鳥教程"})
WriteResult({ "nInserted" : 1 })
myrs:PRIMARY> show dbs
admin      0.000GB
config     0.000GB
kafkatest  0.000GB
local      0.001GB
test       0.000GB

組態檔啟動

// 注意兩個--port
mongo --port 27017
rs.initiate()



rs.add("192.168.137.121:27017")
rs.add("192.168.137.121:27027")
rs.add("192.168.137.121:27037")


myrs:PRIMARY> rs.conf()
{
	"_id" : "myrs",
	"version" : 3,
	"term" : 2,
	"protocolVersion" : NumberLong(1),
	"writeConcernMajorityJournalDefault" : true,
	"members" : [
		{
			"_id" : 0,
			"host" : "hadoop01:27017",
			"arbiterOnly" : false,
			"buildIndexes" : true,
			"hidden" : false,
			"priority" : 1,
			"tags" : {
				
			},
			"slaveDelay" : NumberLong(0),
			"votes" : 1
		},
		{
			"_id" : 1,
			"host" : "192.168.137.121:27027",
			"arbiterOnly" : false,
			"buildIndexes" : true,
			"hidden" : false,
			"priority" : 1,
			"tags" : {
				
			},
			"slaveDelay" : NumberLong(0),
			"votes" : 1
		},
		{
			"_id" : 2,
			"host" : "192.168.137.121:27037",
			"arbiterOnly" : false,
			"buildIndexes" : true,
			"hidden" : false,
			"priority" : 1,
			"tags" : {
				
			},
			"slaveDelay" : NumberLong(0),
			"votes" : 1
		}
	],
	"settings" : {
		"chainingAllowed" : true,
		"heartbeatIntervalMillis" : 2000,
		"heartbeatTimeoutSecs" : 10,
		"electionTimeoutMillis" : 10000,
		"catchUpTimeoutMillis" : -1,
		"catchUpTakeoverDelayMillis" : 30000,
		"getLastErrorModes" : {
			
		},
		"getLastErrorDefaults" : {
			"w" : 1,
			"wtimeout" : 0
		},
		"replicaSetId" : ObjectId("5fa12b198c2c3960105a9151")
	}
}

Environment=“OPTIONS=-f /etc/mongod27017.conf”

正確關閉mongod 的方法：進入mongo shell

    use admin
    db.shutdownServer()

注意關閉順序

洗掉掉該檔案:

rm /data/db/mongo.lock

再執行:

./mongod --repair

檢驗

在這里插入圖片描述

// 查看創建的topic資訊
bin/kafka-topics.sh --list --zookeeper 192.168.137.121:2181 rxguo-topic
// 輸出kafka對應的連接器內容
bin/kafka-console-consumer.sh --bootstrap-server 192.168.137.121:9092 --topic myrs.kafkatest.rxguo --from-beginning

解決無法遠程連接的問題-服務啟動失敗

常見問題1：
開放埠
在這里插入圖片描述

問題二服務未啟動
查看狀態service mongod status
開啟服務sudo service mongod start

Redirecting to /bin/systemctl start mongod.service
Job for mongod.service failed because the control process exited with error code. See "systemctl status mongod.service" and "journalctl -xe" for details.

mongod[6108]: ERROR: child process failed, exited with 14
錯誤原因: mongodb非正常關閉洗掉mongod.lock檔案即可.
ERROR: child process failed, exited with error number 100
錯誤原因: mongodb非正常關閉洗掉mongod.lock檔案即可.
ERROR: child process failed ,exited with error number 1
錯誤原因: dbpath檔案的權限問題,增加寫權限即可
mongodb.conf bind 不能寫127.0.0.1否則其它主機連接不了
情況不唯一，這邊只能當參考，大致就是這么幾種解決思路

exited with 1，說明第一行就是錯的就退出了，應該是一開頭的路徑配置就有錯誤，

這里可能的原因有以下幾種：

1.排查檔案名稱，到底是mongodb.conf 還是 mongod.conf；

2.排查當前bin檔案中，mongodb.conf這個檔案內的內容是否配置路徑是正確的？

3.執行sudo nano /etc/systemd/system/mongodb.service，排查其中的路徑是否正確，是否是指向配置的mongod.conf檔案和mongod檔案，尤其要仔細看到底是放在usr/bin還是usr/bin/local還是usr/etc還是……（等等等路徑）下的，這個路徑要與mongodb.conf中配置的路徑吻合，

修改完成后，執行如下代碼：

systemctl daemon-reload

sudo systemctl start mongodb

sudo systemctl status mongodb

出現綠色的Active: active(running)時，成功，

組態檔

如果組態檔方式啟動
注意三個檔案指定不同的path前綴

[root@hadoop01 mongo]# pwd
/opt/install/mongo
[root@hadoop01 mongo]# ll
總用量 12
drwxr-xr-x. 4 root root 4096 11月  3 17:22 data1
drwxr-xr-x. 4 root root 4096 11月  3 17:17 data2
drwxr-xr-x. 4 root root 4096 11月  3 17:18 data3

啟動指定組態檔mongod -f mongod27017.conf

# mongod.conf

# for documentation of all options, see:
#   http://docs.mongodb.org/manual/reference/configuration-options/

# where to write logging data.
systemLog:
  destination: file
  logAppend: true
  path: /opt/install/mongo/data1/mongod.log

# Where and how to store data.
storage:
  dbPath: /opt/install/mongo/data1
  journal:
    enabled: true
#  engine:
#  wiredTiger:

# how the process runs
processManagement:
  fork: true  # fork and run in background
  pidFilePath: /opt/install/mongo/data1/mongod.pid  # location of pidfile
  timeZoneInfo: /usr/share/zoneinfo

# network interfaces
net:
  port: 27017
  bindIp: 0.0.0.0  # Enter 0.0.0.0,:: to bind to all IPv4 and IPv6 addresses or, alternatively, use the net.bindIpAll setting.


#security:

#operationProfiling:

replication:
  replSetName: myrs
#sharding:

## Enterprise-Only Options

#auditLog:

#snmp:

待解決服務啟動問題

Linux

wget下載url檔案

// 安裝wget命令
yum install wget
// 直接下載檔案url
wget 檔案url

瑞新

CSDN認證博客專家分布式 Java 架構

求職中 ? Java全堆疊養成計劃
公眾號 ? 讓我遇見相似的靈魂
回復領取：競賽書籍專案面試

左手代碼，右手吉他，這就是天下:如果有一天我遇見相似的靈魂那它肯定是步履艱難不被理解喜黑怕光的，如果可以的話讓我觸摸一下吧它也一樣孤獨得太久，不一樣的文藝青年，不一樣的程式猿，

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/204150.html

標籤：python

上一篇：JavaScript 穩居第一、C# 連續下跌，調查 17000 名程式員后有了這些新發現！

下一篇：java后端工程師平時開發或多或少會用到Intellij idea，那么它有哪些快捷鍵呢

【ManggoDB】安裝配置（偽分布式集群搭建）Replia Set